diff options
| author | Brad Anderson <brad@cloudant.com> | 2010-08-17 22:04:15 -0400 |
|---|---|---|
| committer | Adam Kocoloski <adam@cloudant.com> | 2010-08-27 16:52:26 -0400 |
| commit | 3b64928720ce15c92374b031ff24b10022671261 (patch) | |
| tree | 0535ad8bb4f6c3cfd148c62c8c0a0f24c1a7f589 /apps/fabric/src/fabric_view_reduce.erl | |
| parent | 794d78eb02a20e6c545d24fa9649839ebe763636 (diff) | |
split some rexi utilities out from fabric
Diffstat (limited to 'apps/fabric/src/fabric_view_reduce.erl')
| -rw-r--r-- | apps/fabric/src/fabric_view_reduce.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/apps/fabric/src/fabric_view_reduce.erl b/apps/fabric/src/fabric_view_reduce.erl index f401fc58..6ae564cc 100644 --- a/apps/fabric/src/fabric_view_reduce.erl +++ b/apps/fabric/src/fabric_view_reduce.erl @@ -49,7 +49,7 @@ go(DbName, DDoc, VName, Args, Callback, Acc0) -> rows = dict:new(), user_acc = Acc0 }, - try fabric_util:receive_loop(Workers, #shard.ref, fun handle_message/3, + try rexi_utils:recv(Workers, #shard.ref, fun handle_message/3, State, infinity, 1000 * 60 * 60) of {ok, NewState} -> {ok, NewState#collector.user_acc}; |