Flushes pending changes to disk. # Returns Vector of metadata updates that were flushed

The mixing function, G, which mixes either a column or a diagonal.

Gets a shared reference to the database. # Returns A SharedAdsWrap instance for concurrent access

Verifies that two byte slices contain the same hash value # Arguments `tag` - A string identifier for the comparison (used in error messages) `a` - F

Returns the number of elements in the list. # Returns The number of elements currently stored in the list.

Deserializes a byte slice into a list of edge nodes # Arguments `bz` - Byte slice containing serialized edge nodes # Returns Vector of deserialized

Verifies the consistency of all active twigs in the tree This function iterates through all twig shards and checks each active twig's hash relationsh

Commits the current state to disk. This method: 1. Writes the current state to the metadata file 2. Encrypts the data if a cipher is configured 3. Up

Flushes pending changes to disk and optionally deletes old twigs # Arguments `twig_delete_start` - ID of the first twig to delete `twig_delete_end` -

Inserts extra data for a specific block height. # Arguments `height` - Block height to store data for `data` - Data to store # Thread Safety - Threa

Read data from file at `offset` to fill `bz`. If the target segment file has not been opened yet, it will be opened automatically. # Segment boundary

First phase of syncing the Merkle tree for active bits # Returns A list of node IDs that need to be processed in phase 2

Appends and flushes an entry to a file. # Arguments `entry_file` - File to append to `entry` - Entry to append `dsn_list` - List of deactivated seria

Appends a new entry to the tree # Arguments `entry_bz` - The entry to append # Returns The offset of the appended entry in the entry file, or an err

Calculates the maximum level in the Merkle tree based on the youngest twig ID. This function determines how many levels are needed in the Merkle tree

Clears this task job for reuse. Resets: - Read counts - Cache - Task ID - Sub-job count

Clears the set of touched positions

Converts an entry to a vector of bytes. This is a convenience function that allocates a new vector and serializes the entry into it. # Arguments `e

flush buf and stop writing to the current file

Gets a reference to the metadata database. # Returns Reference to the metadata database

Looks up cached bytes by key and passes them to the provided function. # Arguments `cache_key` - The key to look up `idx` - The shard index to use `

Starts processing a new block. # Arguments `height` - Block height to process `tasks_manager` - Manager for block tasks # Returns A tuple containing

Clears a bit to inactive (0) at the specified offset # Arguments `offset` - The bit position to clear (0-2047) # Panics Panics if offset is greater

Returns an iterator over the deactivated serial numbers. # Returns A `DSNIter` that yields (index, serial_number) pairs.

Fetches an entry and stores it in the cache. # Arguments `update_buffer` - Buffer containing recent updates `entry_file` - File containing persisted

Flush the remained data in `buffer` into file system # Parameters - `buffer`: the write buffer, which is used by the client to call `append`. # Ret

Gets the hash value for a specific node # Arguments `level` - Level of the node `nth` - Position of the node at that level `cache` - Cache of previou

Gets a node's hash from the twig file For nodes in middle levels, computes the hash from leaf nodes. For other nodes, reads the hash directly from st

Extract the leading 'indexing_bits' from 'elem'

Computes the hash of this entry's payload. # Returns A 32-byte hash of the entry payload.