Skip to content

Commit

Permalink
Basic handling of mismatched exchange state
Browse files Browse the repository at this point in the history
  • Loading branch information
AeroNotix committed Jul 8, 2016
1 parent 3f3d0bc commit 4042067
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion src/cpg.erl
Original file line number Diff line number Diff line change
Expand Up @@ -3489,7 +3489,10 @@ store(#state{groups = {DictI, ExternalGroupsData},
lists:umerge(V2, V1)
end, ExternalPids, Pids),
State#state{groups = {DictI, NewGroupsData},
pids = NewPids}.
pids = NewPids};
store(_, State) ->
?LOG_INFO("store received mismatched state, ignoring", []),
State.

member_died(Pid, Reason, #state{pids = Pids} = State) ->
case dict:find(Pid, Pids) of
Expand Down

0 comments on commit 4042067

Please sign in to comment.