From b28ba2dbc731832eb4b7b22e552fc173c1b6ca95 Mon Sep 17 00:00:00 2001 From: Brad Anderson Date: Sun, 9 May 2010 22:55:42 -0400 Subject: change cluster_ops:all_parts to accept the list of NodeParts --- src/cluster_ops.erl | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'src') diff --git a/src/cluster_ops.erl b/src/cluster_ops.erl index 72bba92f..c1edc5b2 100644 --- a/src/cluster_ops.erl +++ b/src/cluster_ops.erl @@ -59,8 +59,7 @@ key_lookup(Key, {M,F,A}, Access, Const, N) -> %% @doc Do op on all shards (and maybe even replication partners) -all_parts({M,F,A}, Access, AndPartners, ResolveFun) -> - NodePartList = membership2:all_nodes_parts(AndPartners), +all_parts({M,F,A}, Access, NodeParts, ResolveFun) -> MapFun = fun({Node, Part}) -> try rpc:call(Node, M, F, [[Part | A]]) @@ -68,9 +67,9 @@ all_parts({M,F,A}, Access, AndPartners, ResolveFun) -> {error, Class, Exception} end end, - Replies = ?PMAP(MapFun, NodePartList), + Replies = ?PMAP(MapFun, NodeParts), {Good, Bad} = lists:partition(fun valid/1, Replies), - final_all_parts(Good, Bad, length(NodePartList), ResolveFun, Access). + final_all_parts(Good, Bad, length(NodeParts), ResolveFun, Access). %% @doc Do op on some shards, depending on list of keys sent in. -- cgit v1.2.3