diff options
| author | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-05 15:27:48 +0000 |
|---|---|---|
| committer | Karl Nilsson <kjnilsson@gmail.com> | 2021-11-08 11:07:41 +0000 |
| commit | 3d7edcea921a9fc15349475a61f0c47b6cc668ae (patch) | |
| tree | a60deaec3a4dd57c6c5e67be8dd03e548a1839b1 | |
| parent | 1c6e45257d824ef72b11fad171bb11a88bb9a4b5 (diff) | |
| download | rabbitmq-server-git-3d7edcea921a9fc15349475a61f0c47b6cc668ae.tar.gz | |
Log recovery time by queue type
| -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 886e0ba7e8..128d0a2bd0 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). |