summaryrefslogtreecommitdiff
path: root/src/couchdb/couch_rep_reader.erl
diff options
context:
space:
mode:
authorAdam Kocoloski <kocolosk@apache.org>2009-10-28 19:27:31 +0000
committerAdam Kocoloski <kocolosk@apache.org>2009-10-28 19:27:31 +0000
commit83ae3d22716bd27cac9aba134a32bfbe05f4301c (patch)
tree565d012f56f835db934316844821569102f3959a /src/couchdb/couch_rep_reader.erl
parentcbd893d573e2b37baa50528f2d4a639f885ebefa (diff)
reboot replication from last checkpoint if DB is compacted or server restarts
git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@830737 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'src/couchdb/couch_rep_reader.erl')
-rw-r--r--src/couchdb/couch_rep_reader.erl1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/couchdb/couch_rep_reader.erl b/src/couchdb/couch_rep_reader.erl
index e0ebc2f0..7f061500 100644
--- a/src/couchdb/couch_rep_reader.erl
+++ b/src/couchdb/couch_rep_reader.erl
@@ -262,6 +262,7 @@ reader_loop(ReaderServer, Source, MissingRevsServer) ->
maybe_reopen_db(#db{update_seq=OldSeq} = Db, HighSeq) when HighSeq > OldSeq ->
{ok, NewDb} = couch_db:open(Db#db.name, [{user_ctx, Db#db.user_ctx}]),
+ couch_db:close(Db),
NewDb;
maybe_reopen_db(Db, _HighSeq) ->
Db.