diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-13 23:54:40 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-13 23:54:40 +0200 |
| commit | 963953842918a287df05dd8c9dbe712835b116e7 (patch) | |
| tree | 9d218fb85d08b77d0d81be5f53e5dfbd7cd90e34 | |
| parent | 1539be4261a7c60fc062485c0911ca4fc3bbb79b (diff) | |
| download | rabbitmq-server-git-963953842918a287df05dd8c9dbe712835b116e7.tar.gz | |
fixes stats for lazy publish delivered
| -rw-r--r-- | src/rabbit_variable_queue.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index b663a6a362..2bb737f742 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1401,7 +1401,6 @@ stats(Signs, Statuses, State) -> expand_signs(ready0) -> {0, 0, true}; expand_signs(lazy_pub) -> {1, 0, true}; -expand_signs(lazy_pub_del) -> {0, 1, true}; expand_signs({A, B}) -> {A, B, false}. expand_statuses({none, A}) -> {false, msg_in_ram(A), A}; @@ -1785,7 +1784,7 @@ publish_delivered1(Msg = #basic_message { is_persistent = IsPersistent, Delta1 = expand_delta(SeqId, Delta), State2 = record_pending_ack(m(MsgStatus1), State1), UC1 = gb_sets_maybe_insert(NeedsConfirming, MsgId, UC), - State3 = stats(lazy_pub_del, {lazy, MsgStatus1}, + State3 = stats({0, 1}, {lazy, MsgStatus1}, State2 #vqstate { delta = Delta1, next_seq_id = SeqId + 1, out_counter = OutCount + 1, |