diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-23 15:24:30 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-08-23 15:24:30 +0100 |
| commit | 31acae72aa8ecca63fecb8cf1ac28c8f516b33cc (patch) | |
| tree | 6d2bf6fdb040514f476b0d6fc5e6e1349812347d /src | |
| parent | e70b6cb335aab34fb5a14eb9f794a2491e5edfc8 (diff) | |
| parent | ae57f1c47bc6c262e56ffe01fb5dfb985e852fc1 (diff) | |
| download | rabbitmq-server-git-31acae72aa8ecca63fecb8cf1ac28c8f516b33cc.tar.gz | |
merge bug23167 into default (Large msg_store mailbox can block queue.declare)
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_msg_store.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index 207ddcb839..6576bfbbfb 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 |