diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-01-19 16:42:04 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-01-19 16:42:04 +0000 |
| commit | 4f8383a7c5d9037fc53ffbaa02cc92be888c60cf (patch) | |
| tree | 7a703755eaadee97f4118f8a72cbae5af53bd8b0 /src/rabbit_msg_store.erl | |
| parent | 3a243071d42f9878e7bf4e4d211bba4aa7e60403 (diff) | |
| download | rabbitmq-server-4f8383a7c5d9037fc53ffbaa02cc92be888c60cf.tar.gz | |
More credit for the queue -> msg_store case.
Diffstat (limited to 'src/rabbit_msg_store.erl')
| -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 28eb8213..495e2976 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -463,7 +463,7 @@ client_delete_and_terminate(CState = #client_msstate { client_ref = Ref }) -> client_ref(#client_msstate { client_ref = Ref }) -> Ref. write_flow(MsgId, Msg, CState = #client_msstate { server = Server }) -> - credit_flow:send(whereis(Server)), + credit_flow:send(whereis(Server), ?CREDIT_DISC_BOUND), client_write(MsgId, Msg, flow, CState). write(MsgId, Msg, CState) -> client_write(MsgId, Msg, noflow, CState). @@ -808,7 +808,7 @@ handle_cast({write, CRef, MsgId, Flow}, clients = Clients }) -> case Flow of flow -> {CPid, _, _} = dict:fetch(CRef, Clients), - credit_flow:ack(CPid); + credit_flow:ack(CPid, ?CREDIT_DISC_BOUND); noflow -> ok end, true = 0 =< ets:update_counter(CurFileCacheEts, MsgId, {3, -1}), |