diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2014-02-04 16:42:28 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2014-02-04 16:42:28 +0000 |
| commit | e2170d47dfb8ab2e3685e284c6d2f8d0cea1bd33 (patch) | |
| tree | 8f993a2292f929466a98e42e0bb38041a74d7f7d | |
| parent | 5c48f12df0142471becceda98a23200a4f3b5e5e (diff) | |
| download | rabbitmq-server-e2170d47dfb8ab2e3685e284c6d2f8d0cea1bd33.tar.gz | |
update_counter--
correctness++
And also re-construct the prefix correctly.
| -rw-r--r-- | src/rabbit_queue_consumers.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_queue_consumers.erl b/src/rabbit_queue_consumers.erl index 69659848..ca050f14 100644 --- a/src/rabbit_queue_consumers.erl +++ b/src/rabbit_queue_consumers.erl @@ -270,12 +270,11 @@ subtract_acks([], Prefix, CTagCounts, AckQ) -> {CTagCounts, queue:join(queue:from_list(lists:reverse(Prefix)), AckQ)}; subtract_acks([T | TL] = AckTags, Prefix, CTagCounts, AckQ) -> case queue:out(AckQ) of - {{value, {T, CTag}}, QTail} -> + {{value, {T, CTag}}, QTail} -> subtract_acks(TL, Prefix, orddict:update_counter(CTag, 1, CTagCounts), QTail); - {{value, {AT, CTag}}, QTail} -> - subtract_acks(AckTags, [AT | Prefix], - orddict:update_counter(CTag, 1, CTagCounts), QTail) + {{value, V}, QTail} -> + subtract_acks(AckTags, [V | Prefix], CTagCounts, QTail) end. possibly_unblock(Update, ChPid, State) -> |