summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/couchdb/couch_rep_changes_feed.erl2
-rw-r--r--src/couchdb/couch_rep_reader.erl11
2 files changed, 7 insertions, 6 deletions
diff --git a/src/couchdb/couch_rep_changes_feed.erl b/src/couchdb/couch_rep_changes_feed.erl
index 1b6148a5..7ff741e4 100644
--- a/src/couchdb/couch_rep_changes_feed.erl
+++ b/src/couchdb/couch_rep_changes_feed.erl
@@ -279,7 +279,7 @@ by_seq_loop(Server, Source, StartSeq) ->
{<<"id">>, Id},
{<<"changes">>, [{[{<<"rev">>,R}]} || R <- ParsedRevs]}
]},
- gen_server:call(Server, {add_change, Change}),
+ gen_server:call(Server, {add_change, Change}, infinity),
Seq
end, 0, Rows),
by_seq_loop(Server, Source, EndSeq+1).
diff --git a/src/couchdb/couch_rep_reader.erl b/src/couchdb/couch_rep_reader.erl
index e647cf87..a7c3fd9f 100644
--- a/src/couchdb/couch_rep_reader.erl
+++ b/src/couchdb/couch_rep_reader.erl
@@ -244,18 +244,19 @@ reader_loop(ReaderServer, Source, MissingRevsServer) ->
% to be safe, make sure Results are sorted by source_seq
SortedIdsRevs = lists:keysort(2, IdsRevs),
RequestSeqs = [S || {_,S,_} <- SortedIdsRevs],
- gen_server:call(ReaderServer, {add_request_seqs, RequestSeqs}),
+ gen_server:call(ReaderServer, {add_request_seqs, RequestSeqs}, infinity),
case Source of
#http_db{} ->
- [gen_server:call(ReaderServer, {open_remote_doc, Id, Seq, Revs})
- || {Id,Seq,Revs} <- SortedIdsRevs],
+ [gen_server:call(ReaderServer, {open_remote_doc, Id, Seq, Revs},
+ infinity) || {Id,Seq,Revs} <- SortedIdsRevs],
reader_loop(ReaderServer, Source, MissingRevsServer);
_Local ->
Source2 = maybe_reopen_db(Source, HighSeq),
lists:foreach(fun({Id,Seq,Revs}) ->
{ok, Docs} = couch_db:open_doc_revs(Source2, Id, Revs, [latest]),
JustTheDocs = [Doc || {ok, Doc} <- Docs],
- gen_server:call(ReaderServer, {add_docs, Seq, JustTheDocs})
+ gen_server:call(ReaderServer, {add_docs, Seq, JustTheDocs},
+ infinity)
end, SortedIdsRevs),
reader_loop(ReaderServer, Source2, MissingRevsServer)
end
@@ -271,6 +272,6 @@ spawn_document_request(Source, Id, Seq, Revs) ->
Server = self(),
SpawnFun = fun() ->
Results = open_doc_revs(Source, Id, Revs),
- gen_server:call(Server, {add_docs, Seq, Results})
+ gen_server:call(Server, {add_docs, Seq, Results}, infinity)
end,
spawn_monitor(SpawnFun).