Lines Matching refs:as_mut
175 self.as_mut().in_progress = true;
258 /// aiocb.as_mut().submit().unwrap();
259 /// let cs = aiocb.as_mut().cancel().unwrap();
261 /// while (aiocb.as_mut().error() == Err(Errno::EINPROGRESS)) {
266 /// let _ = aiocb.as_mut().aio_return();
299 /// aiocb.as_mut().submit().unwrap();
300 /// while (aiocb.as_mut().error() == Err(Errno::EINPROGRESS)) {
303 /// assert_eq!(aiocb.as_mut().aio_return().unwrap(), WBUF.len());
332 /// assert!(!aiof.as_mut().in_progress());
333 /// aiof.as_mut().submit().expect("aio_fsync failed early");
334 /// assert!(aiof.as_mut().in_progress());
335 /// while (aiof.as_mut().error() == Err(Errno::EINPROGRESS)) {
338 /// aiof.as_mut().aio_return().expect("aio_fsync failed late");
339 /// assert!(!aiof.as_mut().in_progress());
398 let p: *mut libc::aiocb = &mut self.as_mut().aiocb().aiocb.0;
424 /// aiof.as_mut().submit().expect("aio_fsync failed early");
425 /// while (aiof.as_mut().error() == Err(Errno::EINPROGRESS)) {
428 /// aiof.as_mut().aio_return().expect("aio_fsync failed late");
485 let aiocb = &mut self.as_mut().aiocb().aiocb.0;
535 /// aior.as_mut().submit().unwrap();
536 /// while (aior.as_mut().error() == Err(Errno::EINPROGRESS)) {
539 /// assert_eq!(aior.as_mut().aio_return().unwrap(), LEN);
607 fn as_mut(&mut self) -> &mut libc::aiocb {
654 /// aior.as_mut().submit().unwrap();
655 /// while (aior.as_mut().error() == Err(Errno::EINPROGRESS)) {
658 /// assert_eq!(aior.as_mut().aio_return().unwrap(), expected_len);
730 fn as_mut(&mut self) -> &mut libc::aiocb {
769 /// aiow.as_mut().submit().unwrap();
770 /// while (aiow.as_mut().error() == Err(Errno::EINPROGRESS)) {
773 /// assert_eq!(aiow.as_mut().aio_return().unwrap(), WBUF.len());
843 fn as_mut(&mut self) -> &mut libc::aiocb {
886 /// aiow.as_mut().submit().unwrap();
887 /// while (aiow.as_mut().error() == Err(Errno::EINPROGRESS)) {
890 /// assert_eq!(aiow.as_mut().aio_return().unwrap(), len);
963 fn as_mut(&mut self) -> &mut libc::aiocb {
998 /// aiocb.as_mut().submit().unwrap();
1001 /// while (aiocb.as_mut().error() == Err(Errno::EINPROGRESS)) {
1006 /// let _ = aiocb.as_mut().aio_return();
1043 /// aiocb.as_mut().submit().unwrap();
1045 /// assert_eq!(aiocb.as_mut().aio_return().unwrap() as usize, WBUF.len());
1090 /// lio_listio(LioMode::LIO_WAIT, &mut[aiow.as_mut()], SigevNotify::SigevNone)
1093 /// assert_eq!(aiow.as_mut().aio_return().unwrap(), WBUF.len());
1117 /// lio_listio(LioMode::LIO_NOWAIT, &mut[aiow.as_mut()], SigevNotify::SigevNone)
1120 /// while (aiow.as_mut().error() == Err(Errno::EINPROGRESS)) {
1123 /// assert_eq!(aiow.as_mut().aio_return().unwrap(), WBUF.len());
1167 /// lio_listio(LioMode::LIO_NOWAIT, &mut[aiow.as_mut()], sev).unwrap();
1173 /// assert_eq!(aiow.as_mut().aio_return().unwrap(), WBUF.len());