Skip to content
This repository has been archived by the owner. It is now read-only.
Browse files
Use a consistent commenting syntax
  • Loading branch information
kocolosk authored and rnewson committed Jul 23, 2014
1 parent 94fc763 commit a29e6b7556862f82ce416f93ac5cf847f36a276e
Showing 1 changed file with 2 additions and 2 deletions.
@@ -23,11 +23,11 @@ rebalance(DbName) ->
rebalance(DbName, TargetNodes) when is_binary(DbName) ->
rebalance(mem3:shards(DbName), TargetNodes);
rebalance(Shards, TargetNodes) when is_list(Shards) ->
%% first migrate shards off of non-target nodes
% First migrate all shards off of non-target nodes
{OK, MoveThese} = lists:partition(fun(#shard{node=Node}) ->
lists:member(Node, TargetNodes)
end, Shards),
% ensure every target node is present in the orddict
% Ensure every target node is present in the orddict
ShardsByTargetNode0 = orddict:from_list([{N,[]} || N <- TargetNodes]),
ShardsByTargetNode = lists:foldl(fun(Shard, Acc) ->
orddict:append(Shard#shard.node, Shard, Acc)

0 comments on commit a29e6b7

Please sign in to comment.