Method record

nodedb/src/control/array_sync/ack_registry.rs:184–202

Record an ack from `replica_id` for `array` at `ack_hlc`. Monotonically advances the stored value — older acks are ignored. Persists the updated HLC immediately.

(&self, array: &str, replica_id: ReplicaId, ack_hlc: Hlc)

    /// Monotonically advances the stored value — older acks are ignored.
    /// Persists the updated HLC immediately.
    pub fn record(&self, array: &str, replica_id: ReplicaId, ack_hlc: Hlc) {
        {
            let mut cache = self.cache.write().unwrap_or_else(|p| p.into_inner());
            cache
                .entry(array.to_owned())
                .or_default()
                .record(replica_id, ack_hlc);
        }
        // Persist outside the write-lock to avoid holding it across I/O.
        if let Some(key) = ack_key(array, replica_id.as_u64())
            && let Err(e) = self.persist_row(&key, ack_hlc)
        {
            warn!(
                array = %array,
                error = %e,
                "ack_registry: persist failed — in-memory ack advanced but disk not updated"
            );
        }
    }

    fn persist_row(&self, key: &[u8], hlc: Hlc) -> crate::Result<()> {
        let txn = self.db.begin_write().map_err(|e| crate::Error::Storage {