summaryrefslogtreecommitdiff
path: root/src/gm.erl
diff options
context:
space:
mode:
authorAyanda Dube <ayanda.dube@erlang-solutions.com>2016-08-15 11:37:48 +0100
committerAyanda Dube <ayanda.dube@erlang-solutions.com>2016-08-15 11:37:48 +0100
commit6d0ca9cca257e61ffe522933a1bf6460c8047d5c (patch)
tree442038cbb967f7cbdbe9a44c922a793791d85daf /src/gm.erl
parentc2bd22cdc3c1f0ba75bbeebd3a6d59b3d976cb68 (diff)
downloadrabbitmq-server-git-6d0ca9cca257e61ffe522933a1bf6460c8047d5c.tar.gz
Safely handle (and log) anonymous info messages, most likely
from the gm process' neighbours
Diffstat (limited to 'src/gm.erl')
-rw-r--r--src/gm.erl9
1 files changed, 8 insertions, 1 deletions
diff --git a/src/gm.erl b/src/gm.erl
index 176e14537f..822d50252b 100644
--- a/src/gm.erl
+++ b/src/gm.erl
@@ -757,7 +757,14 @@ handle_info({'DOWN', MRef, process, _Pid, Reason},
catch
lost_membership ->
{stop, normal, State}
- end.
+ end;
+handle_info(Msg, State = #state { self = Self }) ->
+ %% 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.
+ rabbit_log:info("GM member ~p received unexpected message ~p~n"
+ "When Server state == ~p", [Self, Msg, State]),
+ noreply(State).
terminate(Reason, #state { module = Module, callback_args = Args }) ->
Module:handle_terminate(Args, Reason).