summaryrefslogtreecommitdiff
path: root/src/rabbit_mirror_queue_sync.erl
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-01 12:37:23 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-01 12:37:23 +0000
commit5c56a6702ca13de0bbc67daf5c9bcb098011dd42 (patch)
tree7722afdbd12eca25b56bebe5e3b4dc872d2d43c3 /src/rabbit_mirror_queue_sync.erl
parent2a65b5a33f6d7d799d9960e6586d03b42ba9f31d (diff)
downloadrabbitmq-server-5c56a6702ca13de0bbc67daf5c9bcb098011dd42.tar.gz
better fun names
Diffstat (limited to 'src/rabbit_mirror_queue_sync.erl')
-rw-r--r--src/rabbit_mirror_queue_sync.erl12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl
index 5f0307fc..a1c54517 100644
--- a/src/rabbit_mirror_queue_sync.erl
+++ b/src/rabbit_mirror_queue_sync.erl
@@ -59,12 +59,12 @@ master_prepare(Ref, Log, SPids) ->
MPid = self(),
spawn_link(fun () -> syncer(Ref, Log, MPid, SPids) end).
-master_go(Syncer, Ref, Log, InfoPull, InfoPush, BQ, BQS) ->
- Args = {Syncer, Ref, Log, InfoPull, InfoPush, rabbit_misc:get_parent()},
+master_go(Syncer, Ref, Log, HandleInfo, EmitStats, BQ, BQS) ->
+ Args = {Syncer, Ref, Log, HandleInfo, EmitStats, rabbit_misc:get_parent()},
receive
{'EXIT', Syncer, normal} -> {already_synced, BQS};
{'EXIT', Syncer, Reason} -> {sync_died, Reason, BQS};
- {ready, Syncer} -> InfoPush({syncing, 0}),
+ {ready, Syncer} -> EmitStats({syncing, 0}),
master_go0(Args, BQ, BQS)
end.
@@ -77,15 +77,15 @@ master_go0(Args, BQ, BQS) ->
{_, BQS1} -> master_done(Args, BQS1)
end.
-master_send(Msg, MsgProps, {Syncer, Ref, Log, InfoPull, InfoPush, Parent},
+master_send(Msg, MsgProps, {Syncer, Ref, Log, HandleInfo, EmitStats, Parent},
{I, Last}) ->
T = case timer:now_diff(erlang:now(), Last) > ?SYNC_PROGRESS_INTERVAL of
- true -> InfoPush({syncing, I}),
+ true -> EmitStats({syncing, I}),
Log("~p messages", [I]),
erlang:now();
false -> Last
end,
- InfoPull({syncing, I}),
+ HandleInfo({syncing, I}),
receive
{'$gen_cast', {set_maximum_since_use, Age}} ->
ok = file_handle_cache:set_maximum_since_use(Age)