Method handle_array_open

nodedb/src/data/executor/dispatch/array/open.rs:16–125

(
        &mut self,
        task: &ExecutionTask,
        array_id: &ArrayId,
        schema_msgpack: &[u8],
        schema_hash: u64,
        prefix_bits: u8,
    )

impl CoreLoop {
    pub(in crate::data::executor) fn handle_array_open(
        &mut self,
        task: &ExecutionTask,
        array_id: &ArrayId,
        schema_msgpack: &[u8],
        schema_hash: u64,
        prefix_bits: u8,
    ) -> Response {
        // Verify-or-register against the in-memory catalog. Persistence
        // into `_system.arrays` is owned by the Control-Plane DDL path
        // (`SystemCatalog::put_array`), not the Data Plane — redb is
        // Control-Plane-only.
        {
            let cat = match self.array_catalog.read() {
                Ok(g) => g,
                Err(_) => {
                    return self.response_error(
                        task,
                        ErrorCode::Internal {
                            detail: "array catalog lock poisoned".to_string(),
                        },
                    );
                }
            };
            if let Some(existing) = cat.lookup_by_name(&array_id.name) {
                if existing.schema_hash != schema_hash {
                    return self.response_error(
                        task,
                        ErrorCode::Unsupported {
                            detail: format!(
                                "array '{}' already registered with different schema hash ({:#x} != {:#x})",
                                array_id.name, existing.schema_hash, schema_hash
                            ),
                        },
                    );
                }
            } else {
                drop(cat);
                let entry = ArrayCatalogEntry {
                    array_id: array_id.clone(),
                    name: array_id.name.clone(),
                    schema_msgpack: schema_msgpack.to_vec(),
                    schema_hash,
                    created_at_ms: now_epoch_ms(),
                    prefix_bits,
                    audit_retain_ms: None,
                    minimum_audit_retain_ms: None,
                };
                let mut cat = match self.array_catalog.write() {
                    Ok(g) => g,
                    Err(_) => {
                        return self.response_error(
                            task,
                            ErrorCode::Internal {
                                detail: "array catalog lock poisoned".to_string(),
                            },
                        );
                    }