diff options
| author | Adam Kocoloski <adam@cloudant.com> | 2010-06-02 12:07:30 -0400 |
|---|---|---|
| committer | Adam Kocoloski <adam@cloudant.com> | 2010-06-02 12:07:30 -0400 |
| commit | 0340953f4ff3cc6ee09b786031442f97f79090c3 (patch) | |
| tree | e6b87a407b634f6619bf640e5515cc0e744330a4 /src/fabric_util.erl | |
| parent | b12bcd244bdf743de8c91808cf03417b1ea9dde2 (diff) | |
_all_docs with keys, closes BugzID 10218
Diffstat (limited to 'src/fabric_util.erl')
| -rw-r--r-- | src/fabric_util.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/fabric_util.erl b/src/fabric_util.erl index e904b456..760e511c 100644 --- a/src/fabric_util.erl +++ b/src/fabric_util.erl @@ -26,6 +26,8 @@ receive_loop(Workers, Keypos, Fun, Acc0) -> %% @doc set up the receive loop with an overall timeout -spec receive_loop([any()], integer(), function(), any(), timeout(), timeout()) -> {ok, any()}. +receive_loop(RefPartMap, Keypos, Fun, Acc0, infinity, PerMsgTO) -> + process_mailbox(RefPartMap, Keypos, Fun, Acc0, nil, PerMsgTO); receive_loop(RefPartMap, Keypos, Fun, Acc0, GlobalTimeout, PerMsgTO) -> TimeoutRef = erlang:make_ref(), {ok, TRef} = timer:send_after(GlobalTimeout, {timeout, TimeoutRef}), |