@@ -231,6 +231,7 @@ handle_continue(#{name := Name0,
231231 ? DEBUG_ (Name , " replica listening on port '~b ' using transport ~s " ,
232232 [Port , Transport ]),
233233 Acceptor = spawn_link (fun () -> accept (Name , Transport , LSock , Self ) end ),
234+ ? DEBUG_ (Name , " starting replica reader on node '~w '" , [Node ]),
234235
235236 ReplicaReaderConf = #{hosts => IpsHosts ,
236237 port => Port ,
@@ -244,6 +245,7 @@ handle_continue(#{name := Name0,
244245 case osiris_replica_reader :start (Node , ReplicaReaderConf ) of
245246 {ok , RRPid } ->
246247 true = link (RRPid ),
248+ ? DEBUG_ (Name , " started replica reader on node '~w '" , [Node ]),
247249 GcInterval0 = application :get_env (osiris ,
248250 replica_forced_gc_default_interval ,
249251 4999 ),
@@ -280,7 +282,7 @@ handle_continue(#{name := Name0,
280282 log = Log ,
281283 parse_state = undefined }};
282284 {error , Reason } ->
283- ? WARN_ (Name , " failed to start replica reader. Reason ~0p " , [Reason ]),
285+ ? WARN_ (Name , " failed to start replica reader. Reason ~0p " , [Reason ]),
284286 {stop , {shutdown , Reason }, undefined }
285287 end
286288 end .
0 commit comments