Method handle_ack

nodedb/src/control/array_sync/inbound.rs:260–273

Record a peer ack for GC frontier tracking. Forwards the ack into the `ArrayAckRegistry` on `SharedState` so the GC task can compute the min-ack frontier for each array.

(&self, msg: &ArrayAckMsg)

    /// Forwards the ack into the `ArrayAckRegistry` on `SharedState` so the
    /// GC task can compute the min-ack frontier for each array.
    pub fn handle_ack(&self, msg: &ArrayAckMsg) -> Result<InboundOutcome, Option<ArrayRejectMsg>> {
        let ack_hlc = Hlc::from_bytes(&msg.ack_hlc_bytes);
        let replica_id = nodedb_array::sync::replica_id::ReplicaId::new(msg.replica_id);
        self.shared
            .array_ack_registry
            .record(&msg.array, replica_id, ack_hlc);
        tracing::debug!(
            array = %msg.array,
            replica_id = msg.replica_id,
            ack_hlc = ?ack_hlc,
            "array_inbound: peer ack recorded"
        );
        Ok(InboundOutcome::AckRecorded)
    }

    // ─── Catchup request ─────────────────────────────────────────────────────