summaryrefslogtreecommitdiff
path: root/src/gm.erl
diff options
context:
space:
mode:
authorDiana Corbacho <diana@rabbitmq.com>2016-08-19 12:26:10 +0100
committerDiana Corbacho <diana@rabbitmq.com>2016-08-19 12:26:10 +0100
commite08e2b960dc48873c56a6f98b527d99cf52db90f (patch)
treec2c86c4f36a020b60b8218f87facbb36e14c26b3 /src/gm.erl
parent80efcc7258bcf9ae9ca62a8509a76f56b2fc6c5c (diff)
parentd4020f5f50f118f870ead1d1180f79e75032f6f7 (diff)
downloadrabbitmq-server-git-e08e2b960dc48873c56a6f98b527d99cf52db90f.tar.gz
Merge branch 'stable'
Diffstat (limited to 'src/gm.erl')
-rw-r--r--src/gm.erl7
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