summaryrefslogtreecommitdiff
path: root/src/couchdb/couch_rep_changes_feed.erl
diff options
context:
space:
mode:
authorAdam Kocoloski <kocolosk@apache.org>2009-08-23 01:45:48 +0000
committerAdam Kocoloski <kocolosk@apache.org>2009-08-23 01:45:48 +0000
commit4b6baa9cfcbbf6e78c6ea6f1ef208b4f7c25bba2 (patch)
treee59bff11d5889a1f4a8f1c7130c390715634a008 /src/couchdb/couch_rep_changes_feed.erl
parent14c6957b0b4bcda60cc5773df8b0b41f46811725 (diff)
heartbeat bugfix for continuous replication from remote source
git-svn-id: https://svn.apache.org/repos/asf/couchdb/trunk@806918 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'src/couchdb/couch_rep_changes_feed.erl')
-rw-r--r--src/couchdb/couch_rep_changes_feed.erl1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/couchdb/couch_rep_changes_feed.erl b/src/couchdb/couch_rep_changes_feed.erl
index c124af1b..a358bed5 100644
--- a/src/couchdb/couch_rep_changes_feed.erl
+++ b/src/couchdb/couch_rep_changes_feed.erl
@@ -199,6 +199,7 @@ handle_response({error, Reason}, State) ->
{stop, {error, Reason}, State};
handle_response(<<"\n">>, State) ->
?LOG_DEBUG("got a heartbeat from the remote server", []),
+ ok = maybe_stream_next(State),
{noreply, State};
handle_response(<<"{\"results\":[\n">>, State) ->
ok = maybe_stream_next(State),