diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-12-14 11:53:25 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-12-14 11:53:25 +0000 |
| commit | 4b3c6121f420fbfadce4ca5202d53558bb0ff506 (patch) | |
| tree | f193565ea474ccff89ea8520f97ae5400ae8e345 | |
| parent | 2c35646ffc45c7ca262fe1c00600e0866b991c80 (diff) | |
| download | rabbitmq-server-git-4b3c6121f420fbfadce4ca5202d53558bb0ff506.tar.gz | |
Shorter
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index c10d8fd328..457f658bf7 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -69,7 +69,7 @@ master_go(Syncer, Ref, Log, InfoPull, InfoPush, BQ, BQS) -> master_go0(InfoPull, Args, BQ, BQS) -> case BQ:fold(fun (Msg, MsgProps, {I, Last}) -> - InfoPull({synchronising, I}), + InfoPull({syncing, I}), master_send(Args, I, Last, Msg, MsgProps) end, {0, erlang:now()}, BQS) of {{shutdown, Reason}, BQS1} -> {shutdown, Reason, BQS1}; @@ -80,7 +80,7 @@ master_go0(InfoPull, Args, BQ, BQS) -> master_send({Syncer, Ref, Log, InfoPush, Parent}, I, Last, Msg, MsgProps) -> Acc = {I + 1, case timer:now_diff(erlang:now(), Last) > ?SYNC_PROGRESS_INTERVAL of - true -> InfoPush({synchronising, I}), + true -> InfoPush({syncing, I}), Log("~p messages", [I]), erlang:now(); false -> Last |