diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-07-15 11:57:30 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-07-15 11:57:30 +0100 |
| commit | be4e13e6e3e9f7b6f4cfe4efaa998ddf1be516cc (patch) | |
| tree | cb15d803e23bf616bdd07ad523b2d383a31e384b | |
| parent | 76f7d781db623d121096adaf57d4fd0af3929b0f (diff) | |
| download | rabbitmq-server-git-be4e13e6e3e9f7b6f4cfe4efaa998ddf1be516cc.tar.gz | |
Don't expect GMs which have not yet joined to take part in messaging.
| -rw-r--r-- | src/gm_qc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/gm_qc.erl b/src/gm_qc.erl index ded6c97396..394cbcbd12 100644 --- a/src/gm_qc.erl +++ b/src/gm_qc.erl @@ -163,12 +163,12 @@ next_state(S = #state{to_leave = Set}, _Res, {call, ?MODULE, do_leave, [GM]}) -> next_state(S = #state{seq = Seq, outstanding = Outstanding}, _Res, {call, ?MODULE, do_send, [GM]}) -> - case is_pid(GM) andalso lists:member(GM, gms(S)) of + case is_pid(GM) andalso lists:member(GM, gms_joined(S)) of true -> %% Dynamic state, i.e. runtime Msg = [{sequence, Seq}, {sent_to, GM}, - {dests, gms(S)}], + {dests, gms_joined(S)}], gm:broadcast(GM, Msg), Outstanding1 = dict:map( fun (_GM, Set) -> |