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 | 29d0c5c5e52e355903372f69f4b1d302779f9e10 (patch) | |
| tree | 6ccc695bb947683ddf4bdd11b615eb6af40a4ecd /src | |
| parent | b006debdc23f863ad1ca533c7547bb0f51805540 (diff) | |
| download | rabbitmq-server-git-29d0c5c5e52e355903372f69f4b1d302779f9e10.tar.gz | |
We no longer need two different death detectors since we no longer look at Mnesia for majorityness.
Diffstat (limited to 'src')
| -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 fd8080bcfc..ad2003a575 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; |
