diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-07-06 17:40:37 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-07-06 17:40:37 +0100 |
| commit | 42bfd7a31ad6340083d12353ec384e974007bfa3 (patch) | |
| tree | 59e8e5ecb8f176a0d935ee314bec9f07b2a127e5 /src | |
| parent | 57263a7f999fe813de18405200e3d040bcc8429d (diff) | |
| download | rabbitmq-server-git-42bfd7a31ad6340083d12353ec384e974007bfa3.tar.gz | |
ditch per-x-q confirm stats
They don't work properly (see comment in code) and are emitted in a
very awkward place. And they expose implementation detail - there is
no a priori reason why queues should be involved in confirms - and are
of questionable utility.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 0c211b46ab..84728980fb 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -539,17 +539,13 @@ process_confirms(MsgSeqNos, QPid, Nack, State = #ch{unconfirmed_mq = UMQ, fun(MsgSeqNo, {_MXs, UMQ0, _UQM} = Acc) -> case gb_trees:lookup(MsgSeqNo, UMQ0) of {value, XQ} -> remove_unconfirmed(MsgSeqNo, QPid, XQ, - Acc, Nack, State); + Acc, Nack); none -> Acc end end, {[], UMQ, UQM}, MsgSeqNos), {MXs, State#ch{unconfirmed_mq = UMQ1, unconfirmed_qm = UQM1}}. -remove_unconfirmed(MsgSeqNo, QPid, {XName, Qs}, {MXs, UMQ, UQM}, Nack, - State) -> - %% these confirms will be emitted even when a queue dies, but that - %% should be fine, since the queue stats get erased immediately - maybe_incr_stats([{{QPid, XName}, 1}], confirm, State), +remove_unconfirmed(MsgSeqNo, QPid, {XName, Qs}, {MXs, UMQ, UQM}, Nack) -> UQM1 = case gb_trees:lookup(QPid, UQM) of {value, MsgSeqNos} -> MsgSeqNos1 = gb_sets:delete(MsgSeqNo, MsgSeqNos), |
