From 3b64928720ce15c92374b031ff24b10022671261 Mon Sep 17 00:00:00 2001 From: Brad Anderson Date: Tue, 17 Aug 2010 22:04:15 -0400 Subject: split some rexi utilities out from fabric --- apps/fabric/src/fabric_view_changes.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'apps/fabric/src/fabric_view_changes.erl') 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]+-)?(?.*)", [{capture, [opaque], binary}]), -- cgit v1.2.3