You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by ch...@apache.org on 2014/08/28 19:30:31 UTC

[31/50] [abbrv] couch-replicator commit: updated refs/heads/1963-eunit-bigcouch to 3cf0b13

Update changes_reader_cb for new Pending field

We've added a Pending count to changes messages that gets displayed in
replication task statuses. This just ignores that value in the
replication manager.


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/e5e5d84b
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/tree/e5e5d84b
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/diff/e5e5d84b

Branch: refs/heads/1963-eunit-bigcouch
Commit: e5e5d84b5c19b49c40a46530d7e3bcd1c8473110
Parents: 1b32380
Author: Paul J. Davis <pa...@gmail.com>
Authored: Tue Aug 12 12:38:15 2014 -0500
Committer: Paul J. Davis <pa...@gmail.com>
Committed: Tue Aug 12 12:38:15 2014 -0500

----------------------------------------------------------------------
 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/e5e5d84b/src/couch_replicator_manager.erl
----------------------------------------------------------------------
diff --git a/src/couch_replicator_manager.erl b/src/couch_replicator_manager.erl
index 9b1e818..3566433 100644
--- a/src/couch_replicator_manager.erl
+++ b/src/couch_replicator_manager.erl
@@ -308,7 +308,7 @@ changes_reader(Server, DbName, Since) ->
     ),
     ChangesFeedFun({fun ?MODULE:changes_reader_cb/3, {Server, DbName}}).
 
-changes_reader_cb({change, Change}, _, {Server, DbName}) ->
+changes_reader_cb({change, Change, _}, _, {Server, DbName}) ->
     case has_valid_rep_id(Change) of
         true ->
             Msg = {rep_db_update, DbName, Change},