diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2013-02-27 15:30:43 +0000 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2013-02-27 15:30:43 +0000 |
commit | 2279502946e436f40368d66477edafe5c6616f60 (patch) | |
tree | 6ccc695bb947683ddf4bdd11b615eb6af40a4ecd | |
parent | cb97ff80e3a876bfce7e22d213be66fa780032e8 (diff) | |
download | rabbitmq-server-2279502946e436f40368d66477edafe5c6616f60.tar.gz |
We no longer need two different death detectors since we no longer look at Mnesia for majorityness.
-rw-r--r-- | src/rabbit_node_monitor.erl | 11 |
1 files changed, 1 insertions, 10 deletions
diff --git a/src/rabbit_node_monitor.erl b/src/rabbit_node_monitor.erl index fd8080bc..ad2003a5 100644 --- a/src/rabbit_node_monitor.erl +++ b/src/rabbit_node_monitor.erl @@ -250,10 +250,6 @@ handle_info({mnesia_system_event, ordsets:add_element(Node, ordsets:from_list(Partitions))), {noreply, State#state{partitions = Partitions1}}; -handle_info({mnesia_system_event, {mnesia_down, _Node}}, State) -> - handle_dead_according_to_mnesia_rabbit(), - {noreply, State}; - handle_info(_Info, State) -> {noreply, State}. @@ -274,12 +270,7 @@ handle_dead_rabbit(Node) -> ok = rabbit_networking:on_node_down(Node), ok = rabbit_amqqueue:on_node_down(Node), ok = rabbit_alarm:on_node_down(Node), - ok = rabbit_mnesia:on_node_down(Node). - -%% Since we will be introspecting the cluster in response to this, we -%% must only do so based on Mnesia having noticed the other node being -%% down - otherwise we have a race. -handle_dead_according_to_mnesia_rabbit() -> + ok = rabbit_mnesia:on_node_down(Node), case application:get_env(rabbit, cluster_cp_mode) of {ok, true} -> case majority() of true -> ok; |