pub fn wait_for_x(&mut self, amount: u64) -> Result<i32, UringError> {
        let ret: i32;
        unsafe {
            asm!("syscall",
                in("rax") 426, // SYS_IO_URING_ENTER
                in("rdi") self.ring_fd, // io_uring fd
                in("rsi") 0, // to_submit
                in("rdx") amount, // min_complete
                in("r10") 1u32 << 0, // flags, 1u32 << 0 == IORING_ENTER_GETEVENTS
                in("r8") 0, // sigset_t
                out("rcx") _,
                out("r11") _,
                lateout("rax") ret,
            );
        }

        checkerr!(ret.is_negative(), UringError::SubmitToSqResult(ret));

        Ok(ret)
    }
// Wait for all operations to complete
Wait for all operations to complete
Wait for all operations to complete
pub fn wait_for_x(&mut self, amount: u64) -> Result<i32, UringError> {
        let ret: i32;
        unsafe {
            asm!("syscall",
                in("rax") 426, // SYS_IO_URING_ENTER
                in("rdi") self.ring_fd, // io_uring fd
                in("rsi") 0, // to_submit
                in("rdx") amount, // min_complete
                in("r10") 1u32 << 0, // flags, 1u32 << 0 == IORING_ENTER_GETEVENTS
                in("r8") 0, // sigset_t
                out("rcx") _,
                out("r11") _,
                lateout("rax") ret,
            );
        }
        checkerr!(ret.is_negative(), UringError::SubmitToSqResult(ret));
        Ok(ret)
    }
pub fn wait_for_x ( & mut self , amount : u64 ) -> Result < i32 , UringError > { let ret : i32 ; unsafe { asm ! ( " " in ( " " ) 426 // SYS_IO_URING_ENTER in ( " " ) self ring_fd // io_uring fd in ( " " ) 0 // to_submit in ( " " ) amount // min_complete in ( " " ) 1u32 0 // flags, 1u32 << 0 == IORING_ENTER_GETEVENTS in ( " " ) 0 // sigset_t out ( " " ) out ( " " ) lateout ( " " ) ret ) ; } checkerr ! ( ret is_negative ( ) UringError SubmitToSqResult ( ret ) ) ; Ok ( ret ) }
Wait for all operations to complete
Wait for all operations to complete
&mut self
amount
u64