summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-03-03 15:21:43 +0000
committerMatthew Sackman <matthew@rabbitmq.com>2011-03-03 15:21:43 +0000
commit3f0868aa816ed7dd1ac67be4dbcd9d443d820423 (patch)
tree9a68fb000d0e35566f705b8968240a953cd92e6a /src
parentcbd0d077ee6da50d60a51cab587e63d927db1afa (diff)
downloadrabbitmq-server-git-3f0868aa816ed7dd1ac67be4dbcd9d443d820423.tar.gz
renaming
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_alarm.erl34
1 files changed, 17 insertions, 17 deletions
diff --git a/src/rabbit_alarm.erl b/src/rabbit_alarm.erl
index 365a5ed212..9ce468f00a 100644
--- a/src/rabbit_alarm.erl
+++ b/src/rabbit_alarm.erl
@@ -25,7 +25,7 @@
-export([remote_conserve_memory/2]). %% Internal use only
--record(alarms, {alertees, high_watermarks}).
+-record(alarms, {alertees, alarmed_nodes}).
%%----------------------------------------------------------------------------
@@ -78,27 +78,27 @@ remote_conserve_memory(Pid, Conserve) ->
%%----------------------------------------------------------------------------
init([]) ->
- {ok, #alarms{alertees = dict:new(),
- high_watermarks = sets:new()}}.
+ {ok, #alarms{alertees = dict:new(),
+ alarmed_nodes = sets:new()}}.
handle_call({register, Pid, HighMemMFA}, State) ->
- {ok, 0 < sets:size(State#alarms.high_watermarks),
+ {ok, 0 < sets:size(State#alarms.alarmed_nodes),
internal_register(Pid, HighMemMFA, State)};
handle_call(_Request, State) ->
{ok, not_understood, State}.
handle_event({set_alarm, {{vm_memory_high_watermark, Node}, []}},
- State = #alarms{high_watermarks = Highs}) ->
- Highs1 = sets:add_element(Node, Highs),
- ok = maybe_alert(Highs, Highs1, State#alarms.alertees, Node, true),
- {ok, State#alarms{high_watermarks = Highs1}};
+ State = #alarms{alarmed_nodes = AN}) ->
+ AN1 = sets:add_element(Node, AN),
+ ok = maybe_alert(AN, AN1, State#alarms.alertees, Node, true),
+ {ok, State#alarms{alarmed_nodes = AN1}};
handle_event({clear_alarm, {vm_memory_high_watermark, Node}},
- State = #alarms{high_watermarks = Highs}) ->
- Highs1 = sets:del_element(Node, Highs),
- ok = maybe_alert(Highs, Highs1, State#alarms.alertees, Node, false),
- {ok, State#alarms{high_watermarks = Highs1}};
+ State = #alarms{alarmed_nodes = AN}) ->
+ AN1 = sets:del_element(Node, AN),
+ ok = maybe_alert(AN, AN1, State#alarms.alertees, Node, false),
+ {ok, State#alarms{alarmed_nodes = AN1}};
handle_event({node, up, Node}, State) ->
%% Must do this via notify and not call to avoid possible deadlock.
@@ -107,10 +107,10 @@ handle_event({node, up, Node}, State) ->
{register, self(), {?MODULE, remote_conserve_memory, []}}),
{ok, State};
-handle_event({node, down, Node}, State = #alarms{high_watermarks = Highs}) ->
- Highs1 = sets:del_element(Node, Highs),
- ok = maybe_alert(Highs, Highs1, State#alarms.alertees, Node, false),
- {ok, State#alarms{high_watermarks = Highs1}};
+handle_event({node, down, Node}, State = #alarms{alarmed_nodes = AN}) ->
+ AN1 = sets:del_element(Node, AN),
+ ok = maybe_alert(AN, AN1, State#alarms.alertees, Node, false),
+ {ok, State#alarms{alarmed_nodes = AN1}};
handle_event({register, Pid, HighMemMFA}, State) ->
{ok, internal_register(Pid, HighMemMFA, State)};
@@ -173,7 +173,7 @@ alert(Alert, Alertees, NodeComparator) ->
internal_register(Pid, {M, F, A} = HighMemMFA,
State = #alarms{alertees = Alertees}) ->
_MRef = erlang:monitor(process, Pid),
- ok = case sets:is_element(node(), State#alarms.high_watermarks) of
+ ok = case sets:is_element(node(), State#alarms.alarmed_nodes) of
true -> apply(M, F, A ++ [Pid, true]);
false -> ok
end,