diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-29 12:09:57 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-29 12:09:57 +0000 |
| commit | e6768457d3788fc3e6576a0468c98a3733afefbb (patch) | |
| tree | af112b2a0dfba709e745cd7393b4bb03314c299b | |
| parent | 4debb61fb625758cb850d2cf27af93e2cd00b0ea (diff) | |
| download | rabbitmq-server-e6768457d3788fc3e6576a0468c98a3733afefbb.tar.gz | |
Respond to FHC.
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 94f5ae0f..0b9bd42a 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -81,6 +81,12 @@ master_send({Syncer, Ref, QName}, I, Last, Msg, MsgProps) -> end}, Parent = rabbit_misc:get_parent(), receive + {'$gen_cast', {set_maximum_since_use, Age}} -> + ok = file_handle_cache:set_maximum_since_use(Age) + after 0 -> + ok + end, + receive {next, Ref} -> Syncer ! {msg, Ref, Msg, MsgProps}, {cont, Acc}; {'EXIT', Syncer, Reason} -> {stop, {sync_died, Reason}}; @@ -101,7 +107,7 @@ syncer(Ref, QName, MPid, SPids) -> rabbit_log:info("Synchronising ~s: all slaves already synced~n", [rabbit_misc:rs(QName)]); SPidsMRefs1 -> - rabbit_log:info("Synchronising ~s: ~p require sync~n", + rabbit_log:info("Synchronising ~s: ~p to sync~n", [rabbit_misc:rs(QName), [rabbit_misc:pid_to_string(S) || {S, _} <- SPidsMRefs1]]), |