couchdb-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vatam...@apache.org
Subject couch-replicator commit: updated refs/heads/3082-replication-manager-rep_start_pids-fix to 17cb967
Date Tue, 26 Jul 2016 19:32:05 GMT
Repository: couchdb-couch-replicator
Updated Branches:
  refs/heads/3082-replication-manager-rep_start_pids-fix [created] 17cb96724


Replication manager's rep_start_pids now contains only {Tag, Pid} items

Previously the local change feed was added to rep_start_pids as Pid only. So if
replication manager stopped and terminate/2 was called before that change
feed died, then

```
foreach(fun({_Tag, Pid}) -> ... end, [StartPids])
```

would crash with a function clause error.

Jira: COUCHDB-3082


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

Branch: refs/heads/3082-replication-manager-rep_start_pids-fix
Commit: 17cb967243b9b7111a331fea796976c53718dd7d
Parents: bf636d3
Author: Nick Vatamaniuc <vatamane@gmail.com>
Authored: Tue Jul 26 15:22:52 2016 -0400
Committer: Nick Vatamaniuc <vatamane@gmail.com>
Committed: Tue Jul 26 15:22:52 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/17cb9672/src/couch_replicator_manager.erl
----------------------------------------------------------------------
diff --git a/src/couch_replicator_manager.erl b/src/couch_replicator_manager.erl
index 21d732f..1779e1b 100644
--- a/src/couch_replicator_manager.erl
+++ b/src/couch_replicator_manager.erl
@@ -182,7 +182,7 @@ init(_) ->
         scan_pid = ScanPid,
         max_retries = retries_value(
             config:get("replicator", "max_replication_retry_count", "10")),
-        rep_start_pids = [Pid],
+        rep_start_pids = [{rep_start, Pid}],
         live = Live,
         epoch = Epoch
     }}.


Mime
View raw message