@@ -14,8 +14,7 @@ use lightning::chain::chainmonitor::{ChainMonitor, Persist};
14
14
use lightning:: chain:: keysinterface:: { Sign , KeysInterface } ;
15
15
use lightning:: ln:: channelmanager:: ChannelManager ;
16
16
use lightning:: ln:: msgs:: { ChannelMessageHandler , RoutingMessageHandler } ;
17
- use lightning:: ln:: peer_handler:: { PeerManager , SocketDescriptor } ;
18
- use lightning:: ln:: peer_handler:: CustomMessageHandler ;
17
+ use lightning:: ln:: peer_handler:: { CustomMessageHandler , PeerManager , SocketDescriptor } ;
19
18
use lightning:: routing:: network_graph:: NetGraphMsgHandler ;
20
19
use lightning:: util:: events:: { Event , EventHandler , EventsProvider } ;
21
20
use lightning:: util:: logger:: Logger ;
@@ -236,8 +235,7 @@ impl BackgroundProcessor {
236
235
// timer, we should have disconnected all sockets by now (and they're probably
237
236
// dead anyway), so disconnect them by calling `timer_tick_occurred()` twice.
238
237
log_trace ! ( logger, "Awoke after more than double our ping timer, disconnecting peers." ) ;
239
- peer_manager. timer_tick_occurred ( ) ;
240
- peer_manager. timer_tick_occurred ( ) ;
238
+ peer_manager. disconnect_all_peers ( ) ;
241
239
last_ping_call = Instant :: now ( ) ;
242
240
} else if last_ping_call. elapsed ( ) . as_secs ( ) > PING_TIMER {
243
241
log_trace ! ( logger, "Calling PeerManager's timer_tick_occurred" ) ;
0 commit comments