File tree Expand file tree Collapse file tree 2 files changed +14
-17
lines changed Expand file tree Collapse file tree 2 files changed +14
-17
lines changed Original file line number Diff line number Diff line change @@ -1125,7 +1125,7 @@ mod test {
1125
1125
} ) ] ,
1126
1126
} ) ,
1127
1127
Box :: new( SenderReport {
1128
- /// NB: Different SSRC
1128
+ // NB: Different SSRC
1129
1129
ssrc: 9999999 ,
1130
1130
ntp_time: 99999 , // Used for ordering
1131
1131
packet_count: 1231 ,
Original file line number Diff line number Diff line change @@ -1991,22 +1991,19 @@ async fn test_assoc_reset_close_both_ways() -> Result<()> {
1991
1991
let done_ch_tx0 = Arc :: clone ( & done_ch_tx) ;
1992
1992
tokio:: spawn ( async move {
1993
1993
let mut buf = vec ! [ 0u8 ; 32 ] ;
1994
- loop {
1995
- log:: debug!( "s.read_sctp begin" ) ;
1996
- match s0. read_sctp ( & mut buf) . await {
1997
- Ok ( ( 0 , PayloadProtocolIdentifier :: Unknown ) ) => {
1998
- log:: debug!( "s0.read_sctp EOF" ) ;
1999
- let _ = done_ch_tx0. send ( Some ( Error :: ErrEof ) ) . await ;
2000
- break ;
2001
- }
2002
- Ok ( _) => {
2003
- panic ! ( "must be error" ) ;
2004
- }
2005
- Err ( err) => {
2006
- log:: debug!( "s0.read_sctp err {:?}" , err) ;
2007
- let _ = done_ch_tx0. send ( Some ( err) ) . await ;
2008
- break ;
2009
- }
1994
+
1995
+ log:: debug!( "s.read_sctp begin" ) ;
1996
+ match s0. read_sctp ( & mut buf) . await {
1997
+ Ok ( ( 0 , PayloadProtocolIdentifier :: Unknown ) ) => {
1998
+ log:: debug!( "s0.read_sctp EOF" ) ;
1999
+ let _ = done_ch_tx0. send ( Some ( Error :: ErrEof ) ) . await ;
2000
+ }
2001
+ Ok ( _) => {
2002
+ panic ! ( "must be error" ) ;
2003
+ }
2004
+ Err ( err) => {
2005
+ log:: debug!( "s0.read_sctp err {:?}" , err) ;
2006
+ let _ = done_ch_tx0. send ( Some ( err) ) . await ;
2010
2007
}
2011
2008
}
2012
2009
} ) ;
You can’t perform that action at this time.
0 commit comments