@@ -1333,8 +1333,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
1333
1333
match self . do_read_event ( peer_descriptor, data) {
1334
1334
Ok ( res) => Ok ( res) ,
1335
1335
Err ( e) => {
1336
- log_trace ! ( self . logger, "Disconnecting peer due to a protocol error (usually a duplicate connection)." ) ;
1337
- self . disconnect_event_internal ( peer_descriptor) ;
1336
+ self . disconnect_event_internal ( peer_descriptor, "of a protocol error" ) ;
1338
1337
Err ( e)
1339
1338
}
1340
1339
}
@@ -2435,7 +2434,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
2435
2434
2436
2435
/// Indicates that the given socket descriptor's connection is now closed.
2437
2436
pub fn socket_disconnected ( & self , descriptor : & Descriptor ) {
2438
- self . disconnect_event_internal ( descriptor) ;
2437
+ self . disconnect_event_internal ( descriptor, "the socket was disconnected" ) ;
2439
2438
}
2440
2439
2441
2440
fn do_disconnect ( & self , mut descriptor : Descriptor , peer : & Peer , reason : & ' static str ) {
@@ -2455,7 +2454,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
2455
2454
descriptor. disconnect_socket ( ) ;
2456
2455
}
2457
2456
2458
- fn disconnect_event_internal ( & self , descriptor : & Descriptor ) {
2457
+ fn disconnect_event_internal ( & self , descriptor : & Descriptor , reason : & ' static str ) {
2459
2458
let mut peers = self . peers . write ( ) . unwrap ( ) ;
2460
2459
let peer_option = peers. remove ( descriptor) ;
2461
2460
match peer_option {
@@ -2467,7 +2466,8 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
2467
2466
Some ( peer_lock) => {
2468
2467
let peer = peer_lock. lock ( ) . unwrap ( ) ;
2469
2468
if let Some ( ( node_id, _) ) = peer. their_node_id {
2470
- log_trace ! ( WithContext :: from( & self . logger, Some ( node_id) , None , None ) , "Handling disconnection of peer {}" , log_pubkey!( node_id) ) ;
2469
+ let logger = WithContext :: from ( & self . logger , Some ( node_id) , None , None ) ;
2470
+ log_trace ! ( logger, "Handling disconnection of peer {} because {}" , log_pubkey!( node_id) , reason) ;
2471
2471
let removed = self . node_id_to_descriptor . lock ( ) . unwrap ( ) . remove ( & node_id) ;
2472
2472
debug_assert ! ( removed. is_some( ) , "descriptor maps should be consistent" ) ;
2473
2473
if !peer. handshake_complete ( ) { return ; }
0 commit comments