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 2017/03/14 19:26:31 UTC

[36/50] couch-replicator commit: updated refs/heads/63012-scheduler to 27a5eae

Update filtered replication id when it changes in doc processor ETS table

When replication filter changes, replication id record in doc processor ETS
table was not updated. This led to the new replication job not showing up in
the _scheduler/docs output.


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

Branch: refs/heads/63012-scheduler
Commit: f2b3ac5d009ea3a185097676316669b84dfaaeb0
Parents: 73d1736
Author: Nick Vatamaniuc <va...@apache.org>
Authored: Wed Dec 7 20:50:14 2016 -0500
Committer: Nick Vatamaniuc <va...@apache.org>
Committed: Wed Jan 11 14:58:33 2017 -0500

----------------------------------------------------------------------
 src/couch_replicator_doc_processor.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/couchdb-couch-replicator/blob/f2b3ac5d/src/couch_replicator_doc_processor.erl
----------------------------------------------------------------------
diff --git a/src/couch_replicator_doc_processor.erl b/src/couch_replicator_doc_processor.erl
index 035a7ec..402a72f 100644
--- a/src/couch_replicator_doc_processor.erl
+++ b/src/couch_replicator_doc_processor.erl
@@ -310,7 +310,7 @@ worker_returned(Ref, Id, {ok, RepId}) ->
                 % for future changes.
                 ok = couch_replicator_scheduler:remove_job(OldRepId),
                 Msg = io_lib:format("Replication id changed: ~p -> ~p", [OldRepId, RepId]),
-                Row0#rdoc{info = couch_util:to_binary(Msg)};
+                Row0#rdoc{rid = RepId, info = couch_util:to_binary(Msg)};
             #rdoc{rid = nil} ->
                 % Calculated new replication id for non-filtered replication. Remove
                 % replication doc body, after this we won't needed any more.