summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-07-25 14:38:53 +0100
committerSimon MacMullen <simon@rabbitmq.com>2014-07-25 14:38:53 +0100
commit2b1181e55bb2372cf65cea5df1895001b301c10c (patch)
tree0f2fb501054301842d4bcaa82d74a9aa066af1bd
parent78e32ab7f920ed0cc5acf15fea30a7aff446bdd4 (diff)
parent8a6a5594335adec0ddb13ad382269d0cfb694223 (diff)
downloadrabbitmq-server-2b1181e55bb2372cf65cea5df1895001b301c10c.tar.gz
Merge in stable
-rw-r--r--src/pmon.erl22
1 files changed, 20 insertions, 2 deletions
diff --git a/src/pmon.erl b/src/pmon.erl
index ae1be40c..de3e9fea 100644
--- a/src/pmon.erl
+++ b/src/pmon.erl
@@ -54,8 +54,13 @@ new(Module) -> #state{dict = dict:new(),
monitor(Item, S = #state{dict = M, module = Module}) ->
case dict:is_key(Item, M) of
true -> S;
- false -> S#state{dict = dict:store(
- Item, Module:monitor(process, Item), M)}
+ false -> case node_alive_shortcut(Item) of
+ true -> Ref = Module:monitor(process, Item),
+ S#state{dict = dict:store(Item, Ref, M)};
+ false -> self() ! {'DOWN', fake_ref, process, Item,
+ nodedown},
+ S
+ end
end.
monitor_all([], S) -> S; %% optimisation
@@ -76,3 +81,16 @@ erase(Item, S = #state{dict = M}) -> S#state{dict = dict:erase(Item, M)}.
monitored(#state{dict = M}) -> dict:fetch_keys(M).
is_empty(#state{dict = M}) -> dict:size(M) == 0.
+
+%%----------------------------------------------------------------------------
+
+%% We check here to see if the node is alive in order to avoid trying
+%% to connect to it if it isn't - this can cause substantial
+%% slowdowns. We can't perform this shortcut if passed {Name, Node}
+%% since we would need to convert that into a pid for the fake 'DOWN'
+%% message, so we always return true here - but that's OK, it's just
+%% an optimisation.
+node_alive_shortcut(P) when is_pid(P) ->
+ lists:member(node(P), [node() | nodes()]);
+node_alive_shortcut({_Name, _Node}) ->
+ true.