diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-21 13:09:02 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-01-21 13:09:02 +0000 |
| commit | 3695364c713b5a5476c61233eaea41a4beabf890 (patch) | |
| tree | 6b824a8951a01006a6165372301b31d406fcda0a /src | |
| parent | af57a26e9a1a44ee9765460a07402c55e5583957 (diff) | |
| download | rabbitmq-server-git-3695364c713b5a5476c61233eaea41a4beabf890.tar.gz | |
fold cases
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 14 |
1 files changed, 4 insertions, 10 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 40337843ed..fbf0e573d7 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1249,17 +1249,11 @@ lock_message(true, MsgStruct, State = #ch{unacked_message_q = UAMQ}) -> lock_message(false, _MsgStruct, State) -> State. -send_confirms(State = #ch{confirmed = C, stats_timer = StatsTimer}) -> +send_confirms(State = #ch{confirmed = C}) -> C1 = lists:append(C), - MsgSeqNos = case rabbit_event:stats_level(StatsTimer) of - fine -> - [ begin maybe_incr_stats([{ExchangeName, 1}], - confirm, State), - MsgSeqNo - end || {MsgSeqNo, ExchangeName} <- C1]; - _ -> - [MsgSeqNo || {MsgSeqNo, _} <- C1] - end, + MsgSeqNos = [ begin maybe_incr_stats([{ExchangeName, 1}], confirm, State), + MsgSeqNo + end || {MsgSeqNo, ExchangeName} <- C1 ], send_confirms(MsgSeqNos, State #ch{confirmed = []}). send_confirms([], State) -> State; |
