@@ -398,12 +398,12 @@ impl Peer {
398398 }
399399
400400 /// Returns whether this peer's buffer is full and we should drop gossip messages.
401- fn buffer_full_drop_gossip ( & self ) -> bool {
401+ fn buffer_full_drop_gossip_broadcast ( & self ) -> bool {
402402 if self . pending_outbound_buffer . len ( ) > OUTBOUND_BUFFER_LIMIT_DROP_GOSSIP
403403 || self . msgs_sent_since_pong > BUFFER_DRAIN_MSGS_PER_TICK * FORWARD_INIT_SYNC_BUFFER_LIMIT_RATIO {
404- return false
404+ return true
405405 }
406- true
406+ false
407407 }
408408}
409409
@@ -1325,7 +1325,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
13251325 !peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
13261326 continue
13271327 }
1328- if peer. buffer_full_drop_gossip ( ) {
1328+ if peer. buffer_full_drop_gossip_broadcast ( ) {
13291329 log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
13301330 continue ;
13311331 }
@@ -1349,7 +1349,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
13491349 !peer. should_forward_node_announcement ( msg. contents . node_id ) {
13501350 continue
13511351 }
1352- if peer. buffer_full_drop_gossip ( ) {
1352+ if peer. buffer_full_drop_gossip_broadcast ( ) {
13531353 log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
13541354 continue ;
13551355 }
@@ -1372,7 +1372,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
13721372 !peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
13731373 continue
13741374 }
1375- if peer. buffer_full_drop_gossip ( ) {
1375+ if peer. buffer_full_drop_gossip_broadcast ( ) {
13761376 log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
13771377 continue ;
13781378 }
0 commit comments