diff options
| author | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2016-08-15 11:37:48 +0100 |
|---|---|---|
| committer | Ayanda Dube <ayanda.dube@erlang-solutions.com> | 2016-08-15 11:37:48 +0100 |
| commit | 6d0ca9cca257e61ffe522933a1bf6460c8047d5c (patch) | |
| tree | 442038cbb967f7cbdbe9a44c922a793791d85daf /src/gm.erl | |
| parent | c2bd22cdc3c1f0ba75bbeebd3a6d59b3d976cb68 (diff) | |
| download | rabbitmq-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.erl | 9 |
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). |
