diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-25 22:07:40 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-25 22:07:40 +0100 |
| commit | 8cbced41a42542001f64a5fb2d8526965583ae02 (patch) | |
| tree | a0b2cd6512416512b73e928d51aac05b56b2a21a | |
| parent | dd38990bd1b1e3f11ba71d85546482367068aa29 (diff) | |
| download | rabbitmq-server-git-8cbced41a42542001f64a5fb2d8526965583ae02.tar.gz | |
remember when we've refused a queue's can_send due to being blocked
so that we can tell the queue when we get unblocked
| -rw-r--r-- | src/rabbit_limiter.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 1b72dd761a..e79583fa89 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -120,9 +120,9 @@ init([ChPid, UnackedMsgCount]) -> prioritise_call(get_limit, _From, _State) -> 9; prioritise_call(_Msg, _From, _State) -> 0. -handle_call({can_send, _QPid, _AckRequired}, _From, +handle_call({can_send, QPid, _AckRequired}, _From, State = #lim{blocked = true}) -> - {reply, false, State}; + {reply, false, limit_queue(QPid, State)}; handle_call({can_send, QPid, AckRequired}, _From, State = #lim{volume = Volume}) -> case limit_reached(State) of |