diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-02-18 13:30:23 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-02-18 13:30:23 +0000 |
| commit | 703df9f52c08029827c1fe7ea369ecb58a0d273f (patch) | |
| tree | ada42c4a96d3cdba2f981bf20e81d52383041bd3 /src | |
| parent | 552e1481ecf74c6040b135d251537ba14c8d7a1a (diff) | |
| download | rabbitmq-server-git-703df9f52c08029827c1fe7ea369ecb58a0d273f.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_reader.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 11621b127f..316e63c26a 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -1076,9 +1076,9 @@ i(state, #v1{connection_state = ConnectionState, throttle = #throttle{alarmed_by = Alarms, last_blocked_by = WasBlockedBy, last_blocked_at = T}}) -> - case Alarms =:= [] andalso %% not blocked by resource alarms - (credit_flow:blocked() %% blocked by flow now - orelse %% blocked by flow recently + case Alarms =:= [] andalso %% not throttled by resource alarms + (credit_flow:blocked() %% throttled by flow now + orelse %% throttled by flow recently (WasBlockedBy =:= flow andalso T =/= never andalso timer:now_diff(erlang:now(), T) < 5000000)) of true -> flow; |
