Permalink
Browse files

Use mem3:live_shards/2

  • Loading branch information...
1 parent 0a2a4ae commit 07d4e31208a7d62f7bec994c84134ccfc59c9e02 @kocolosk kocolosk committed Jun 5, 2012
Showing with 1 addition and 3 deletions.
  1. +1 −3 src/fabric_view_changes.erl
@@ -92,9 +92,7 @@ keep_sending_changes(DbName, Args, Callback, Seqs, AccIn, Timeout) ->
send_changes(DbName, ChangesArgs, Callback, PackedSeqs, AccIn, Timeout) ->
LiveNodes = [node() | nodes()],
- %% This can be replaced by mem3:live_shards when we upgrade mem3
- AllLiveShards =
- [S || #shard{node=Node} = S <- mem3:shards(DbName), lists:member(Node, LiveNodes)],
+ AllLiveShards = mem3:live_shards(DbName, LiveNodes),
Seqs = lists:flatmap(fun({#shard{name=Name, node=N} = Shard, Seq}) ->
case lists:member(Shard, AllLiveShards) of
true ->

0 comments on commit 07d4e31

Please sign in to comment.