summaryrefslogtreecommitdiff
path: root/src/serialiser.erl
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2011-09-14 15:07:23 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2011-09-14 15:07:23 +0100
commite90a269896ba8dcd538f5314356d7ff9170721a0 (patch)
tree2f5805175873d92297c572990e573b8b0d2f12f0 /src/serialiser.erl
parentc357bcad38bdf86f9db8a499fe471cddb5e73342 (diff)
downloadrabbitmq-server-git-e90a269896ba8dcd538f5314356d7ff9170721a0.tar.gz
file2 will start the serialiser when it needs it
Diffstat (limited to 'src/serialiser.erl')
-rw-r--r--src/serialiser.erl11
1 files changed, 2 insertions, 9 deletions
diff --git a/src/serialiser.erl b/src/serialiser.erl
index 958f0d500c..0f9bcf17cd 100644
--- a/src/serialiser.erl
+++ b/src/serialiser.erl
@@ -43,15 +43,8 @@
start_link() ->
gen_server2:start_link(?MODULE, [], [{timeout, infinity}]).
-submit(Pid, Fun) when is_pid(Pid) ->
- gen_server2:call(Pid, {run, Fun}, infinity);
-submit(Server, Fun) ->
- %% If the io_runner is not running, just run the Fun in the
- %% current process.
- case whereis(Server) of
- undefined -> run(Fun);
- _ -> gen_server2:call(Server, {run, Fun}, infinity)
- end.
+submit(Pid, Fun) ->
+ gen_server2:call(Pid, {run, Fun}, infinity).
%%----------------------------------------------------------------------------