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_changes.erl | |
| parent | 794d78eb02a20e6c545d24fa9649839ebe763636 (diff) | |
split some rexi utilities out from fabric
Diffstat (limited to 'apps/fabric/src/fabric_view_changes.erl')
| -rw-r--r-- | apps/fabric/src/fabric_view_changes.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/apps/fabric/src/fabric_view_changes.erl b/apps/fabric/src/fabric_view_changes.erl index e4f44485..c7b6b7c4 100644 --- a/apps/fabric/src/fabric_view_changes.erl +++ b/apps/fabric/src/fabric_view_changes.erl @@ -103,7 +103,7 @@ send_changes(DbName, ChangesArgs, Callback, PackedSeqs, AccIn) -> limit = ChangesArgs#changes_args.limit, rows = Seqs % store sequence positions instead }, - 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, 5000) after fabric_util:cleanup(Workers) @@ -221,7 +221,7 @@ unpack_seqs(0, DbName) -> unpack_seqs("0", DbName) -> fabric_dict:init(mem3:shards(DbName), 0); - + unpack_seqs(Packed, DbName) -> {match, [Opaque]} = re:run(Packed, "^([0-9]+-)?(?<opaque>.*)", [{capture, [opaque], binary}]), |