diff options
| author | Luke Bakken <luke@bakken.io> | 2018-04-11 08:44:02 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-04-11 08:44:02 -0700 |
| commit | 3b4af50b8886cf11a2d39b2cd0d92c0745dc9d84 (patch) | |
| tree | 4b2053c8fccb858aca96ed7ff1e496cb7e1a7abd | |
| parent | a267d6bc0b02eff60efed677027c6db392be726b (diff) | |
| parent | e840323bc49db4e4e378cf7b95bacabe2f40d1c8 (diff) | |
| download | rabbitmq-server-git-3b4af50b8886cf11a2d39b2cd0d92c0745dc9d84.tar.gz | |
Merge pull request #1577 from rabbitmq/rabbitmq-peer-discovery-k8s-23
Make it possible for peer discovery backends to provide their own RSD range
| -rw-r--r-- | src/rabbit_peer_discovery.erl | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/rabbit_peer_discovery.erl b/src/rabbit_peer_discovery.erl index b1a6db637c..19df5c07cb 100644 --- a/src/rabbit_peer_discovery.erl +++ b/src/rabbit_peer_discovery.erl @@ -184,11 +184,16 @@ inject_randomized_delay() -> -spec randomized_delay_range_in_ms() -> {integer(), integer()}. randomized_delay_range_in_ms() -> + Backend = backend(), + Default = case erlang:function_exported(Backend, randomized_startup_delay_range, 0) of + true -> Backend:randomized_startup_delay_range(); + false -> ?DEFAULT_STARTUP_RANDOMIZED_DELAY + end, {Min, Max} = case application:get_env(rabbit, cluster_formation) of {ok, Proplist} -> - proplists:get_value(randomized_startup_delay_range, Proplist, ?DEFAULT_STARTUP_RANDOMIZED_DELAY); + proplists:get_value(randomized_startup_delay_range, Proplist, Default); undefined -> - ?DEFAULT_STARTUP_RANDOMIZED_DELAY + Default end, {Min * 1000, Max * 1000}. |