@@ -1097,15 +1097,11 @@ add_member(Q, Node, Timeout) when ?amqqueue_is_quorum(Q) ->
1097
1097
% % TODO parallel calls might crash this, or add a duplicate in quorum_nodes
1098
1098
ServerId = {RaName , Node },
1099
1099
Members = members (Q ),
1100
- <<<<<<< HEAD
1101
1100
TickTimeout = application :get_env (rabbit , quorum_tick_interval ,
1102
1101
? TICK_TIMEOUT ),
1103
1102
SnapshotInterval = application :get_env (rabbit , quorum_snapshot_interval ,
1104
1103
? SNAPSHOT_INTERVAL ),
1105
1104
Conf = make_ra_conf (Q , ServerId , TickTimeout , SnapshotInterval ),
1106
- =======
1107
- Conf = make_ra_conf (Q , ServerId , Membership ),
1108
- >>>>>>> ddf896e4e4 (QQ : ensure members that are started late have right config .)
1109
1105
case ra :start_server (? RA_SYSTEM , Conf ) of
1110
1106
ok ->
1111
1107
case ra :add_member (Members , ServerId , Timeout ) of
@@ -1605,9 +1601,6 @@ members(Q) when ?amqqueue_is_quorum(Q) ->
1605
1601
format_ra_event (ServerId , Evt , QRef ) ->
1606
1602
{'$gen_cast' , {queue_event , QRef , {ServerId , Evt }}}.
1607
1603
1608
- <<<<<<< HEAD
1609
- make_ra_conf (Q , ServerId , TickTimeout , SnapshotInterval ) ->
1610
- =======
1611
1604
make_ra_conf (Q , ServerId ) ->
1612
1605
make_ra_conf (Q , ServerId , voter ).
1613
1606
@@ -1619,7 +1612,6 @@ make_ra_conf(Q, ServerId, Membership) ->
1619
1612
make_ra_conf (Q , ServerId , TickTimeout , SnapshotInterval , Membership ).
1620
1613
1621
1614
make_ra_conf (Q , ServerId , TickTimeout , SnapshotInterval , Membership ) ->
1622
- >>>>>>> ddf896e4e4 (QQ : ensure members that are started late have right config .)
1623
1615
QName = amqqueue :get_name (Q ),
1624
1616
RaMachine = ra_machine (Q ),
1625
1617
[{ClusterName , _ } | _ ] = Members = members (Q ),
0 commit comments