Skip to content

Commit a243e5b

Browse files
committed
Add test with network partition for super stream SAC group
1 parent f99ad34 commit a243e5b

File tree

3 files changed

+240
-42
lines changed

3 files changed

+240
-42
lines changed

deps/rabbit/src/rabbit_stream_sac_coordinator.erl

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1168,8 +1168,7 @@ evaluate_active_consumer(#group{consumers = Consumers} = G) ->
11681168
do_evaluate_active_consumer(G#group{consumers = eligible(Consumers)})
11691169
end.
11701170

1171-
do_evaluate_active_consumer(#group{partition_index = -1,
1172-
consumers = Consumers})
1171+
do_evaluate_active_consumer(#group{consumers = Consumers})
11731172
when length(Consumers) == 0 ->
11741173
undefined;
11751174
do_evaluate_active_consumer(#group{partition_index = -1,

deps/rabbitmq_ct_helpers/src/stream_test_utils.erl

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,9 @@
1818

1919
connect(Config, Node) ->
2020
StreamPort = rabbit_ct_broker_helpers:get_node_config(Config, Node, tcp_port_stream),
21+
connect(StreamPort).
22+
23+
connect(StreamPort) ->
2124
{ok, Sock} = gen_tcp:connect("localhost", StreamPort, [{active, false}, {mode, binary}]),
2225

2326
C0 = rabbit_stream_core:init(0),

0 commit comments

Comments
 (0)