summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-08-09 07:38:10 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2013-08-09 07:38:10 +0100
commit555671358dabe274308932d0184325b50cfae1a7 (patch)
treefb89e167d1abd1e9bbcd0ac6bd9812be2336864a /src
parent513711585c23c48a3e8b55d19b46b779ab3d63cd (diff)
downloadrabbitmq-server-git-555671358dabe274308932d0184325b50cfae1a7.tar.gz
refactor: better name for function application
plus lose the type check; we are not that paranoid.
Diffstat (limited to 'src')
-rw-r--r--src/delegate.erl10
1 files changed, 4 insertions, 6 deletions
diff --git a/src/delegate.erl b/src/delegate.erl
index 68dc1f34d6..5277e59fcc 100644
--- a/src/delegate.erl
+++ b/src/delegate.erl
@@ -64,7 +64,7 @@ start_link(Num) ->
gen_server2:start_link({local, Name}, ?MODULE, [Name], []).
invoke(Pid, FunOrMFA) when is_pid(Pid) andalso node(Pid) =:= node() ->
- fun_or_mfa(FunOrMFA, Pid);
+ apply1(FunOrMFA, Pid);
invoke(Pid, FunOrMFA) when is_pid(Pid) ->
case invoke([Pid], FunOrMFA) of
{[{Pid, Result}], []} ->
@@ -174,15 +174,13 @@ safe_invoke(Pids, FunOrMFA) when is_list(Pids) ->
[safe_invoke(Pid, FunOrMFA) || Pid <- Pids];
safe_invoke(Pid, FunOrMFA) when is_pid(Pid) ->
try
- {ok, Pid, fun_or_mfa(FunOrMFA, Pid)}
+ {ok, Pid, apply1(FunOrMFA, Pid)}
catch Class:Reason ->
{error, Pid, {Class, Reason, erlang:get_stacktrace()}}
end.
-fun_or_mfa(Fun, Pid) when is_function(Fun) ->
- Fun(Pid);
-fun_or_mfa({M, F, A}, Pid) ->
- apply(M, F, [Pid | A]).
+apply1({M, F, A}, Arg) -> apply(M, F, [Arg | A]);
+apply1(Fun, Arg) -> Fun(Arg).
%%----------------------------------------------------------------------------