@@ -398,7 +398,7 @@ 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 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
404404 }
@@ -1322,7 +1322,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
13221322 !peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
13231323 continue
13241324 }
1325- if peer. buffer_full_drop_gossip ( ) {
1325+ if peer. buffer_full_drop_gossip_broadcast ( ) {
13261326 log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
13271327 continue ;
13281328 }
@@ -1346,7 +1346,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
13461346 !peer. should_forward_node_announcement ( msg. contents . node_id ) {
13471347 continue
13481348 }
1349- if peer. buffer_full_drop_gossip ( ) {
1349+ if peer. buffer_full_drop_gossip_broadcast ( ) {
13501350 log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
13511351 continue ;
13521352 }
@@ -1369,7 +1369,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
13691369 !peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
13701370 continue
13711371 }
1372- if peer. buffer_full_drop_gossip ( ) {
1372+ if peer. buffer_full_drop_gossip_broadcast ( ) {
13731373 log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
13741374 continue ;
13751375 }
0 commit comments