summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEmile Joubert <emile@rabbitmq.com>2012-01-11 10:52:01 +0000
committerEmile Joubert <emile@rabbitmq.com>2012-01-11 10:52:01 +0000
commit6f93ba715fb450bafdf24b00f790312107f16634 (patch)
tree05b0039d9ea8c7e2dd575bf442f9c0beac344204
parentd24140fc1093e3e23d0e2f8cd84ded88539ea1e1 (diff)
downloadrabbitmq-server-git-6f93ba715fb450bafdf24b00f790312107f16634.tar.gz
No timeout when calling
-rw-r--r--src/mnesia_sync.erl12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mnesia_sync.erl b/src/mnesia_sync.erl
index c9dc1c1c35..e80f9af621 100644
--- a/src/mnesia_sync.erl
+++ b/src/mnesia_sync.erl
@@ -38,10 +38,10 @@
%%----------------------------------------------------------------------------
start_link() ->
- gen_server2:start_link({local, ?SERVER}, ?MODULE, [], [{timeout, infinity}]).
+ gen_server2:start_link({local, ?SERVER}, ?MODULE, [], []).
sync() ->
- gen_server2:call(?SERVER, sync).
+ gen_server2:call(?SERVER, sync, infinity).
%%----------------------------------------------------------------------------
@@ -64,10 +64,10 @@ sync_proc(Waiting) ->
%%----------------------------------------------------------------------------
init([]) ->
- {ok, #state{sync_pid = case rabbit_mnesia:is_disc_node() of
- true -> proc_lib:spawn_link(fun sync_proc/0);
- false -> undefined
- end}}.
+ {ok, #state{sync_pid = case mnesia:system_info(use_dir) of
+ true -> proc_lib:spawn_link(fun sync_proc/0);
+ false -> undefined
+ end}}.
handle_call(sync, _From, #state{sync_pid = undefined} = State) ->
{reply, ok, State};