diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-10-09 16:31:19 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-10-09 16:31:19 +0100 |
| commit | 9ab1051ca0e168eeae6f478e2d393a4a39099280 (patch) | |
| tree | 749d1ff68ac3cb525dca8466460ab1a551228bf1 | |
| parent | 3dd516866b71143340647f9ad0295867d38a7cb5 (diff) | |
| download | rabbitmq-server-git-9ab1051ca0e168eeae6f478e2d393a4a39099280.tar.gz | |
Check Mnesia's idea of which nodes are running; avoid infinite loop.
| -rw-r--r-- | src/rabbit_node_monitor.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_node_monitor.erl b/src/rabbit_node_monitor.erl index fdda62528f..b4e87f75f3 100644 --- a/src/rabbit_node_monitor.erl +++ b/src/rabbit_node_monitor.erl @@ -411,7 +411,8 @@ handle_info({nodedown, Node, Info}, State = #state{node_guids = GUIDs}) -> Node, DownGUID, node(), CheckGUID}) end, case orddict:find(Node, GUIDs) of - {ok, DownGUID} -> Alive = alive_nodes() -- [node(), Node], + {ok, DownGUID} -> Alive = rabbit_mnesia:cluster_nodes(running) + -- [node(), Node], [case orddict:find(N, GUIDs) of {ok, CheckGUID} -> Check(N, CheckGUID, DownGUID); error -> ok |