@@ -1347,6 +1347,7 @@ pub fn test_tcp_recv_multi_bundle<S: squeue::EntryMarker, C: cqueue::EntryMarker
1347
1347
1348
1348
let mut cqe: cqueue:: Entry = ring. completion ( ) . next ( ) . expect ( "cqueue is empty" ) . into ( ) ;
1349
1349
1350
+ assert ! ( cqe. result( ) >= 0 ) ;
1350
1351
assert_eq ! ( cqe. user_data( ) , 0x31 ) ;
1351
1352
assert ! ( cqueue:: buffer_select( cqe. flags( ) ) . is_some( ) ) ;
1352
1353
let mut remaining = cqe. result ( ) as usize ;
@@ -1375,6 +1376,7 @@ pub fn test_tcp_recv_multi_bundle<S: squeue::EntryMarker, C: cqueue::EntryMarker
1375
1376
1376
1377
cqe = ring. completion ( ) . next ( ) . expect ( "cqueue is empty" ) . into ( ) ;
1377
1378
1379
+ assert ! ( cqe. result( ) >= 0 ) ;
1378
1380
assert_eq ! ( cqe. user_data( ) , 0x31 ) ;
1379
1381
assert ! ( cqueue:: buffer_select( cqe. flags( ) ) . is_some( ) ) ;
1380
1382
remaining = cqe. result ( ) as usize ;
@@ -1397,9 +1399,7 @@ pub fn test_tcp_recv_multi_bundle<S: squeue::EntryMarker, C: cqueue::EntryMarker
1397
1399
cqe = ring. completion ( ) . next ( ) . expect ( "cqueue is empty" ) . into ( ) ;
1398
1400
assert_eq ! ( cqe. user_data( ) , 0x31 ) ;
1399
1401
assert ! ( !cqueue:: more( cqe. flags( ) ) ) ;
1400
- if used_bufs < 5 {
1401
- assert_eq ! ( cqe. result( ) , 0 ) ; // Buffer space is avaialble
1402
- } else {
1402
+ if used_bufs >= 5 || cqe. result ( ) != 0 {
1403
1403
assert_eq ! ( cqe. result( ) , -105 ) ; // No buffer space available
1404
1404
}
1405
1405
}
0 commit comments