diff options
| -rw-r--r-- | apps/couch/src/couch_replication_manager.erl | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/apps/couch/src/couch_replication_manager.erl b/apps/couch/src/couch_replication_manager.erl index 943cafa8..b3fc3e3c 100644 --- a/apps/couch/src/couch_replication_manager.erl +++ b/apps/couch/src/couch_replication_manager.erl @@ -314,8 +314,13 @@ process_update(State, {Change}) -> <<"completed">> -> replication_complete(DocId), State; - _ -> - State + <<"error">> -> + case ets:lookup(?DOC_TO_REP, DocId) of + [] -> + maybe_start_replication(State, DocId, JsonRepDoc); + _ -> + State + end end end. |