diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2016-08-19 12:26:10 +0100 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2016-08-19 12:26:10 +0100 |
| commit | e08e2b960dc48873c56a6f98b527d99cf52db90f (patch) | |
| tree | c2c86c4f36a020b60b8218f87facbb36e14c26b3 /src/gm.erl | |
| parent | 80efcc7258bcf9ae9ca62a8509a76f56b2fc6c5c (diff) | |
| parent | d4020f5f50f118f870ead1d1180f79e75032f6f7 (diff) | |
| download | rabbitmq-server-git-e08e2b960dc48873c56a6f98b527d99cf52db90f.tar.gz | |
Merge branch 'stable'
Diffstat (limited to 'src/gm.erl')
| -rw-r--r-- | src/gm.erl | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl index 985b5bfa6d..0b5c1c44c4 100644 --- a/src/gm.erl +++ b/src/gm.erl @@ -760,6 +760,9 @@ handle_info({'DOWN', MRef, process, _Pid, Reason}, end; handle_info(_, State) -> %% Discard any unexpected messages, such as late replies from neighbour_call/2 + %% TODO: For #gm_group{} related info messages, it could be worthwhile to + %% change_view/2, as this might reflect an alteration in the gm group, meaning + %% we now need to update our state. see rabbitmq-server#914. noreply(State). terminate(Reason, #state { module = Module, callback_args = Args }) -> @@ -1596,7 +1599,9 @@ check_membership(Self, #gm_group{members = M} = Group) -> Group; false -> throw(lost_membership) - end. + end; +check_membership(_Self, {error, not_found}) -> + throw(lost_membership). check_membership(GroupName) -> case dirty_read_group(GroupName) of |
