@@ -512,7 +512,7 @@ start_coordinator_cluster() ->
512512 " initial machine version ~b " ,
513513 [Nodes , MinVersion ]),
514514 case ra :start_cluster (? RA_SYSTEM ,
515- [make_system_conf (Node , Nodes , MinVersion )
515+ [make_ra_conf (Node , Nodes , MinVersion )
516516 || Node <- Nodes ]) of
517517 {ok , Started , _ } ->
518518 rabbit_log :debug (" Started stream coordinator on ~w " , [Started ]),
@@ -1350,11 +1350,6 @@ phase_update_mnesia(StreamId, Args, #{reference := QName,
13501350format_ra_event (ServerId , Evt ) ->
13511351 {stream_coordinator_event , ServerId , Evt }.
13521352
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-
13581353make_ra_conf (Node , Nodes , MinMacVersion ) ->
13591354 UId = ra :new_uid (ra_lib :to_binary (? MODULE )),
13601355 Formatter = {? MODULE , format_ra_event , []},
@@ -1369,7 +1364,7 @@ make_ra_conf(Node, Nodes, MinMacVersion) ->
13691364 initial_members => Members ,
13701365 log_init_args => #{uid => UId },
13711366 tick_timeout => TickTimeout ,
1372- machine => {module , ? MODULE , #{}},
1367+ machine => {module , ? MODULE , #{sac_conf => make_sac_conf ( MinMacVersion ) }},
13731368 initial_machine_version => MinMacVersion ,
13741369 ra_event_formatter => Formatter }.
13751370
0 commit comments