summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2010-08-25 11:52:24 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2010-08-25 11:52:24 +0100
commit0c86922cded6d5f1a1f482580157f98e1bec10ea (patch)
tree2206ceec235a980df351127bbbd61289735348b9
parent9398957b19e81628d057fd7ea2d7a0eb4630ab1f (diff)
parentf0d747b04add6133e85633335590fffb7015456d (diff)
downloadrabbitmq-server-bug23178.tar.gz
Merging in default now that default has only one headbug23178
-rw-r--r--src/rabbit_msg_store.erl16
1 files changed, 8 insertions, 8 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl
index 6576bfbb..ff248c23 100644
--- a/src/rabbit_msg_store.erl
+++ b/src/rabbit_msg_store.erl
@@ -379,7 +379,7 @@ client_terminate(CState) ->
client_delete_and_terminate(CState, Server, Ref) ->
ok = client_terminate(CState),
- ok = gen_server2:call(Server, {delete_client, Ref}, infinity).
+ ok = gen_server2:cast(Server, {delete_client, Ref}).
successfully_recovered_state(Server) ->
gen_server2:pcall(Server, 7, successfully_recovered_state, infinity).
@@ -604,12 +604,7 @@ handle_call({new_client_state, CRef}, _From,
State #msstate { client_refs = sets:add_element(CRef, ClientRefs) });
handle_call(successfully_recovered_state, _From, State) ->
- reply(State #msstate.successfully_recovered, State);
-
-handle_call({delete_client, CRef}, _From,
- State = #msstate { client_refs = ClientRefs }) ->
- reply(ok,
- State #msstate { client_refs = sets:del_element(CRef, ClientRefs) }).
+ reply(State #msstate.successfully_recovered, State).
handle_cast({write, Guid},
State = #msstate { current_file_handle = CurHdl,
@@ -724,7 +719,12 @@ handle_cast({gc_done, Reclaimed, Src, Dst},
handle_cast({set_maximum_since_use, Age}, State) ->
ok = file_handle_cache:set_maximum_since_use(Age),
- noreply(State).
+ noreply(State);
+
+handle_cast({delete_client, CRef},
+ State = #msstate { client_refs = ClientRefs }) ->
+ noreply(
+ State #msstate { client_refs = sets:del_element(CRef, ClientRefs) }).
handle_info(timeout, State) ->
noreply(internal_sync(State));