Skip to content

Commit a3bcc37

Browse files
committed
Handle suggested_queue_nodes output when slave nodes are empty
1 parent 34f42f7 commit a3bcc37

File tree

3 files changed

+12
-7
lines changed

3 files changed

+12
-7
lines changed

.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
.*.sw?
44
*.beam
55
*.coverdata
6+
MNesiaCore.*
67
/.erlang.mk/
78
/cover/
89
/debug/

src/rabbit_queue_master_location_misc.erl

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,5 +93,9 @@ get_location_mod_by_config(#amqqueue{}) ->
9393
end.
9494

9595
all_nodes(Queue = #amqqueue{}) ->
96-
{MNode, SNodes} = rabbit_mirror_queue_misc:suggested_queue_nodes(Queue),
96+
handle_suggested_queue_nodes(rabbit_mirror_queue_misc:suggested_queue_nodes(Queue)).
97+
98+
handle_suggested_queue_nodes({MNode, []}) ->
99+
rabbit_nodes:all_running();
100+
handle_suggested_queue_nodes({MNode, SNodes}) ->
97101
[MNode | SNodes].

test/queue_master_location_SUITE.erl

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ end_per_testcase(Testcase, Config) ->
112112
declare_args(Config) ->
113113
setup_test_environment(Config),
114114
unset_location_config(Config),
115-
QueueName = rabbit_misc:r(<<"/">>, queue, Q= <<"qm.test">>),
115+
QueueName = rabbit_misc:r(<<"/">>, queue, Q = <<"qm.test">>),
116116
Args = [{<<"x-queue-master-locator">>, longstr, <<"min-masters">>}],
117117
declare(Config, QueueName, false, false, Args, none),
118118
verify_min_master(Config, Q).
@@ -121,14 +121,14 @@ declare_policy(Config) ->
121121
setup_test_environment(Config),
122122
unset_location_config(Config),
123123
set_location_policy(Config, ?POLICY, <<"min-masters">>),
124-
QueueName = rabbit_misc:r(<<"/">>, queue, Q= <<"qm.test">>),
124+
QueueName = rabbit_misc:r(<<"/">>, queue, Q = <<"qm.test">>),
125125
declare(Config, QueueName, false, false, _Args=[], none),
126126
verify_min_master(Config, Q).
127127

128128
declare_config(Config) ->
129129
setup_test_environment(Config),
130130
set_location_config(Config, <<"min-masters">>),
131-
QueueName = rabbit_misc:r(<<"/">>, queue, Q= <<"qm.test">>),
131+
QueueName = rabbit_misc:r(<<"/">>, queue, Q = <<"qm.test">>),
132132
declare(Config, QueueName, false, false, _Args=[], none),
133133
verify_min_master(Config, Q),
134134
unset_location_config(Config),
@@ -140,23 +140,23 @@ declare_config(Config) ->
140140

141141
calculate_min_master(Config) ->
142142
setup_test_environment(Config),
143-
QueueName = rabbit_misc:r(<<"/">>, queue, Q= <<"qm.test">>),
143+
QueueName = rabbit_misc:r(<<"/">>, queue, Q = <<"qm.test">>),
144144
Args = [{<<"x-queue-master-locator">>, longstr, <<"min-masters">>}],
145145
declare(Config, QueueName, false, false, Args, none),
146146
verify_min_master(Config, Q),
147147
ok.
148148

149149
calculate_random(Config) ->
150150
setup_test_environment(Config),
151-
QueueName = rabbit_misc:r(<<"/">>, queue, Q= <<"qm.test">>),
151+
QueueName = rabbit_misc:r(<<"/">>, queue, Q = <<"qm.test">>),
152152
Args = [{<<"x-queue-master-locator">>, longstr, <<"random">>}],
153153
declare(Config, QueueName, false, false, Args, none),
154154
verify_random(Config, Q),
155155
ok.
156156

157157
calculate_client_local(Config) ->
158158
setup_test_environment(Config),
159-
QueueName = rabbit_misc:r(<<"/">>, queue, Q= <<"qm.test">>),
159+
QueueName = rabbit_misc:r(<<"/">>, queue, Q = <<"qm.test">>),
160160
Args = [{<<"x-queue-master-locator">>, longstr, <<"client-local">>}],
161161
declare(Config, QueueName, false, false, Args, none),
162162
verify_client_local(Config, Q),

0 commit comments

Comments
 (0)