Method submit_and_wait_fsync

nodedb-wal/src/uring_writer.rs:268–293

Submit an fsync SQE and wait for the CQE.

(&mut self)

    /// Submit an fsync SQE and wait for the CQE.
    fn submit_and_wait_fsync(&mut self) -> Result<()> {
        let fd = types::Fd(self.file.as_raw_fd());
        let fsync_op = opcode::Fsync::new(fd).build().user_data(0x02);

        unsafe {
            self.ring
                .submission()
                .push(&fsync_op)
                .map_err(|_| WalError::Io(std::io::Error::other("io_uring SQ full")))?;
        }

        self.ring.submit_and_wait(1).map_err(WalError::Io)?;

        let cqe =
            self.ring.completion().next().ok_or_else(|| {
                WalError::Io(std::io::Error::other("io_uring: no CQE after fsync"))
            })?;

        if cqe.result() < 0 {
            return Err(WalError::Io(std::io::Error::from_raw_os_error(
                -cqe.result(),
            )));
        }

        Ok(())
    }

    /// Seal the WAL.
    pub fn seal(&mut self) -> Result<()> {