@@ -512,7 +512,7 @@ start_coordinator_cluster() ->
512
512
" initial machine version ~b " ,
513
513
[Nodes , MinVersion ]),
514
514
case ra :start_cluster (? RA_SYSTEM ,
515
- [make_system_conf (Node , Nodes , MinVersion )
515
+ [make_ra_conf (Node , Nodes , MinVersion )
516
516
|| Node <- Nodes ]) of
517
517
{ok , Started , _ } ->
518
518
rabbit_log :debug (" Started stream coordinator on ~w " , [Started ]),
@@ -1350,11 +1350,6 @@ phase_update_mnesia(StreamId, Args, #{reference := QName,
1350
1350
format_ra_event (ServerId , Evt ) ->
1351
1351
{stream_coordinator_event , ServerId , Evt }.
1352
1352
1353
- make_system_conf (Node , Nodes , MinMacVersion ) ->
1354
- RaConf = make_ra_conf (Node , Nodes , MinMacVersion ),
1355
- SacConf = make_sac_conf (MinMacVersion ),
1356
- RaConf #{sac_conf => SacConf }.
1357
-
1358
1353
make_ra_conf (Node , Nodes , MinMacVersion ) ->
1359
1354
UId = ra :new_uid (ra_lib :to_binary (? MODULE )),
1360
1355
Formatter = {? MODULE , format_ra_event , []},
@@ -1369,7 +1364,7 @@ make_ra_conf(Node, Nodes, MinMacVersion) ->
1369
1364
initial_members => Members ,
1370
1365
log_init_args => #{uid => UId },
1371
1366
tick_timeout => TickTimeout ,
1372
- machine => {module , ? MODULE , #{}},
1367
+ machine => {module , ? MODULE , #{sac_conf => make_sac_conf ( MinMacVersion ) }},
1373
1368
initial_machine_version => MinMacVersion ,
1374
1369
ra_event_formatter => Formatter }.
1375
1370
0 commit comments