Method serialize

src/models/serializer/tree_map/node.rs:17–87

(
        &self,
        dim_bufman: &BufferManager,
        data_bufmans: &BufferManagerFactory<VersionNumber>,
        cursor: u64,
    )

impl<T: SimpleSerialize> TreeMapSerialize for TreeMapNode<T> {
    fn serialize(
        &self,
        dim_bufman: &BufferManager,
        data_bufmans: &BufferManagerFactory<VersionNumber>,
        cursor: u64,
    ) -> Result<u32, BufIoError> {
        let offset_read_guard = self.offset.read();
        if let Some(offset) = *offset_read_guard {
            dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 2)?;
            for (idx, child) in self.children.items.iter().enumerate() {
                let opt_child = unsafe { child.load(Ordering::Relaxed).as_ref() };
                let Some(child) = opt_child else {
                    dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 2 + (idx as u64 * 4))?;
                    dim_bufman.update_u32_with_cursor(cursor, u32::MAX)?;
                    continue;
                };
                let child_offset = child.serialize(dim_bufman, data_bufmans, cursor)?;
                dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 2 + (idx as u64 * 4))?;
                dim_bufman.update_u32_with_cursor(cursor, child_offset)?;
            }

            if self.dirty.swap(false, Ordering::Relaxed) {
                let quotient_offset = self.quotients.serialize(dim_bufman, data_bufmans, cursor)?;
                dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 34)?;
                dim_bufman.update_u32_with_cursor(cursor, quotient_offset)?;
            }

            return Ok(offset.0);
        }
        drop(offset_read_guard);
        let mut offset_write_guard = self.offset.write();
        if let Some(offset) = *offset_write_guard {
            dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 2)?;
            for (idx, child) in self.children.items.iter().enumerate() {
                let opt_child = unsafe { child.load(Ordering::Relaxed).as_ref() };
                let Some(child) = opt_child else {
                    dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 2 + (idx as u64 * 4))?;
                    dim_bufman.update_u32_with_cursor(cursor, u32::MAX)?;
                    continue;
                };
                let child_offset = child.serialize(dim_bufman, data_bufmans, cursor)?;
                dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 2 + (idx as u64 * 4))?;
                dim_bufman.update_u32_with_cursor(cursor, child_offset)?;
            }

            if self.dirty.swap(false, Ordering::Relaxed) {
                let quotient_offset = self.quotients.serialize(dim_bufman, data_bufmans, cursor)?;
                dim_bufman.seek_with_cursor(cursor, offset.0 as u64 + 34)?;
                dim_bufman.update_u32_with_cursor(cursor, quotient_offset)?;
            }

            return Ok(offset.0);
        }
        let mut buf = Vec::with_capacity(38);
        buf.extend(self.node_idx.to_le_bytes());
        for child in &self.children.items {
            let opt_child = unsafe { child.load(Ordering::Relaxed).as_ref() };
            let Some(child) = opt_child else {