diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-09-20 19:35:30 -0600 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2017-09-22 11:23:33 -0700 |
| commit | ece1c99c2d53c8efd03bfde949ce1c2b13234c05 (patch) | |
| tree | e7388582f08fb40a07dcd5f01b36ffbde29cad6a | |
| parent | 225063f5607ddcf4a8e2ddc0805fc8991b675ca7 (diff) | |
| download | rabbitmq-server-git-ece1c99c2d53c8efd03bfde949ce1c2b13234c05.tar.gz | |
Cosmetics
| -rw-r--r-- | src/rabbit_queue_location_min_masters.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_queue_location_random.erl | 2 | ||||
| -rw-r--r-- | src/rabbit_queue_master_location_misc.erl | 4 |
3 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_queue_location_min_masters.erl b/src/rabbit_queue_location_min_masters.erl index 8fc8d47aae..5d6f568d4a 100644 --- a/src/rabbit_queue_location_min_masters.erl +++ b/src/rabbit_queue_location_min_masters.erl @@ -37,7 +37,7 @@ description() -> [{description, <<"Locate queue master node from cluster node with least bound queues">>}]. -queue_master_location(#amqqueue{}=Q) -> +queue_master_location(#amqqueue{} = Q) -> Cluster = rabbit_queue_master_location_misc:all_nodes(Q), VHosts = rabbit_vhost:list(), BoundQueueMasters = get_bound_queue_masters_per_vhost(VHosts, []), diff --git a/src/rabbit_queue_location_random.erl b/src/rabbit_queue_location_random.erl index 9f318b9359..d103d3f126 100644 --- a/src/rabbit_queue_location_random.erl +++ b/src/rabbit_queue_location_random.erl @@ -37,7 +37,7 @@ description() -> [{description, <<"Locate queue master node from cluster in a random manner">>}]. -queue_master_location(#amqqueue{}=Q) -> +queue_master_location(#amqqueue{} = Q) -> Cluster = rabbit_queue_master_location_misc:all_nodes(Q), RandomPos = erlang:phash2(time_compat:monotonic_time(), length(Cluster)), MasterNode = lists:nth(RandomPos + 1, Cluster), diff --git a/src/rabbit_queue_master_location_misc.erl b/src/rabbit_queue_master_location_misc.erl index 0e3dec9b83..bb2329b958 100644 --- a/src/rabbit_queue_master_location_misc.erl +++ b/src/rabbit_queue_master_location_misc.erl @@ -92,6 +92,6 @@ get_location_mod_by_config(#amqqueue{}) -> _ -> {error, "queue_master_locator undefined"} end. -all_nodes(Queue=#amqqueue{}) -> +all_nodes(Queue = #amqqueue{}) -> {MNode, SNodes} = rabbit_mirror_queue_misc:suggested_queue_nodes(Queue), - [MNode|SNodes]. + [MNode | SNodes]. |