Sets the first twig ID and entry file size at a specific height. # Arguments `shard_id` - ID of the shard `height` - Block height `twig_id` - First t

Sets the last pruned twig information for a shard. # Arguments `shard_id` - ID of the shard `twig_id` - ID of the last pruned twig `ef_prune_to` - En

Sets the oldest active file position for a shard. # Arguments `shard_id` - ID of the shard `pos` - New oldest active file position # State Changes -

Sets the oldest active serial number for a shard. # Arguments `shard_id` - ID of the shard `id` - New oldest active serial number # State Changes -

Returns the size of the virtual large file, including the non-flushed bytes

Starts the io_uring worker thread. Consumes self and spawns a dedicated thread for io_uring operations. # Arguments `entry_files` - Vec of EntryFiles

Creates a temporary clone of the writer The clone shares the same twig file but has an empty write buffer. # Returns A new TwigFileWriter instance

Truncates the twig file to the specified size # Arguments `size` - New size in bytes # Panics If the truncate operation fails

Returns a reference to the value bytes of this entry.

Verify and return pairs of (serial_number, leaf_hash) in canonical order

Writes a key-value pair to the database. # Arguments `ebw` - Entry buffer writer guard `key_hash` - Hash of the key to write `key` - Key to write `va

Section 5.1.2 of the BLAKE3 spec explains this algorithm in more detail.

Adds a sub-job and checks if it needs to read from SSD. # Arguments `j` - Reference to the parent job `sj` - Reference to the sub-job # Returns `tru

Allocates a buffer from the pool. # Returns A tuple containing: - A mutable reference to the allocated buffer - The buffer ID

Allocates a new entry cache. # Returns A new entry cache instance

Returns the underlying data as a byte slice

Returns all buffers as iovecs for io_uring registration

Returns the raw 64-bit position value

Builds job channels for task and warmup jobs. # Returns A tuple containing: - Arc reference to self - Receiver for task jobs - Vector of receivers fo

Helper to compute node hash with a null-right policy for arbitrary n

Verifies the consistency of a twig's active bits Merkle tree This function checks that: 1. Level 1 nodes correctly hash their active bits 2. Level 2

Internal helper for checking upper tree node consistency For each node in a shard, verifies that its hash matches its children's hashes. Handles both

Compares active entry information with a record. # Arguments `rec` - Optional operation record for verification # Verification - Entry existence - V

Public wrapper for _compare_dig_entry.

Public wrapper for _compare_put_entry.

Computes the level-11 right-subtree top hash (active_bits_mtl3) from a right path.

Receives an item from the producer. # Returns The received item # Panics If the channel is disconnected

create a new entry with 'key' and 'value'

Creates a null Merkle tree for a twig This tree represents an empty twig where all entries are null. The tree is structured with: - Levels 0: 2048 le

Creates an array of null node hashes for levels above the twig # Arguments `null_twig` - A null twig instance to use as the base for computing higher

Creates a null twig instance with all fields initialized to represent empty state # Arguments `null_mt_for_twig` - The root hash of a null Merkle tre

remove the entry 'old'

Returns the number of deactivated serial numbers in this entry.

flush the meta info to DB when ending a block

Computes the hash for a key, excluding null and sentry entries.

Returns the expected existence state for a logical key number. Semantics: - Stable range [0, entry_count_wo_del): always returns Some(true), since th

Partially fill a preallocated key buffer deterministically based on `n`. Returns the filled slice of the buffer that represents the key bytes.

Fill a preallocated value buffer with all bytes of `v` repeated, length derived from `n`. Returns the slice of the buffer that represents the value b

Main flush loop that coordinates operations across all shards. This method implements the core flushing logic: 1. Block Height Management: - Incremen

Process all pending fd registrations (must be called after submission queue is released)