File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -4702,8 +4702,8 @@ mod tests {
4702
4702
fd_a. hang_writes . store ( true , Ordering :: Relaxed ) ;
4703
4703
4704
4704
// Now push an arbitrarily large number of messages and check that only
4705
- // `OUTBOUND_BUFFER_LIMIT_DROP_GOSSIP` messages end up in the queue.
4706
- for i in 0 ..OUTBOUND_BUFFER_SIZE_LIMIT_DROP_GOSSIP / encoded_size {
4705
+ // `OUTBOUND_BUFFER_SIZE_LIMIT_DROP_GOSSIP` message bytes end up in the queue.
4706
+ for _ in 0 ..OUTBOUND_BUFFER_SIZE_LIMIT_DROP_GOSSIP / encoded_size {
4707
4707
cfgs[ 0 ] . routing_handler . pending_events . lock ( ) . unwrap ( ) . push ( msg_ev. clone ( ) ) ;
4708
4708
peers[ 0 ] . process_events ( ) ;
4709
4709
}
@@ -4733,7 +4733,8 @@ mod tests {
4733
4733
4734
4734
// Finally, deliver all the messages and make sure we got the right count. Note that there
4735
4735
// was an extra message that had already moved from the broadcast queue to the encrypted
4736
- // message queue so we actually receive `OUTBOUND_BUFFER_LIMIT_DROP_GOSSIP + 2` messages.
4736
+ // message queue so we actually receive `OUTBOUND_BUFFER_SIZE_LIMIT_DROP_GOSSIP + 2`
4737
+ // message bytes.
4737
4738
fd_a. hang_writes . store ( false , Ordering :: Relaxed ) ;
4738
4739
cfgs[ 1 ] . routing_handler . chan_anns_recvd . store ( 0 , Ordering :: Relaxed ) ;
4739
4740
peers[ 0 ] . write_buffer_space_avail ( & mut fd_a) . unwrap ( ) ;
You can’t perform that action at this time.
0 commit comments