Fix rexi_EXIT handling for db/group info and doc_count

cloudant · Feb 9, 2012 · e479a04 · e479a04
1 parent 8fea39c
commit e479a04
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/fabric_db_doc_count.erl b/src/fabric_db_doc_count.erl
@@ -40,7 +40,7 @@ handle_message({rexi_DOWN, _, {_,NodeRef},_}, _Shard, {Counters, Acc}) ->
     end;
 
 handle_message({rexi_EXIT, Reason}, Shard, {Counters, Acc}) ->
-    NewCounters = lists:keydelete(Shard, 1, Counters),
+    NewCounters = lists:keydelete(Shard, #shard.ref, Counters),
     case fabric_view:is_progress_possible(NewCounters) of
     true ->
         {ok, {NewCounters, Acc}};

diff --git a/src/fabric_db_info.erl b/src/fabric_db_info.erl
@@ -39,8 +39,8 @@ handle_message({rexi_DOWN, _, {_,NodeRef},_}, _Shard, {Counters, Acc}) ->
     end;
 
 handle_message({rexi_EXIT, Reason}, Shard, {Counters, Acc}) ->
-    NewCounters = lists:keydelete(Shard,1,Counters),
-    case fabric_view:is_progress_possible(Counters) of
+    NewCounters = lists:keydelete(Shard, #shard.ref, Counters),
+    case fabric_view:is_progress_possible(NewCounters) of
     true ->
         {ok, {NewCounters, Acc}};
     false ->

diff --git a/src/fabric_group_info.erl b/src/fabric_group_info.erl
@@ -45,8 +45,8 @@ handle_message({rexi_DOWN, _, {_,NodeRef},_}, _Shard, {Counters, Acc}) ->
     end;
 
 handle_message({rexi_EXIT, Reason}, Shard, {Counters, Acc}) ->
-    NewCounters = lists:keydelete(Shard,1,Counters),
-    case fabric_view:is_progress_possible(Counters) of
+    NewCounters = lists:keydelete(Shard, #shard.ref, Counters),
+    case fabric_view:is_progress_possible(NewCounters) of
     true ->
         {ok, {NewCounters, Acc}};
     false ->