@@ -755,10 +755,13 @@ impl<Descriptor: SocketDescriptor, CM: Deref> PeerManager<Descriptor, CM> where
755
755
756
756
// Unknown messages:
757
757
wire:: Message :: Unknown ( msg_type) if msg_type. is_even ( ) => {
758
+ log_debug ! ( self , "Received unknown even message of type {}, disconnecting peer!" , msg_type) ;
758
759
// Fail the channel if message is an even, unknown type as per BOLT #1.
759
760
return Err ( PeerHandleError { no_connection_possible : true } ) ;
760
761
} ,
761
- wire:: Message :: Unknown ( _) => { } ,
762
+ wire:: Message :: Unknown ( msg_type) => {
763
+ log_trace ! ( self , "Received unknown odd message of type {}, ignoring" , msg_type) ;
764
+ } ,
762
765
}
763
766
}
764
767
}
@@ -1086,10 +1089,15 @@ impl<Descriptor: SocketDescriptor, CM: Deref> PeerManager<Descriptor, CM> where
1086
1089
descriptors_needing_disconnect. push ( descriptor. clone ( ) ) ;
1087
1090
match peer. their_node_id {
1088
1091
Some ( node_id) => {
1092
+ log_trace ! ( self , "Disconnecting peer with id {} due to ping timeout" , node_id) ;
1089
1093
node_id_to_descriptor. remove ( & node_id) ;
1090
- self . message_handler . chan_handler . peer_disconnected ( & node_id, true ) ;
1094
+ self . message_handler . chan_handler . peer_disconnected ( & node_id, false ) ;
1091
1095
}
1092
- None => { }
1096
+ None => {
1097
+ // This can't actually happen as we should have hit
1098
+ // is_ready_for_encryption() previously on this same peer.
1099
+ unreachable ! ( ) ;
1100
+ } ,
1093
1101
}
1094
1102
return false ;
1095
1103
}
0 commit comments