root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Extract a constant

This commit is contained in:
Michael Klishin 2021-02-26 16:55:06 +03:00
parent 85629e70da
commit ddf2dd6a12
No known key found for this signature in database
GPG Key ID: E80EDCFA0CDB21EE
4 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
deps/rabbitmq_management/include/rabbit_mgmt.hrl vendored
View File

@ -18,4 +18,5 @@
-define(HEALTH_CHECK_FAILURE_STATUS, 503). -define(HEALTH_CHECK_FAILURE_STATUS, 503).
-define(MANAGEMENT_PG_SCOPE, rabbit_mgmt). -define(MANAGEMENT_PG_SCOPE, rabbit_mgmt).
-define(MANAGEMENT_PG_GROUP, management_db).

2
deps/rabbitmq_management/src/rabbit_mgmt_db.erl vendored
View File

@ -732,7 +732,7 @@ created_stats_delegated(Type) ->
-spec delegate_invoke(mfargs()) -> [any()]. -spec delegate_invoke(mfargs()) -> [any()].
delegate_invoke(FunOrMFA) -> delegate_invoke(FunOrMFA) ->
MemberPids = [P || P <- pg:get_members(?MANAGEMENT_PG_SCOPE, management_db)], MemberPids = [P || P <- pg:get_members(?MANAGEMENT_PG_SCOPE, ?MANAGEMENT_PG_GROUP)],
{Results, Errors} = delegate:invoke(MemberPids, ?DELEGATE_PREFIX, FunOrMFA), {Results, Errors} = delegate:invoke(MemberPids, ?DELEGATE_PREFIX, FunOrMFA),
case Errors of case Errors of
[] -> ok; [] -> ok;

1
deps/rabbitmq_management_agent/include/rabbit_mgmt_agent.hrl vendored
View File

@ -15,3 +15,4 @@
%% %%
-define(MANAGEMENT_PG_SCOPE, rabbit_mgmt). -define(MANAGEMENT_PG_SCOPE, rabbit_mgmt).
-define(MANAGEMENT_PG_GROUP, management_db).

2
deps/rabbitmq_management_agent/src/rabbit_mgmt_agent_sup.erl vendored
View File

@ -36,7 +36,7 @@ start_link() ->
maybe_enable_metrics_collector() -> maybe_enable_metrics_collector() ->
case application:get_env(rabbitmq_management_agent, disable_metrics_collector, false) of case application:get_env(rabbitmq_management_agent, disable_metrics_collector, false) of
false -> false ->
ok = pg:join(?MANAGEMENT_PG_SCOPE, management_db, self()), ok = pg:join(?MANAGEMENT_PG_SCOPE, ?MANAGEMENT_PG_GROUP, self()),
ST = {rabbit_mgmt_storage, {rabbit_mgmt_storage, start_link, []}, ST = {rabbit_mgmt_storage, {rabbit_mgmt_storage, start_link, []},
permanent, ?WORKER_WAIT, worker, [rabbit_mgmt_storage]}, permanent, ?WORKER_WAIT, worker, [rabbit_mgmt_storage]},
MD = {delegate_management_sup, {delegate_sup, start_link, [5, ?DELEGATE_PREFIX]}, MD = {delegate_management_sup, {delegate_sup, start_link, [5, ?DELEGATE_PREFIX]},