diff options
| -rw-r--r-- | src/couchdb/couch_rep.erl | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/couchdb/couch_rep.erl b/src/couchdb/couch_rep.erl index 7aa491ae..4c938683 100644 --- a/src/couchdb/couch_rep.erl +++ b/src/couchdb/couch_rep.erl @@ -527,7 +527,13 @@ do_checkpoint(Source, Target, Context, NewSeqNum, Stats) -> % commit tgt sync {ok, TgtInstanceStartTime2} = ensure_full_commit(Target), - receive {SrcCommitPid, {ok, SrcInstanceStartTime2}} -> ok end, + SrcInstanceStartTime2 = + receive + {SrcCommitPid, {ok, Timestamp}} -> + Timestamp; + {'EXIT', SrcCommitPid, {http_request_failed, _}} -> + exit(replication_link_failure) + end, RecordSeqNum = if SrcInstanceStartTime2 == SrcInstanceStartTime andalso |