diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-16 17:41:24 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-10-16 17:41:24 +0100 |
| commit | f713d9848a529f97b7bfb9ec88acf8d56ace1299 (patch) | |
| tree | 2b9e4298821741528d5a53d925bc3a1684e6d871 | |
| parent | a00e05261cc178cf967b7a4917e3c094a966e489 (diff) | |
| download | rabbitmq-server-git-f713d9848a529f97b7bfb9ec88acf8d56ace1299.tar.gz | |
no more blind confirms
| -rw-r--r-- | src/rabbit_variable_queue.erl | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 8ff44a296d..8a3fd9d917 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1316,12 +1316,9 @@ must_sync_index(#vqstate { msg_indices_on_disk = MIOD, %% subtraction. not (gb_sets:is_empty(UC) orelse gb_sets:is_subset(UC, MIOD)). -blind_confirm(Callback, MsgIdSet) -> - Callback(?MODULE, - fun (?MODULE, State) -> record_confirms(MsgIdSet, State) end). - msgs_written_to_disk(Callback, MsgIdSet, ignored) -> - blind_confirm(Callback, MsgIdSet); + Callback(?MODULE, + fun (?MODULE, State) -> record_confirms(MsgIdSet, State) end); msgs_written_to_disk(Callback, MsgIdSet, written) -> Callback(?MODULE, fun (?MODULE, State = #vqstate { msgs_on_disk = MOD, |