summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAdam Kocoloski <adam@cloudant.com>2010-05-27 12:51:11 -0400
committerAdam Kocoloski <adam@cloudant.com>2010-05-27 12:51:11 -0400
commite91bbf3d70eefdd44c123e06c12e0b9ab498a791 (patch)
tree49bceb9e112adc8f3533284b9f4290ec9aa54f33
parent200d64d61d209599a1f32b954605c46abacd45bc (diff)
sloppy commit
-rw-r--r--src/fabric_util.erl6
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).