You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by va...@apache.org on 2016/08/15 07:23:30 UTC
couch-replicator commit: updated
refs/heads/3104-fix-replicator-manager-changes-feed-checkpoint to f67ebff
Repository: couchdb-couch-replicator
Updated Branches:
refs/heads/3104-fix-replicator-manager-changes-feed-checkpoint 40a087630 -> f67ebff22
Fix passing epoch in correctly with rep_db_checkpoint message.
This bug was hidden previously because this code never ran due to
another bug in handling the stop callback message from change feed.
Jira: COUCHDB-3104
Project: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/commit/f67ebff2
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/tree/f67ebff2
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/diff/f67ebff2
Branch: refs/heads/3104-fix-replicator-manager-changes-feed-checkpoint
Commit: f67ebff225d63d20ccbcbd33de800f86911a5e79
Parents: 40a0876
Author: Nick Vatamaniuc <va...@gmail.com>
Authored: Mon Aug 15 03:20:44 2016 -0400
Committer: Nick Vatamaniuc <va...@gmail.com>
Committed: Mon Aug 15 03:20:44 2016 -0400
----------------------------------------------------------------------
src/couch_replicator_manager.erl | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/blob/f67ebff2/src/couch_replicator_manager.erl
----------------------------------------------------------------------
diff --git a/src/couch_replicator_manager.erl b/src/couch_replicator_manager.erl
index cb38133..eed72b8 100644
--- a/src/couch_replicator_manager.erl
+++ b/src/couch_replicator_manager.erl
@@ -389,7 +389,7 @@ changes_reader_cb({change, Change, _}, _, {Server, DbName, Epoch}) ->
end,
{Server, DbName, Epoch};
changes_reader_cb({stop, EndSeq}, _, {Server, DbName, Epoch}) ->
- Msg = {rep_db_checkpoint, DbName, EndSeq},
+ Msg = {rep_db_checkpoint, DbName, EndSeq, Epoch},
ok = gen_server:call(Server, Msg, infinity),
{Server, DbName, Epoch};
changes_reader_cb(_, _, Acc) ->