@@ -1602,15 +1602,21 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
1602
1602
}
1603
1603
( msgs:: DecodeError :: UnsupportedCompression , _) => {
1604
1604
log_gossip ! ( logger, "We don't support zlib-compressed message fields, sending a warning and ignoring message" ) ;
1605
- self . enqueue_message ( peer, & msgs:: WarningMessage { channel_id : ChannelId :: new_zero ( ) , data : "Unsupported message compression: zlib" . to_owned ( ) } ) ;
1605
+ let channel_id = ChannelId :: new_zero ( ) ;
1606
+ let data = "Unsupported message compression: zlib" . to_owned ( ) ;
1607
+ let msg = msgs:: WarningMessage { channel_id, data } ;
1608
+ self . enqueue_message ( peer, & msg) ;
1606
1609
continue ;
1607
1610
}
1608
1611
( _, Some ( ty) ) if is_gossip_msg ( ty) => {
1609
1612
log_gossip ! ( logger, "Got an invalid value while deserializing a gossip message" ) ;
1610
- self . enqueue_message ( peer, & msgs:: WarningMessage {
1611
- channel_id : ChannelId :: new_zero ( ) ,
1612
- data : format ! ( "Unreadable/bogus gossip message of type {}" , ty) ,
1613
- } ) ;
1613
+ let channel_id = ChannelId :: new_zero ( ) ;
1614
+ let data = format ! ( "Unreadable/bogus gossip message of type {}" , ty) ;
1615
+ let msg = msgs:: WarningMessage {
1616
+ channel_id,
1617
+ data,
1618
+ } ;
1619
+ self . enqueue_message ( peer, & msg) ;
1614
1620
continue ;
1615
1621
}
1616
1622
( msgs:: DecodeError :: UnknownRequiredFeature , _) => {
0 commit comments