@@ -398,7 +398,7 @@ impl Peer {
398
398
}
399
399
400
400
/// 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 {
402
402
self . pending_outbound_buffer . len ( ) > OUTBOUND_BUFFER_LIMIT_DROP_GOSSIP ||
403
403
self . msgs_sent_since_pong > BUFFER_DRAIN_MSGS_PER_TICK * FORWARD_INIT_SYNC_BUFFER_LIMIT_RATIO
404
404
}
@@ -1322,7 +1322,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
1322
1322
!peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
1323
1323
continue
1324
1324
}
1325
- if peer. buffer_full_drop_gossip ( ) {
1325
+ if peer. buffer_full_drop_gossip_broadcast ( ) {
1326
1326
log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
1327
1327
continue ;
1328
1328
}
@@ -1346,7 +1346,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
1346
1346
!peer. should_forward_node_announcement ( msg. contents . node_id ) {
1347
1347
continue
1348
1348
}
1349
- if peer. buffer_full_drop_gossip ( ) {
1349
+ if peer. buffer_full_drop_gossip_broadcast ( ) {
1350
1350
log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
1351
1351
continue ;
1352
1352
}
@@ -1369,7 +1369,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref, CMH: Deref> P
1369
1369
!peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
1370
1370
continue
1371
1371
}
1372
- if peer. buffer_full_drop_gossip ( ) {
1372
+ if peer. buffer_full_drop_gossip_broadcast ( ) {
1373
1373
log_gossip ! ( self . logger, "Skipping broadcast message to {:?} as its outbound buffer is full" , peer. their_node_id) ;
1374
1374
continue ;
1375
1375
}
0 commit comments