@@ -577,7 +577,6 @@ impl Node {
577
577
} )
578
578
} ;
579
579
580
- let background_stop_logger = Arc :: clone ( & self . logger ) ;
581
580
let handle = runtime. spawn ( async move {
582
581
process_events_async (
583
582
background_persister,
@@ -598,7 +597,6 @@ impl Node {
598
597
log_error ! ( background_error_logger, "Failed to process events: {}" , e) ;
599
598
panic ! ( "Failed to process events" ) ;
600
599
} ) ;
601
- log_debug ! ( background_stop_logger, "Events processing stopped." , ) ;
602
600
} ) ;
603
601
debug_assert ! ( self . background_processor_task. lock( ) . unwrap( ) . is_none( ) ) ;
604
602
* self . background_processor_task . lock ( ) . unwrap ( ) = Some ( handle) ;
@@ -644,7 +642,7 @@ impl Node {
644
642
645
643
// Stop the runtime.
646
644
match self . stop_sender . send ( ( ) ) {
647
- Ok ( _) => ( ) ,
645
+ Ok ( _) => log_trace ! ( self . logger , "Sent shutdown signal to background tasks." ) ,
648
646
Err ( e) => {
649
647
log_error ! (
650
648
self . logger,
@@ -657,9 +655,11 @@ impl Node {
657
655
658
656
// Disconnect all peers.
659
657
self . peer_manager . disconnect_all_peers ( ) ;
658
+ log_debug ! ( self . logger, "Disconnected all network peers." ) ;
660
659
661
660
// Stop any runtime-dependant chain sources.
662
661
self . chain_source . stop ( ) ;
662
+ log_debug ! ( self . logger, "Stopped chain sources." ) ;
663
663
664
664
// Wait until background processing stopped, at least until a timeout is reached.
665
665
if let Some ( background_processor_task) =
@@ -678,7 +678,7 @@ impl Node {
678
678
679
679
match timeout_res {
680
680
Ok ( stop_res) => match stop_res {
681
- Ok ( ( ) ) => { } ,
681
+ Ok ( ( ) ) => log_debug ! ( self . logger , "Stopped background processing of events." ) ,
682
682
Err ( e) => {
683
683
abort_handle. abort ( ) ;
684
684
log_error ! (
0 commit comments