@@ -172,8 +172,8 @@ fn test_aio_suspend() {
172
172
}
173
173
}
174
174
175
- assert ! ( wcb. aio_return( ) . unwrap( ) as usize == WBUF . len( ) ) ;
176
- assert ! ( rcb. aio_return( ) . unwrap( ) as usize == rlen) ;
175
+ assert_eq ! ( wcb. aio_return( ) . unwrap( ) as usize , WBUF . len( ) ) ;
176
+ assert_eq ! ( rcb. aio_return( ) . unwrap( ) as usize , rlen) ;
177
177
}
178
178
179
179
// Test a simple aio operation with no completion notification. We must poll
@@ -196,11 +196,11 @@ fn test_read() {
196
196
aiocb. read ( ) . unwrap ( ) ;
197
197
198
198
let err = poll_aio ( & mut aiocb) ;
199
- assert ! ( err == Ok ( ( ) ) ) ;
200
- assert ! ( aiocb. aio_return( ) . unwrap( ) as usize == EXPECT . len( ) ) ;
199
+ assert_eq ! ( err, Ok ( ( ) ) ) ;
200
+ assert_eq ! ( aiocb. aio_return( ) . unwrap( ) as usize , EXPECT . len( ) ) ;
201
201
}
202
202
203
- assert ! ( EXPECT == rbuf. deref( ) . deref( ) ) ;
203
+ assert_eq ! ( EXPECT , rbuf. deref( ) . deref( ) ) ;
204
204
}
205
205
206
206
/// `AioCb::read` should not modify the `AioCb` object if `libc::aio_read`
@@ -242,11 +242,11 @@ fn test_read_into_mut_slice() {
242
242
aiocb. read ( ) . unwrap ( ) ;
243
243
244
244
let err = poll_aio ( & mut aiocb) ;
245
- assert ! ( err == Ok ( ( ) ) ) ;
246
- assert ! ( aiocb. aio_return( ) . unwrap( ) as usize == EXPECT . len( ) ) ;
245
+ assert_eq ! ( err, Ok ( ( ) ) ) ;
246
+ assert_eq ! ( aiocb. aio_return( ) . unwrap( ) as usize , EXPECT . len( ) ) ;
247
247
}
248
248
249
- assert ! ( rbuf == EXPECT ) ;
249
+ assert_eq ! ( rbuf, EXPECT ) ;
250
250
}
251
251
252
252
// Tests from_ptr
@@ -272,11 +272,11 @@ fn test_read_into_pointer() {
272
272
aiocb. read ( ) . unwrap ( ) ;
273
273
274
274
let err = poll_aio ( & mut aiocb) ;
275
- assert ! ( err == Ok ( ( ) ) ) ;
276
- assert ! ( aiocb. aio_return( ) . unwrap( ) as usize == EXPECT . len( ) ) ;
275
+ assert_eq ! ( err, Ok ( ( ) ) ) ;
276
+ assert_eq ! ( aiocb. aio_return( ) . unwrap( ) as usize , EXPECT . len( ) ) ;
277
277
}
278
278
279
- assert ! ( rbuf == EXPECT ) ;
279
+ assert_eq ! ( rbuf, EXPECT ) ;
280
280
}
281
281
282
282
// Test reading into an immutable buffer. It should fail
@@ -318,13 +318,13 @@ fn test_write() {
318
318
aiocb. write ( ) . unwrap ( ) ;
319
319
320
320
let err = poll_aio ( & mut aiocb) ;
321
- assert ! ( err == Ok ( ( ) ) ) ;
322
- assert ! ( aiocb. aio_return( ) . unwrap( ) as usize == wbuf. len( ) ) ;
321
+ assert_eq ! ( err, Ok ( ( ) ) ) ;
322
+ assert_eq ! ( aiocb. aio_return( ) . unwrap( ) as usize , wbuf. len( ) ) ;
323
323
324
324
f. seek ( SeekFrom :: Start ( 0 ) ) . unwrap ( ) ;
325
325
let len = f. read_to_end ( & mut rbuf) . unwrap ( ) ;
326
- assert ! ( len == EXPECT . len( ) ) ;
327
- assert ! ( rbuf == EXPECT ) ;
326
+ assert_eq ! ( len, EXPECT . len( ) ) ;
327
+ assert_eq ! ( rbuf, EXPECT ) ;
328
328
}
329
329
330
330
// Tests `AioCb::from_boxed_slice` with `Bytes`
@@ -348,13 +348,13 @@ fn test_write_bytes() {
348
348
aiocb. write ( ) . unwrap ( ) ;
349
349
350
350
let err = poll_aio ( & mut aiocb) ;
351
- assert ! ( err == Ok ( ( ) ) ) ;
352
- assert ! ( aiocb. aio_return( ) . unwrap( ) as usize == expected_len) ;
351
+ assert_eq ! ( err, Ok ( ( ) ) ) ;
352
+ assert_eq ! ( aiocb. aio_return( ) . unwrap( ) as usize , expected_len) ;
353
353
354
354
f. seek ( SeekFrom :: Start ( 0 ) ) . unwrap ( ) ;
355
355
let len = f. read_to_end ( & mut rbuf) . unwrap ( ) ;
356
- assert ! ( len == EXPECT . len( ) ) ;
357
- assert ! ( rbuf == EXPECT ) ;
356
+ assert_eq ! ( len, EXPECT . len( ) ) ;
357
+ assert_eq ! ( rbuf, EXPECT ) ;
358
358
}
359
359
360
360
// Tests `AioCb::from_boxed_mut_slice` with `BytesMut`
@@ -406,13 +406,13 @@ fn test_write_from_pointer() {
406
406
aiocb. write ( ) . unwrap ( ) ;
407
407
408
408
let err = poll_aio ( & mut aiocb) ;
409
- assert ! ( err == Ok ( ( ) ) ) ;
410
- assert ! ( aiocb. aio_return( ) . unwrap( ) as usize == wbuf. len( ) ) ;
409
+ assert_eq ! ( err, Ok ( ( ) ) ) ;
410
+ assert_eq ! ( aiocb. aio_return( ) . unwrap( ) as usize , wbuf. len( ) ) ;
411
411
412
412
f. seek ( SeekFrom :: Start ( 0 ) ) . unwrap ( ) ;
413
413
let len = f. read_to_end ( & mut rbuf) . unwrap ( ) ;
414
- assert ! ( len == EXPECT . len( ) ) ;
415
- assert ! ( rbuf == EXPECT ) ;
414
+ assert_eq ! ( len, EXPECT . len( ) ) ;
415
+ assert_eq ! ( rbuf, EXPECT ) ;
416
416
}
417
417
418
418
/// `AioCb::write` should not modify the `AioCb` object if `libc::aio_write`
@@ -473,11 +473,11 @@ fn test_write_sigev_signal() {
473
473
thread:: sleep ( time:: Duration :: from_millis ( 10 ) ) ;
474
474
}
475
475
476
- assert ! ( aiocb. aio_return( ) . unwrap( ) as usize == WBUF . len( ) ) ;
476
+ assert_eq ! ( aiocb. aio_return( ) . unwrap( ) as usize , WBUF . len( ) ) ;
477
477
f. seek ( SeekFrom :: Start ( 0 ) ) . unwrap ( ) ;
478
478
let len = f. read_to_end ( & mut rbuf) . unwrap ( ) ;
479
- assert ! ( len == EXPECT . len( ) ) ;
480
- assert ! ( rbuf == EXPECT ) ;
479
+ assert_eq ! ( len, EXPECT . len( ) ) ;
480
+ assert_eq ! ( rbuf, EXPECT ) ;
481
481
}
482
482
483
483
// Test LioCb::listio with LIO_WAIT, so all AIO ops should be complete by the
@@ -516,15 +516,15 @@ fn test_liocb_listio_wait() {
516
516
let err = liocb. listio ( LioMode :: LIO_WAIT , SigevNotify :: SigevNone ) ;
517
517
err. expect ( "lio_listio" ) ;
518
518
519
- assert ! ( liocb. aio_return( 0 ) . unwrap( ) as usize == WBUF . len( ) ) ;
520
- assert ! ( liocb. aio_return( 1 ) . unwrap( ) as usize == rlen) ;
519
+ assert_eq ! ( liocb. aio_return( 0 ) . unwrap( ) as usize , WBUF . len( ) ) ;
520
+ assert_eq ! ( liocb. aio_return( 1 ) . unwrap( ) as usize , rlen) ;
521
521
}
522
- assert ! ( rbuf. deref( ) . deref( ) == b"3456" ) ;
522
+ assert_eq ! ( rbuf. deref( ) . deref( ) , b"3456" ) ;
523
523
524
524
f. seek ( SeekFrom :: Start ( 0 ) ) . unwrap ( ) ;
525
525
let len = f. read_to_end ( & mut rbuf2) . unwrap ( ) ;
526
- assert ! ( len == EXPECT . len( ) ) ;
527
- assert ! ( rbuf2 == EXPECT ) ;
526
+ assert_eq ! ( len, EXPECT . len( ) ) ;
527
+ assert_eq ! ( rbuf2, EXPECT ) ;
528
528
}
529
529
530
530
// Test LioCb::listio with LIO_NOWAIT and no SigEvent, so we must use some other
@@ -565,15 +565,15 @@ fn test_liocb_listio_nowait() {
565
565
566
566
poll_aio ( & mut liocb. aiocbs [ 0 ] ) . unwrap ( ) ;
567
567
poll_aio ( & mut liocb. aiocbs [ 1 ] ) . unwrap ( ) ;
568
- assert ! ( liocb. aiocbs[ 0 ] . aio_return( ) . unwrap( ) as usize == WBUF . len( ) ) ;
569
- assert ! ( liocb. aiocbs[ 1 ] . aio_return( ) . unwrap( ) as usize == rlen) ;
568
+ assert_eq ! ( liocb. aiocbs[ 0 ] . aio_return( ) . unwrap( ) as usize , WBUF . len( ) ) ;
569
+ assert_eq ! ( liocb. aiocbs[ 1 ] . aio_return( ) . unwrap( ) as usize , rlen) ;
570
570
}
571
- assert ! ( rbuf. deref( ) . deref( ) == b"3456" ) ;
571
+ assert_eq ! ( rbuf. deref( ) . deref( ) , b"3456" ) ;
572
572
573
573
f. seek ( SeekFrom :: Start ( 0 ) ) . unwrap ( ) ;
574
574
let len = f. read_to_end ( & mut rbuf2) . unwrap ( ) ;
575
- assert ! ( len == EXPECT . len( ) ) ;
576
- assert ! ( rbuf2 == EXPECT ) ;
575
+ assert_eq ! ( len, EXPECT . len( ) ) ;
576
+ assert_eq ! ( rbuf2, EXPECT ) ;
577
577
}
578
578
579
579
// Test LioCb::listio with LIO_NOWAIT and a SigEvent to indicate when all
@@ -624,15 +624,15 @@ fn test_liocb_listio_signal() {
624
624
thread:: sleep ( time:: Duration :: from_millis ( 10 ) ) ;
625
625
}
626
626
627
- assert ! ( liocb. aiocbs[ 0 ] . aio_return( ) . unwrap( ) as usize == WBUF . len( ) ) ;
628
- assert ! ( liocb. aiocbs[ 1 ] . aio_return( ) . unwrap( ) as usize == rlen) ;
627
+ assert_eq ! ( liocb. aiocbs[ 0 ] . aio_return( ) . unwrap( ) as usize , WBUF . len( ) ) ;
628
+ assert_eq ! ( liocb. aiocbs[ 1 ] . aio_return( ) . unwrap( ) as usize , rlen) ;
629
629
}
630
- assert ! ( rbuf. deref( ) . deref( ) == b"3456" ) ;
630
+ assert_eq ! ( rbuf. deref( ) . deref( ) , b"3456" ) ;
631
631
632
632
f. seek ( SeekFrom :: Start ( 0 ) ) . unwrap ( ) ;
633
633
let len = f. read_to_end ( & mut rbuf2) . unwrap ( ) ;
634
- assert ! ( len == EXPECT . len( ) ) ;
635
- assert ! ( rbuf2 == EXPECT ) ;
634
+ assert_eq ! ( len, EXPECT . len( ) ) ;
635
+ assert_eq ! ( rbuf2, EXPECT ) ;
636
636
}
637
637
638
638
// Try to use LioCb::listio to read into an immutable buffer. It should fail
0 commit comments