diff options
author | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-05 15:27:48 +0000 |
---|---|---|
committer | mergify-bot <noreply@mergify.io> | 2021-11-08 13:05:51 +0000 |
commit | 65496366178c687d64b9d7a63b033abad0da76be (patch) | |
tree | 9e8f6d6dd89ff0605424408da90492c3c88f64aa | |
parent | 0efba041228e230430196f55ff01375ee7dae4c1 (diff) | |
download | rabbitmq-server-git-65496366178c687d64b9d7a63b033abad0da76be.tar.gz |
Log recovery time by queue type
(cherry picked from commit 3d7edcea921a9fc15349475a61f0c47b6cc668ae)
-rw-r--r-- | deps/rabbit/src/rabbit_queue_type.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/deps/rabbit/src/rabbit_queue_type.erl b/deps/rabbit/src/rabbit_queue_type.erl index 055b637354..e5fc39bbdb 100644 --- a/deps/rabbit/src/rabbit_queue_type.erl +++ b/deps/rabbit/src/rabbit_queue_type.erl @@ -384,7 +384,9 @@ recover(VHost, Qs) -> rabbit_quorum_queue => [], rabbit_stream_queue => []}, Qs), maps:fold(fun (Mod, Queues, {R0, F0}) -> - {R, F} = Mod:recover(VHost, Queues), + {Taken, {R, F}} = timer:tc(Mod, recover, [VHost, Queues]), + rabbit_log:info("Recovering ~b queues of type ~s took ~bms", + [length(Queues), Mod, Taken div 1000]), {R0 ++ R, F0 ++ F} end, {[], []}, ByType). |