@@ -902,16 +902,21 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
902
902
Ok ( x) => x,
903
903
Err ( e) => {
904
904
match e {
905
+ ( msgs:: DecodeError :: UnknownRequiredFeature , _) => {
906
+ log_gossip ! ( self . logger, "Got a channel/node announcement with an unknown required feature flag, you may want to update!" ) ;
907
+ continue ;
908
+ }
909
+ ( msgs:: DecodeError :: UnsupportedCompression , _) => {
910
+ log_gossip ! ( self . logger, "We don't support zlib-compressed message fields, sending a warning and ignoring message" ) ;
911
+ self . enqueue_message ( peer, & msgs:: WarningMessage { channel_id : [ 0 ; 32 ] , data : "Unsupported message compression: zlib" . to_owned ( ) } ) ;
912
+ continue ;
913
+ }
905
914
( _, Some ( ty) ) if is_gossip_msg ( ty) => {
906
915
log_gossip ! ( self . logger, "Got an invalid value while deserializing a gossip message" ) ;
907
916
self . enqueue_message ( peer, & msgs:: WarningMessage { channel_id : [ 0 ; 32 ] , data : "Unreadable/bogus gossip message" . to_owned ( ) } ) ;
908
917
continue ;
909
918
}
910
919
( msgs:: DecodeError :: UnknownVersion , _) => return Err ( PeerHandleError { no_connection_possible : false } ) ,
911
- ( msgs:: DecodeError :: UnknownRequiredFeature , _) => {
912
- log_gossip ! ( self . logger, "Got a channel/node announcement with an unknown required feature flag, you may want to update!" ) ;
913
- continue ;
914
- }
915
920
( msgs:: DecodeError :: InvalidValue , _) => {
916
921
log_debug ! ( self . logger, "Got an invalid value while deserializing message" ) ;
917
922
return Err ( PeerHandleError { no_connection_possible : false } ) ;
@@ -922,11 +927,6 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
922
927
}
923
928
( msgs:: DecodeError :: BadLengthDescriptor , _) => return Err ( PeerHandleError { no_connection_possible : false } ) ,
924
929
( msgs:: DecodeError :: Io ( _) , _) => return Err ( PeerHandleError { no_connection_possible : false } ) ,
925
- ( msgs:: DecodeError :: UnsupportedCompression , _) => {
926
- log_gossip ! ( self . logger, "We don't support zlib-compressed message fields, sending a warning and ignoring message" ) ;
927
- self . enqueue_message ( peer, & msgs:: WarningMessage { channel_id : [ 0 ; 32 ] , data : "Unsupported message compression: zlib" . to_owned ( ) } ) ;
928
- continue ;
929
- }
930
930
}
931
931
}
932
932
} ;
0 commit comments