diff options
| -rw-r--r-- | src/rabbit_alarm.erl | 20 |
1 files changed, 8 insertions, 12 deletions
diff --git a/src/rabbit_alarm.erl b/src/rabbit_alarm.erl index 82c921a29d..62c1cc7459 100644 --- a/src/rabbit_alarm.erl +++ b/src/rabbit_alarm.erl @@ -64,18 +64,14 @@ on_node_up(Node) -> gen_event:notify(alarm_handler, {node_up, Node}). on_node_down(Node) -> gen_event:notify(alarm_handler, {node_down, Node}). -remote_conserve_memory(Pid, Conserve) -> - RemoteNode = node(Pid), - %% Can't use alarm_handler:{set,clear}_alarm because that doesn't - %% permit notifying a remote node. - case Conserve of - true -> gen_event:notify( - {alarm_handler, RemoteNode}, - {set_alarm, {{vm_memory_high_watermark, node()}, []}}); - false -> gen_event:notify( - {alarm_handler, RemoteNode}, - {clear_alarm, {vm_memory_high_watermark, node()}}) - end. +%% Can't use alarm_handler:{set,clear}_alarm because that doesn't +%% permit notifying a remote node. +remote_conserve_memory(Pid, true) -> + gen_event:notify({alarm_handler, node(Pid)}, + {set_alarm, {{vm_memory_high_watermark, node()}, []}}); +remote_conserve_memory(Pid, false) -> + gen_event:notify({alarm_handler, node(Pid)}, + {clear_alarm, {vm_memory_high_watermark, node()}}). %%---------------------------------------------------------------------------- |