diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-10 21:26:10 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-04-10 21:26:10 +0100 |
| commit | 7711938a8f2a279b1d64afd106f3bfb724ece927 (patch) | |
| tree | 2df68d78a7c9a90785092ead7e8cd71f2e4e2746 /src | |
| parent | 371faaed57fb9489d768c02666a3b0807c5e88ba (diff) | |
| download | rabbitmq-server-git-7711938a8f2a279b1d64afd106f3bfb724ece927.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index cd9dabc4cc..5db0fa2f45 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -177,10 +177,11 @@ dropwhile(Pred, MsgFun, backing_queue = BQ, set_delivered = SetDelivered, backing_queue_state = BQS }) -> - Len = BQ:len(BQS), + Len = BQ:len(BQS), BQS1 = BQ:dropwhile(Pred, MsgFun, BQS), - ok = gm:broadcast(GM, {set_length, BQ:len(BQS1)}), - Dropped = Len - BQ:len(BQS1), + Len1 = BQ:len(BQS1), + ok = gm:broadcast(GM, {set_length, Len1}), + Dropped = Len - Len1, SetDelivered1 = lists:max([0, SetDelivered - Dropped]), State #state { backing_queue_state = BQS1, set_delivered = SetDelivered1 }. |