Method append_durable

nodedb/src/wal/audit_segment.rs:84–99

Append AND sync atomically. This is the primary durable write path.

(&self, audit_bytes: &[u8], data_lsn: u64)

    /// Append AND sync atomically. This is the primary durable write path.
    pub fn append_durable(&self, audit_bytes: &[u8], data_lsn: u64) -> crate::Result<u64> {
        let mut wal = self.wal.lock().map_err(|_| crate::Error::Internal {
            detail: "audit WAL lock poisoned".into(),
        })?;

        let mut payload = Vec::with_capacity(8 + audit_bytes.len());
        payload.extend_from_slice(&data_lsn.to_le_bytes());
        payload.extend_from_slice(audit_bytes);

        let lsn = wal
            .append(RecordType::Put as u32, 0, 0, 0, &payload)
            .map_err(crate::Error::Wal)?;
        wal.sync().map_err(crate::Error::Wal)?;

        Ok(lsn)
    }

    /// Replay all audit WAL entries for crash recovery.
    ///