Function apply_trunk_op

atomic-core/src/apply/file_ops.rs:519–580

Apply a TrunkOp (file-level operation).

(
    txn: &mut T,
    _change_id: NodeId,
    trunk_id: TrunkId,
    path: &str,
    trunk_op: &TrunkOp,
    stats: &mut ApplyFileOpsStats,
)

/// Apply a TrunkOp (file-level operation).
fn apply_trunk_op<T: MutTxnT>(
    txn: &mut T,
    _change_id: NodeId,
    trunk_id: TrunkId,
    path: &str,
    trunk_op: &TrunkOp,
    stats: &mut ApplyFileOpsStats,
) -> PristineResult<()> {
    match trunk_op {
        TrunkOp::Create { encoding, .. } => {
            // Use the inode the tree layer has already allocated for this
            // path during `write_recorded`'s FileAdd pre-pass.  Allocating
            // a fresh one here would create a parallel inode for the same
            // file: the tree layer would index `path → tree_inode → pos`
            // while the CRDT layer would index `crdt_inode → trunk`, and
            // a caller asking "what's the CRDT trunk for the inode the
            // tree returned for this path" would get nothing — even
            // though both rows exist.
            //
            // Falling back to `alloc_inode` only when the tree has no
            // entry preserves the original behaviour for CRDT-only
            // callers (no FileAdd hunk).
            let inode = match txn.get_inode(path)? {
                Some(i) => i,
                None => txn.alloc_inode()?,
            };

            // Create the serialized trunk record
            let serialized = SerializedTrunk {
                inode,
                state: TrunkState::Alive,
                encoding: encoding_to_u8(encoding.as_ref()),
                path: path.to_string(),
            };

            // Store in CRDT tables
            put_trunk(txn, trunk_id, &serialized)?;
            stats.trunks_created += 1;
        }

        TrunkOp::Delete { .. } => {
            // Mark trunk as deleted (don't remove - CRDT semantics)
            update_trunk_state(txn, trunk_id, TrunkState::Deleted)?;
            stats.trunks_deleted += 1;
        }

        TrunkOp::Move { new_path, .. } => {
            // Update trunk path
            update_trunk_path(txn, trunk_id, new_path)?;
            stats.trunks_moved += 1;
        }

        TrunkOp::Undelete { .. } => {
            // Restore trunk to alive state
            update_trunk_state(txn, trunk_id, TrunkState::Alive)?;
            // Count as created for stats purposes
            stats.trunks_created += 1;
        }