summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexandru Scvortov <alexandru@rabbitmq.com>2010-08-24 15:01:48 +0100
committerAlexandru Scvortov <alexandru@rabbitmq.com>2010-08-24 15:01:48 +0100
commitd46aec5ae2cd306a623add21927d40b36859479f (patch)
tree511a4fc72b1c14f7e147d270744933e60a6d00c7
parent7226bab4249be72eec5d346b569a6229d858077a (diff)
parentf588b129a945c940a716c803d784bde29b6ff30e (diff)
downloadrabbitmq-server-d46aec5ae2cd306a623add21927d40b36859479f.tar.gz
merge default into bug23157
-rw-r--r--src/rabbit_msg_store.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl
index 207ddcb8..6576bfbb 100644
--- a/src/rabbit_msg_store.erl
+++ b/src/rabbit_msg_store.erl
@@ -362,7 +362,7 @@ set_maximum_since_use(Server, Age) ->
client_init(Server, Ref) ->
{IState, IModule, Dir, GCPid,
FileHandlesEts, FileSummaryEts, DedupCacheEts, CurFileCacheEts} =
- gen_server2:call(Server, {new_client_state, Ref}, infinity),
+ gen_server2:pcall(Server, 7, {new_client_state, Ref}, infinity),
#client_msstate { file_handle_cache = dict:new(),
index_state = IState,
index_module = IModule,
@@ -382,7 +382,7 @@ client_delete_and_terminate(CState, Server, Ref) ->
ok = gen_server2:call(Server, {delete_client, Ref}, infinity).
successfully_recovered_state(Server) ->
- gen_server2:call(Server, successfully_recovered_state, infinity).
+ gen_server2:pcall(Server, 7, successfully_recovered_state, infinity).
%%----------------------------------------------------------------------------
%% Client-side-only helpers