diff options
author | Adam Kocoloski <adam@cloudant.com> | 2010-05-27 12:51:11 -0400 |
---|---|---|
committer | Adam Kocoloski <adam@cloudant.com> | 2010-05-27 12:51:11 -0400 |
commit | e91bbf3d70eefdd44c123e06c12e0b9ab498a791 (patch) | |
tree | 49bceb9e112adc8f3533284b9f4290ec9aa54f33 | |
parent | 200d64d61d209599a1f32b954605c46abacd45bc (diff) |
sloppy commit
-rw-r--r-- | src/fabric_util.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/fabric_util.erl b/src/fabric_util.erl index 98da1001..4b2f611a 100644 --- a/src/fabric_util.erl +++ b/src/fabric_util.erl @@ -1,14 +1,14 @@ -module(fabric_util). --export([receive_loop/4, receive_loop/6]). +-export([submit_jobs/3, recv/4, receive_loop/4, receive_loop/6]). -include("../../dynomite/include/membership.hrl"). submit_jobs(Shards, EndPoint, ExtraArgs) -> lists:map(fun(#shard{node=Node, name=ShardName} = Shard) -> - Ref = rexi:cast(Node, {?RPC, EndPoint, [ShardName | ExtraArgs]}), + Ref = rexi:cast(Node, {fabric_rpc, EndPoint, [ShardName | ExtraArgs]}), Shard#shard{ref = Ref} - end. + end, Shards). recv(Workers, Keypos, Fun, Acc0) -> receive_loop(Workers, Keypos, Fun, Acc0). |