Skip to content

Commit ebecded

Browse files
Resolve a conflict #10034 #10049, take two
1 parent 031c90c commit ebecded

File tree

1 file changed

+13
-20
lines changed

1 file changed

+13
-20
lines changed

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 13 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1097,11 +1097,7 @@ add_member(Q, Node, Timeout) when ?amqqueue_is_quorum(Q) ->
10971097
%% TODO parallel calls might crash this, or add a duplicate in quorum_nodes
10981098
ServerId = {RaName, Node},
10991099
Members = members(Q),
1100-
TickTimeout = application:get_env(rabbit, quorum_tick_interval,
1101-
?TICK_TIMEOUT),
1102-
SnapshotInterval = application:get_env(rabbit, quorum_snapshot_interval,
1103-
?SNAPSHOT_INTERVAL),
1104-
Conf = make_ra_conf(Q, ServerId, TickTimeout, SnapshotInterval),
1100+
Conf = make_ra_conf(Q, ServerId),
11051101
case ra:start_server(?RA_SYSTEM, Conf) of
11061102
ok ->
11071103
case ra:add_member(Members, ServerId, Timeout) of
@@ -1602,33 +1598,30 @@ format_ra_event(ServerId, Evt, QRef) ->
16021598
{'$gen_cast', {queue_event, QRef, {ServerId, Evt}}}.
16031599

16041600
make_ra_conf(Q, ServerId) ->
1605-
make_ra_conf(Q, ServerId, voter).
1606-
1607-
make_ra_conf(Q, ServerId, Membership) ->
16081601
TickTimeout = application:get_env(rabbit, quorum_tick_interval,
16091602
?TICK_TIMEOUT),
16101603
SnapshotInterval = application:get_env(rabbit, quorum_snapshot_interval,
16111604
?SNAPSHOT_INTERVAL),
1612-
make_ra_conf(Q, ServerId, TickTimeout, SnapshotInterval, Membership).
1605+
make_ra_conf(Q, ServerId, TickTimeout, SnapshotInterval).
16131606

1614-
make_ra_conf(Q, ServerId, TickTimeout, SnapshotInterval, Membership) ->
1607+
make_ra_conf(Q, ServerId, TickTimeout, SnapshotInterval) ->
16151608
QName = amqqueue:get_name(Q),
16161609
RaMachine = ra_machine(Q),
16171610
[{ClusterName, _} | _] = Members = members(Q),
16181611
UId = ra:new_uid(ra_lib:to_binary(ClusterName)),
16191612
FName = rabbit_misc:rs(QName),
16201613
Formatter = {?MODULE, format_ra_event, [QName]},
16211614
#{cluster_name => ClusterName,
1622-
id => ServerId,
1623-
uid => UId,
1624-
friendly_name => FName,
1625-
metrics_key => QName,
1626-
initial_members => Members,
1627-
log_init_args => #{uid => UId,
1628-
snapshot_interval => SnapshotInterval},
1629-
tick_timeout => TickTimeout,
1630-
machine => RaMachine,
1631-
ra_event_formatter => Formatter}.
1615+
id => ServerId,
1616+
uid => UId,
1617+
friendly_name => FName,
1618+
metrics_key => QName,
1619+
initial_members => Members,
1620+
log_init_args => #{uid => UId,
1621+
snapshot_interval => SnapshotInterval},
1622+
tick_timeout => TickTimeout,
1623+
machine => RaMachine,
1624+
ra_event_formatter => Formatter}.
16321625

16331626
make_mutable_config(Q) ->
16341627
QName = amqqueue:get_name(Q),

0 commit comments

Comments
 (0)