root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

updates comment

This commit is contained in:
Alvaro Videla 2015-09-07 18:32:13 +02:00
parent bb515df0ea
commit fe4c7980f3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/rabbit_variable_queue.erl
View File

@ -533,9 +533,9 @@ terminate(_Reason, State) ->
%% the only difference between purge and delete is that delete also
%% needs to delete everything that's been delivered and not ack'd.
delete_and_terminate(_Reason, State) ->
%% There is no need to interact with qi at all - which we do as
%% part of 'purge' and 'purge_pending_ack', other than deleting
%% it.
%% Normally when we purge messages we interact with the qi by
%% issues delivers and acks for every purged message. In this case
%% we don't need to do that, so we just delete the qi.
State1 = purge_and_index_reset(State),
State2 = #vqstate { msg_store_clients = {MSCStateP, MSCStateT} } =
purge_pending_ack_delete_and_terminate(State1),