couchdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vatam...@apache.org
Subject [36/50] couch-replicator commit: updated refs/heads/63012-scheduler to 27a5eae
Date Tue, 14 Mar 2017 19:26:31 GMT
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 <vatamane@apache.org>
Authored: Wed Dec 7 20:50:14 2016 -0500
Committer: Nick Vatamaniuc <vatamane@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.


Mime
View raw message