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 | fe8e5bf03098a9393ad0f1db433cf97cea4d2fc2 (patch) | |
| tree | 2df68d78a7c9a90785092ead7e8cd71f2e4e2746 | |
| parent | f1719addbe1c0d7e0f9fbcf2ce8445a2841e80c8 (diff) | |
| download | rabbitmq-server-fe8e5bf03098a9393ad0f1db433cf97cea4d2fc2.tar.gz | |
cosmetic
| -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 cd9dabc4..5db0fa2f 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 }. |