summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/couchdb/couch_rep_db_listener.erl8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/couchdb/couch_rep_db_listener.erl b/src/couchdb/couch_rep_db_listener.erl
index 89a18e85..ef0ced0a 100644
--- a/src/couchdb/couch_rep_db_listener.erl
+++ b/src/couchdb/couch_rep_db_listener.erl
@@ -318,14 +318,14 @@ keep_retrying(Server, _RepId, RepDoc, _UserCtx, Error, _Wait, 0) ->
ok = gen_server:call(Server, {restart_failure, RepDoc, Error}, infinity);
keep_retrying(Server, RepId, RepDoc, UserCtx, Error, Wait, RetriesLeft) ->
- ?LOG_ERROR("Error starting replication `~s`: ~p. "
- "Retrying in ~p seconds", [pp_rep_id(RepId), Error, Wait]),
+ {RepProps} = RepDoc,
+ DocId = get_value(<<"_id">>, RepProps),
+ ?LOG_ERROR("Error starting replication `~s` (document `~s`): ~p. "
+ "Retrying in ~p seconds", [pp_rep_id(RepId), DocId, Error, Wait]),
ok = timer:sleep(Wait * 1000),
case (catch couch_rep:start_replication(RepDoc, RepId, UserCtx)) of
Pid when is_pid(Pid) ->
ok = gen_server:call(Server, {triggered, RepId}, infinity),
- {RepProps} = RepDoc,
- DocId = get_value(<<"_id">>, RepProps),
[{DocId, {RepId, MaxRetries}}] = ets:lookup(?DOC_ID_TO_REP_ID, DocId),
?LOG_INFO("Document `~s` triggered replication `~s` after ~p attempts",
[DocId, pp_rep_id(RepId), MaxRetries - RetriesLeft + 1]),