@@ -114,17 +114,17 @@ wait_for_follower_node(Parent, Host, Name, Node, Paths, Args,
114
114
case (catch mk_cmd (Host , Name , Paths , Args , Waiter , Prog )) of
115
115
{ok , Cmd } ->
116
116
? DEBUG (" command generated: ~n~s " , [Cmd ]),
117
- case (catch ssh_follower_start (Host , Cmd )) of
117
+ case (catch ssh_follower_start (Host , Cmd )) of
118
118
{ok , Conn , _Chan } ->
119
119
? DEBUG (" ssh channel created" , []),
120
120
receive
121
- {FollowerPid , follower_started } ->
122
- ? DEBUG (" follower started: ~p " , [FollowerPid ]),
121
+ {FollowerPid , follower_started } ->
122
+ ? DEBUG (" follower started: ~p " , [FollowerPid ]),
123
123
unregister (Waiter ),
124
- follower_started (Parent , LinkTo , FollowerPid , Conn ,
125
- DebugLevel )
124
+ follower_started (Parent , LinkTo , FollowerPid , Conn ,
125
+ DebugLevel )
126
126
after 32000 ->
127
- ? INFO (" follower node failed to report in on time" ,
127
+ ? INFO (" follower node failed to report in on time" ,
128
128
[]),
129
129
% % If it seems that the node was partially started,
130
130
% % try to kill it.
@@ -200,8 +200,8 @@ follower_started(ReplyTo, Master, Follower, Conn, Level)
200
200
when is_pid (Master ) andalso is_pid (Follower ) ->
201
201
process_flag (trap_exit , true ),
202
202
SName = lists :flatten (
203
- io_lib :format (" HDLT FOLLOWER CTRL[~p ,~p ]" ,
204
- [self (), node (Follower )])),
203
+ io_lib :format (" HDLT FOLLOWER CTRL[~p ,~p ]" ,
204
+ [self (), node (Follower )])),
205
205
? SET_NAME (SName ),
206
206
? SET_LEVEL (Level ),
207
207
? LOG (" initiating" , []),
@@ -219,18 +219,18 @@ follower_running(Master, MasterRef, Follower, FollowerRef, Conn) ->
219
219
receive
220
220
{'DOWN' , MasterRef , process , _Object , _Info } ->
221
221
? LOG (" received DOWN from master" , []),
222
- erlang :demonitor (FollowerRef , [flush ]),
223
- Follower ! {nodedown , node ()},
222
+ erlang :demonitor (FollowerRef , [flush ]),
223
+ Follower ! {nodedown , node ()},
224
224
ssh :close (Conn );
225
225
226
- {'DOWN' , FollowerRef , process , Object , _Info } ->
227
- ? LOG (" received DOWN from follower (~p )" , [Object ]),
226
+ {'DOWN' , FollowerRef , process , Object , _Info } ->
227
+ ? LOG (" received DOWN from follower (~p )" , [Object ]),
228
228
erlang :demonitor (MasterRef , [flush ]),
229
229
ssh :close (Conn );
230
230
231
231
Other ->
232
232
? DEBUG (" received unknown: ~n~p " , [Other ]),
233
- follower_running (Master , MasterRef , Follower , FollowerRef , Conn )
233
+ follower_running (Master , MasterRef , Follower , FollowerRef , Conn )
234
234
235
235
end .
236
236
@@ -255,7 +255,7 @@ mk_cmd(Host, Name, Paths, Args, Waiter, Prog) ->
255
255
" -detached -nopinput " ,
256
256
Args , " " ,
257
257
" -sname " , Name , " @" , Host ,
258
- " -s " , ? MODULE , " follower_node_start " , node (),
258
+ " -s " , ? MODULE , " follower_node_start " , node (),
259
259
" " , Waiter ,
260
260
" " , PaPaths ]))}.
261
261
@@ -267,12 +267,12 @@ follower_node_start([Master, Waiter]) ->
267
267
spawn (? MODULE , wait_for_master_to_die , [Master , Waiter , silence ]);
268
268
follower_node_start ([Master , Waiter , Level ]) ->
269
269
spawn (? MODULE , wait_for_master_to_die , [Master , Waiter , Level ]).
270
-
270
+
271
271
272
272
wait_for_master_to_die (Master , Waiter , Level ) ->
273
273
process_flag (trap_exit , true ),
274
274
SName = lists :flatten (
275
- io_lib :format (" HDLT-FOLLOWER MASTER MONITOR[~p ,~p ,~p ]" ,
275
+ io_lib :format (" HDLT-FOLLOWER MASTER MONITOR[~p ,~p ,~p ]" ,
276
276
[self (), node (), Master ])),
277
277
? SET_NAME (SName ),
278
278
? SET_LEVEL (Level ),
0 commit comments