@@ -556,12 +556,28 @@ deploy_nodes(NodeConfig, Hosts) ->
556
556
orddict :from_list (
557
557
orddict :to_list (rt_config :get (rt_versions , orddict :new ())) ++ VersionMap )),
558
558
559
+ rt :pmap (fun ({Node , _ }) ->
560
+ {ok ,
561
+ {_ , _ , _ , _ , _ , [IP0 |_ ]}} = inet :gethostbyname (
562
+ rtssh :node_to_host (Node )),
563
+ IP = inet :ntoa (IP0 ),
564
+ Config = [{" listener.protobuf.internal" ,
565
+ IP ++ " :10017" },
566
+ {" listener.http.internal" ,
567
+ IP ++ " :10018" }],
568
+ rtssh :set_conf (Node , Config )
569
+ end , lists :zip (Nodes , Configs )),
570
+ timer :sleep (500 ),
571
+
559
572
rt :pmap (fun ({_ , default }) ->
560
- ok ;
573
+ lager :info (" Default configuration detected!" ),
574
+ ok ;
561
575
({Node , {cuttlefish , Config }}) ->
562
- rtssh :set_conf (Node , Config );
576
+ lager :info (" Cuttlefish configuration detected!" ),
577
+ rtssh :set_conf (Node , Config );
563
578
({Node , Config }) ->
564
- rtssh :update_app_config (Node , Config )
579
+ lager :info (" Legacy configuration detected!" ),
580
+ rtssh :update_app_config (Node , Config )
565
581
end ,
566
582
lists :zip (Nodes , Configs )),
567
583
timer :sleep (500 ),
0 commit comments