File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -430,7 +430,7 @@ impl Association {
430430 // read from the underlying transport. We do this because the
431431 // user data is passed to the reassembly queue without
432432 // copying.
433- log:: debug!( "[{}] receiving {} bytes" , name, n) ;
433+ log:: debug!( "[{}] recving {} bytes" , name, n) ;
434434 let inbound = Bytes :: from ( buffer[ ..n] . to_vec ( ) ) ;
435435 bytes_received. fetch_add ( n, Ordering :: SeqCst ) ;
436436
@@ -468,9 +468,6 @@ impl Association {
468468 ' outer: while !done. load ( Ordering :: Relaxed ) {
469469 //log::debug!("[{}] gather_outbound begin", name);
470470 let ( packets, continue_loop) = {
471- // Yielding here fixes a deadlock that crops up when requestor and responder are
472- // using the same tokio event loop as in examples/data=channels-flow-control
473- tokio:: task:: yield_now ( ) . await ;
474471 let mut ai = association_internal. lock ( ) . await ;
475472 ai. gather_outbound ( ) . await
476473 } ;
You can’t perform that action at this time.
0 commit comments