diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-10-16 16:55:43 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-10-16 16:55:43 +0100 |
| commit | 03376e026f7e9705a8c7000f93c515a63a7becc1 (patch) | |
| tree | 46f235bc44563b84cfc0c4099e26e85e9daa9998 | |
| parent | 01346bcfb11aa88e5a1ab51361997f5415ce0dd6 (diff) | |
| download | rabbitmq-server-git-03376e026f7e9705a8c7000f93c515a63a7becc1.tar.gz | |
assertion that the purge count equals the queue length
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index ac2bab0fd7..ffdb695e40 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -289,10 +289,10 @@ ack(AckTags, State = #vqstate { index_state = IndexState }) -> purge(State = #vqstate { prefetcher = undefined, q4 = Q4, index_state = IndexState, len = Len }) -> {Q4Count, IndexState1} = remove_queue_entries(Q4, IndexState), - {TotalCount, State1} = + {Len, State1} = purge1(Q4Count, State #vqstate { index_state = IndexState1, q4 = queue:new() }), - {TotalCount, State1 #vqstate { len = 0 }}; + {Len, State1 #vqstate { len = 0 }}; purge(State) -> purge(drain_prefetcher(stop, State)). |