File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1527,7 +1527,7 @@ where
15271527 }
15281528 }
15291529
1530- fn peer_should_read ( & self , peer : & mut Peer ) -> bool {
1530+ fn should_read_from ( & self , peer : & mut Peer ) -> bool {
15311531 peer. should_read ( self . gossip_processing_backlogged . load ( Ordering :: Relaxed ) )
15321532 }
15331533
@@ -1546,7 +1546,7 @@ where
15461546 // vice versa, then we need to tell the socket driver to update their internal flag
15471547 // indicating whether or not reads are paused. Do this by forcing a write with the desired
15481548 // `continue_read` flag set, even if no outbound messages are currently queued.
1549- force_one_write |= self . peer_should_read ( peer) == peer. sent_pause_read ;
1549+ force_one_write |= self . should_read_from ( peer) == peer. sent_pause_read ;
15501550 while force_one_write || !peer. awaiting_write_event {
15511551 if peer. should_buffer_onion_message ( ) {
15521552 if let Some ( ( peer_node_id, _) ) = peer. their_node_id {
@@ -1612,7 +1612,7 @@ where
16121612 self . maybe_send_extra_ping ( peer) ;
16131613 }
16141614
1615- let should_read = self . peer_should_read ( peer) ;
1615+ let should_read = self . should_read_from ( peer) ;
16161616 let next_buff = match peer. pending_outbound_buffer . front ( ) {
16171617 None => {
16181618 if force_one_write {
You can’t perform that action at this time.
0 commit comments