diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-07 18:16:41 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-07 18:16:41 +0000 |
| commit | 10019f2985e35118b6535d4d9fd6b227a33183ac (patch) | |
| tree | c3085fa0d01a06fbd2a30222e64246f5357a9826 /src/rabbit_variable_queue.erl | |
| parent | c1ed96f54d78908639925800fb11cff0d24a4970 (diff) | |
| download | rabbitmq-server-10019f2985e35118b6535d4d9fd6b227a33183ac.tar.gz | |
rename WaitForIndex to ActionTakenbug23612
Diffstat (limited to 'src/rabbit_variable_queue.erl')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c30be37c..48baeea6 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -412,8 +412,8 @@ stop_msg_store() -> init(QueueName, IsDurable, Recover) -> Self = self(), init(QueueName, IsDurable, Recover, - fun (Guids, WaitForIndex) -> - msgs_written_to_disk(Self, Guids, WaitForIndex) + fun (Guids, ActionTaken) -> + msgs_written_to_disk(Self, Guids, ActionTaken) end, fun (Guids) -> msg_indices_written_to_disk(Self, Guids) end). @@ -1402,9 +1402,9 @@ blind_confirm(QPid, GuidSet) -> msgs_confirmed(GuidSet, State) end). -msgs_written_to_disk(QPid, GuidSet, false) -> +msgs_written_to_disk(QPid, GuidSet, removed) -> blind_confirm(QPid, GuidSet); -msgs_written_to_disk(QPid, GuidSet, true) -> +msgs_written_to_disk(QPid, GuidSet, written) -> rabbit_amqqueue:maybe_run_queue_via_backing_queue_async( QPid, fun (State = #vqstate { msgs_on_disk = MOD, msg_indices_on_disk = MIOD, |