summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2014-02-18 13:30:23 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2014-02-18 13:30:23 +0000
commit703df9f52c08029827c1fe7ea369ecb58a0d273f (patch)
treeada42c4a96d3cdba2f981bf20e81d52383041bd3 /src
parent552e1481ecf74c6040b135d251537ba14c8d7a1a (diff)
downloadrabbitmq-server-git-703df9f52c08029827c1fe7ea369ecb58a0d273f.tar.gz
cosmetic
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_reader.erl6
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;