diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-06-26 20:10:53 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-06-26 20:10:53 +0200 |
| commit | 31173263e1c34356f7e85b0268a531b85247e0f1 (patch) | |
| tree | a64e132c9d0654e8a5e8af1ae842a1f7149462c6 /src | |
| parent | d7b18da002ceab4c1afd31aa6fa3f5828e0f8084 (diff) | |
| download | rabbitmq-server-git-31173263e1c34356f7e85b0268a531b85247e0f1.tar.gz | |
cosmetics
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index f3151b0578..5bfa006e09 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -787,7 +787,8 @@ on_node_up(Node) -> end). maybe_clear_recoverable_node(Node, - #amqqueue{sync_slave_pids = SPids, recoverable_slaves = RSs} = Q) -> + #amqqueue{sync_slave_pids = SPids, + recoverable_slaves = RSs} = Q) -> case lists:member(Node, RSs) of true -> %% There is a race with @@ -801,10 +802,11 @@ maybe_clear_recoverable_node(Node, %% the case, then this function is executed after. In this %% situation, we don't touch the queue record, it is already %% correct. - DoClearNode = case [SP || SP <- SPids, node(SP) =:= Node] of - [SPid] -> not rabbit_misc:is_process_alive(SPid); - _ -> true - end, + DoClearNode = + case [SP || SP <- SPids, node(SP) =:= Node] of + [SPid] -> not rabbit_misc:is_process_alive(SPid); + _ -> true + end, if DoClearNode -> RSs1 = RSs -- [Node], store_queue( |
