diff options
| author | Gerhard Lazu <gerhard@lazu.co.uk> | 2020-03-12 15:46:25 +0000 |
|---|---|---|
| committer | Gerhard Lazu <gerhard@lazu.co.uk> | 2020-03-12 15:59:53 +0000 |
| commit | b9d672c4fa07ef8645547db091bc4d3752109637 (patch) | |
| tree | b69ad67d33cb5ce8c2427fd0cac4c36ec133141a | |
| parent | 1a60b43aa99bb8d97fe29a3c5266ede7678fe26e (diff) | |
| download | rabbitmq-server-git-b9d672c4fa07ef8645547db091bc4d3752109637.tar.gz | |
Log if definitions are imported sequentially vs concurrently
Signed-off-by: Philip Kuryloski <pkuryloski@pivotal.io>
(cherry picked from commit 955ad8d90744f352a2608ab3e305f3419df0cf0f)
| -rw-r--r-- | src/rabbit_definitions.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_definitions.erl b/src/rabbit_definitions.erl index 7460b1b838..ee7e236f8e 100644 --- a/src/rabbit_definitions.erl +++ b/src/rabbit_definitions.erl @@ -304,7 +304,7 @@ sequential_for_all(Category, ActingUser, Definitions, Fun) -> List -> case length(List) of 0 -> ok; - N -> rabbit_log:info("Importing ~p ~s...", [N, human_readable_category_name(Category)]) + N -> rabbit_log:info("Importing sequentially ~p ~s...", [N, human_readable_category_name(Category)]) end, [begin %% keys are expected to be atoms @@ -324,7 +324,7 @@ concurrent_for_all(Category, ActingUser, Definitions, Fun) -> List -> case length(List) of 0 -> ok; - N -> rabbit_log:info("Importing ~p ~s...", [N, human_readable_category_name(Category)]) + N -> rabbit_log:info("Importing concurrently ~p ~s...", [N, human_readable_category_name(Category)]) end, WorkPoolFun = fun(M) -> Fun(atomize_keys(M), ActingUser) |