Function apply_file_ops_batched

atomic-core/src/apply/file_ops.rs:184–309

Apply FileOps using CRDT table handles opened once for the full pass. This is a specialized fast path for insert-only workloads such as large initial file adds. More complex edit patterns fall back to the generic `apply_file_ops`.

(
    txn: &mut WriteTxn<'_>,
    change_id: NodeId,
    file_ops: &[FileOps],
)

/// initial file adds. More complex edit patterns fall back to the generic
/// `apply_file_ops`.
pub fn apply_file_ops_batched(
    txn: &mut WriteTxn<'_>,
    change_id: NodeId,
    file_ops: &[FileOps],
) -> PristineResult<ApplyFileOpsStats> {
    if !can_batch_apply_file_ops(file_ops) {
        return apply_file_ops(txn, change_id, file_ops);
    }

    let mut stats = ApplyFileOpsStats::new();
    let mut trunk_creates = Vec::with_capacity(file_ops.len());

    for ops in file_ops {
        let trunk_create = match ops.trunk_op() {
            Some(TrunkOp::Create { encoding, .. }) => {
                let inode = match txn.get_inode(ops.path())? {
                    Some(i) => i,
                    None => txn.alloc_inode()?,
                };
                Some(SerializedTrunk {
                    inode,
                    state: TrunkState::Alive,
                    encoding: encoding_to_u8(encoding.as_ref()),
                    path: ops.path().to_string(),
                })
            }
            _ => None,
        };
        trunk_creates.push(trunk_create);
    }

    let mut trunks_table = txn.txn.open_table(TRUNKS)?;
    let mut inode_trunk_table = txn.txn.open_table(INODE_TRUNK)?;
    let mut path_trunk_table = txn.txn.open_table(PATH_TRUNK)?;
    let mut branches_table = txn.txn.open_table(BRANCHES)?;
    let mut trunk_branches_table = txn.txn.open_multimap_table(TRUNK_BRANCHES)?;
    let mut branch_after_table = txn.txn.open_table(BRANCH_AFTER)?;
    let mut leaves_table = txn.txn.open_table(LEAVES)?;
    let mut branch_leaves_table = txn.txn.open_multimap_table(BRANCH_LEAVES)?;
    let mut branch_vertex_table = txn.txn.open_table(BRANCH_VERTEX)?;
    let mut vertex_branch_table = txn.txn.open_table(VERTEX_BRANCH)?;

    let mut next_leaf_idx = 0u32;
    for (ops, trunk_create) in file_ops.iter().zip(trunk_creates.iter()) {
        // Resolve TrunkId placeholder — same logic as apply_single_file_ops.
        let raw_trunk_id = ops.trunk_id();
        let trunk_id = if raw_trunk_id.change_id().is_root() {
            TrunkId::new(change_id, raw_trunk_id.file_idx())
        } else {
            raw_trunk_id
        };
        let trunk_key = encode_trunk_id(&trunk_id);

        if let Some(serialized) = trunk_create {
            let trunk_value = encode_trunk_value(serialized);
            trunks_table.insert(&trunk_key, trunk_value.as_slice())?;
            inode_trunk_table.insert(serialized.inode.get(), &trunk_key)?;
            path_trunk_table.insert(ops.path(), &trunk_key)?;