diff options
| author | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-04 23:51:59 +0200 |
|---|---|---|
| committer | Alvaro Videla <videlalvaro@gmail.com> | 2015-10-05 00:26:59 +0200 |
| commit | 7f27f432c2ac97a7cc12b57d652a522d4b9293cf (patch) | |
| tree | b1ddcfc61b7c257ac3e296ac55fa827c9051fa8f /src | |
| parent | b6f44d6a25ee2605a5eff5ca36ab52fa0e669f28 (diff) | |
| download | rabbitmq-server-git-7f27f432c2ac97a7cc12b57d652a522d4b9293cf.tar.gz | |
off by one error
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 7cc2e54d96..d7ed9484b5 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -127,7 +127,7 @@ master_batch_go0(Args, BatchSize, BQ, BQS) -> FoldFun = fun (Msg, MsgProps, Unacked, Acc) -> Acc1 = append_to_acc(Msg, MsgProps, Unacked, Acc), - case maybe_master_batch_send(Acc, BatchSize) of + case maybe_master_batch_send(Acc1, BatchSize) of true -> master_batch_send(Args, Acc1); false -> {cont, Acc1} end |