Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/LayerZero-Labs/qmdb
/ functions
Functions
1,374 in github.com/LayerZero-Labs/qmdb
⨍
Functions
1,374
◇
Types & classes
185
↓ 3 callers
Method
end_block
(&self, height: i64)
crates/qmdb/src/tasks/bptaskhub.rs:49
↓ 3 callers
Method
eq
(&self, other: &Self)
crates/qmdb-common/src/utils/changeset.rs:206
↓ 3 callers
Function
extend_with_align8
(buf: &mut Vec<u8>)
crates/qmdb-common/src/utils/mod.rs:79
↓ 3 callers
Function
fill_gap_once
( rohpfile: &RoHPFile, segment_size: u64, cursor: u64, target_pos: u64,
crates/hpfile/src/watcher.rs:266
↓ 3 callers
Method
flush
Flushes the write buffer to disk
crates/qmdb/src/merkletree/twigfile.rs:389
↓ 3 callers
Method
gen_cset
(&mut self)
bench/src/speed/test_gen.rs:326
↓ 3 callers
Function
generate_twig
(mut rand_num: u32, twig: &mut TwigMT)
crates/qmdb/src/merkletree/twigfile.rs:403
↓ 3 callers
Method
get_active_bits
Gets the active bits for a specific twig # Arguments `twig_id` - ID of the twig to get active bits for # Returns Reference to the active bits for th
crates/qmdb/src/merkletree/tree.rs:678
↓ 3 callers
Function
get_ciphers
Generates encryption ciphers for secure storage. # Arguments `aes_keys` - Optional 96-byte key material for AES-GCM encryption # Returns A tuple con
crates/qmdb/src/lib.rs:215
↓ 3 callers
Method
get_entry_file_size
Gets the entry file size for a shard. # Arguments `shard_id` - ID of the shard # Returns The current entry file size # Performance - Direct access
crates/qmdb/src/metadb.rs:692
↓ 3 callers
Method
get_file_sizes
Returns the current sizes of the entry and twig files # Returns A tuple of (entry_file_size, twig_file_size) in bytes
crates/qmdb/src/merkletree/tree.rs:651
↓ 3 callers
Method
get_key_hash
get key_hash from a SN2KH record
crates/qmdb/examples/v1_refdbfuzz/refdb.rs:233
↓ 3 callers
Method
get_last_pruned_twig
Gets the last pruned twig information for a shard. # Arguments `shard_id` - ID of the shard # Returns A tuple containing: - ID of the last pruned tw
crates/qmdb/src/metadb.rs:800
↓ 3 callers
Method
get_multi_proof
(&self, sns: &[u64])
crates/qmdb/src/merkletree/multiproof.rs:36
↓ 3 callers
Method
get_oldest_active_sn
Gets the oldest active serial number for a shard. # Arguments `shard_id` - ID of the shard # Returns The oldest active serial number # Performance
crates/qmdb/src/metadb.rs:958
↓ 3 callers
Function
get_pos
(x: u128)
crates/qmdb/src/indexer/hybrid/ref_unit.rs:21
↓ 3 callers
Method
get_root_hash
Gets the root hash for a shard. # Arguments `shard_id` - ID of the shard # Returns The current root hash # Performance - Direct access - No disk I/
crates/qmdb/src/metadb.rs:893
↓ 3 callers
Method
get_shared
(&self)
crates/qmdb/src/seqads.rs:195
↓ 3 callers
Function
hash2x
(children_level: u8, a: T, b: T, exchange_ab: bool)
crates/qmdb/src/merkletree/singleproof.rs:50
↓ 3 callers
Function
into_parts
(value: i64)
crates/qmdb/src/utils/intset.rs:22
↓ 3 callers
Method
is_empty
(&self)
crates/qmdb-common/src/utils/simplemap.rs:218
↓ 3 callers
Method
log_time
(&mut self, event_name: &str)
bench/src/speed/results.rs:428
↓ 3 callers
Method
lookup
(&self, shard_id: usize, file_pos: i64, buf: &mut ReadBuf)
crates/qmdb/src/entryfile/entrycache.rs:68
↓ 3 callers
Method
lookup_without_prev
(&self, height: i64, warmup: bool, k: u64)
crates/qmdb/src/indexer/hybrid/index_cache.rs:123
↓ 3 callers
Function
merkle_node_hash_inplace
( output: &mut AlignedHash32, children_level: usize, left: &AlignedHash32, right: &AlignedHash
crates/qmdb-common/src/merkletree/hash.rs:8
↓ 3 callers
Function
new_big_buf_boxed
Creates a new boxed buffer of size BIG_BUF_SIZE. # Returns A boxed slice initialized with zeros
crates/qmdb-common/src/utils/mod.rs:46
↓ 3 callers
Function
new_temp_file
(dir: &str, num: usize, part: usize)
crates/qmdb/src/indexer/hybrid/mod.rs:33
↓ 3 callers
Method
next_idx
(&self, idx: usize)
crates/qmdb-common/src/utils/simplemap.rs:99
↓ 3 callers
Method
next_key_hash_start
Returns the starting position of the next key hash in the serialized data.
crates/qmdb-common/src/entryfile/entry.rs:499
↓ 3 callers
Method
num_op_in_blk
(&self)
bench/src/speed/test_gen.rs:79
↓ 3 callers
Function
pad32
(bz: &[u8])
crates/qmdb/src/entryfile/entryfile.rs:489
↓ 3 callers
Function
parent_output
( left_child_cv: [u32; 8], right_child_cv: [u32; 8], key_words: [u32; 8], flags: u32, )
crates/qmdb-common/tests/reference_impl.rs:239
↓ 3 callers
Method
payload_len
Returns the length of the payload data (excluding padding and tags).
crates/qmdb-common/src/entryfile/entry.rs:446
↓ 3 callers
Method
print
(&self, name: &str, compact: bool)
bench/src/speed/metrics.rs:215
↓ 3 callers
Method
rand_n
Advances the LFSR by n steps and returns the lowest n bits. # Arguments `n` - Number of steps to advance and bits to return # Returns The lowest n b
crates/qmdb/src/utils/lfsr.rs:144
↓ 3 callers
Method
raw_get
(&self, key: &[u8])
crates/qmdb/examples/v1_refdbfuzz/refdb.rs:213
↓ 3 callers
Method
read_at_with_pre_reader
Read at most `num_bytes` from file at `offset` to fill `buf` # Parameters - `buf`: a vector to be filled - `num_bytes`: the wanted number of bytes t
crates/hpfile/src/lib.rs:531
↓ 3 callers
Method
read_entry_with_pre_reader
( &self, off: i64, end: i64, buf: &mut Vec<u8>, pre_reader: &mut PreRe
crates/qmdb/src/entryfile/entryfile.rs:137
↓ 3 callers
Method
read_extra_info
(&self)
crates/qmdb/src/entryfile/entrybuffer.rs:335
↓ 3 callers
Function
read_u64_with_alignment
Reads a 64-bit unsigned integer from a buffer. # Arguments `buf` - The buffer to read from. `offset` - The byte offset within the buffer. # Returns
crates/qmdb-common/src/entryfile/entry.rs:592
↓ 3 callers
Method
record_throughput_as_total
( &mut self, operation_name: &str, new_total: u64, duration: Duration, )
bench/src/speed/results.rs:447
↓ 3 callers
Method
remove_largest
Remove the largest value and decrement largest_id.
crates/hpfile/src/file_slots.rs:360
↓ 3 callers
Method
resize
(&mut self)
crates/qmdb-common/src/utils/simplemap.rs:141
↓ 3 callers
Method
rotate
Rotate to a new segment. The old `current_file` is dropped (no longer needed - reading uses O_DIRECT from slots). The new segment gets both O_DIRECT
crates/hpfile/src/file_slots.rs:588
↓ 3 callers
Method
set_aes_keys
Sets the encryption keys for the database. # Arguments `keys` - 96-byte array containing the encryption keys: - Bytes 0-31: Shard encryption keys - B
crates/qmdb/src/config.rs:290
↓ 3 callers
Method
set_entry_activiation
Sets the activation status of an entry # Arguments `sn` - Serial number of the entry to update `active` - New activation status
crates/qmdb/src/merkletree/tree.rs:716
↓ 3 callers
Method
set_root_hash
Sets the root hash for a shard. # Arguments `shard_id` - ID of the shard `h` - New root hash # State Changes - Updates root hash - Affects tree stat
crates/qmdb/src/metadb.rs:907
↓ 3 callers
Function
split_cache_pos
Splits a cache position into its component buffer index and offset. # Arguments `idx_and_offset` - The combined cache position value # Returns A t
crates/qmdb/src/utils/bytescache.rs:63
↓ 3 callers
Method
step
(&mut self)
crates/qmdb/src/test_helper/randsrc.rs:48
↓ 3 callers
Method
sync_l3
Synchronizes the level 3 (10) node in the active bits Merkle tree
crates/qmdb-common/src/merkletree/twig.rs:164
↓ 3 callers
Function
sync_mtree
Synchronizes a range of nodes in a twig's Merkle tree This function updates the internal nodes of the tree after leaf changes. # Arguments `mtree` -
crates/qmdb-common/src/merkletree/twig.rs:58
↓ 3 callers
Method
sync_top
Synchronizes the twig root by combining the left_root and active_bits_mtl3
crates/qmdb-common/src/merkletree/twig.rs:170
↓ 3 callers
Function
sync_tree
Helper to sync tree hashes after building (same as in test_proof.rs)
crates/qmdb/src/merkletree/multiproof.rs:260
↓ 3 callers
Method
try_twice_compact
( &mut self, batch: &mut WriteBatchWithTransaction<false>, shard_id: usize, op
crates/qmdb/examples/v1_refdbfuzz/refdb.rs:415
↓ 3 callers
Method
try_twice_compact
Compact the entry file
crates/qmdb-common/src/mutator/entrymutator.rs:306
↓ 3 callers
Function
verify_partial_merkle_tree
( n_leaves: u64, hashes: &[[u8; 32]], bits_words: &[u64], bits_len: usize, mut calc_parent
crates/qmdb-common/src/merkletree/multiproof.rs:159
↓ 3 callers
Method
with_indexer
Sets the indexer for the EntryMutator. # Arguments `indexer` - The indexer to use for tracking entry positions
crates/qmdb-common/src/mutator/entrymutator.rs:401
↓ 3 callers
Method
write_to_file
(&mut self, filename: &str)
bench/src/speed/results.rs:188
↓ 2 callers
Function
_compare_dig_entry
Compares a dug entry with a record for testing. # Arguments `rec` - Optional operation record to compare against `entry_bz` - Entry to compare `comp_
crates/qmdb/src/updater.rs:979
↓ 2 callers
Function
_compare_new_entry
Compares a new entry with a record for testing. # Arguments `rec` - Optional operation record to compare against `entry` - Entry to compare `dsn_list
crates/qmdb/src/updater.rs:965
↓ 2 callers
Function
_compare_old_entry
Compares an old entry with a record for testing. # Arguments `rec` - Optional operation record to compare against `entry_bz` - Entry to compare
crates/qmdb/src/updater.rs:907
↓ 2 callers
Function
_compare_prev_changed
Compares changes to a previous entry with a record for testing. # Arguments `rec` - Optional operation record to compare against `entry` - Entry to c
crates/qmdb/src/updater.rs:939
↓ 2 callers
Function
_compare_prev_entry
Compares a previous entry with a record for testing. # Arguments `rec` - Optional operation record to compare against `entry_bz` - Entry to compare
crates/qmdb/src/updater.rs:919
↓ 2 callers
Function
_compare_put_entry
Compares a put entry with a record for testing. # Arguments `rec` - Optional operation record to compare against `entry` - Entry to compare `dsn_list
crates/qmdb/src/updater.rs:1008
↓ 2 callers
Method
_find_not_erased_value
ensure 'cur_record' is not erased
crates/qmdb/src/indexer/hybrid/file_reader.rs:76
↓ 2 callers
Method
_flush
(&mut self)
crates/qmdb/src/indexer/hybrid/file_writer.rs:78
↓ 2 callers
Method
_for_each_adjacent_value
(&self, height: i64, warmup: bool, k80: &[u8])
crates/qmdb/src/indexer/hybrid/mod.rs:228
↓ 2 callers
Method
_for_each_value
(&self, k: u64, mut access: F)
crates/qmdb/src/indexer/memidx.rs:174
↓ 2 callers
Method
_for_each_value
(&self, height: i64, warmup: bool, k80: &[u8])
crates/qmdb/src/indexer/hybrid/mod.rs:214
↓ 2 callers
Method
_get_rand_kv
(&mut self, keys: &mut HashSet<u32>, with_recent: bool)
crates/qmdb/src/test_helper/testgen.rs:335
↓ 2 callers
Method
_next
(&mut self)
crates/qmdb/src/indexer/hybrid/file_reader.rs:86
↓ 2 callers
Method
active_entry
Marks an entry as active # Arguments `sn` - Serial number of the entry to activate
crates/qmdb/src/merkletree/tree.rs:745
↓ 2 callers
Method
add
Adds the integer `value` to the set. # Arguments `value` - The integer to add to the set. # Returns `true` if the value was added to the set, `fal
crates/qmdb/src/utils/intset.rs:136
↓ 2 callers
Function
add_entry
(batch: &mut WriteBatchWithTransaction<false>, key_hash: &[u8; 32], e: &EntryBz)
crates/qmdb/examples/v1_refdbfuzz/refdb.rs:491
↓ 2 callers
Method
add_op_rec
Adds an operation from an existing operation record. # Arguments `rec` - The operation record to add # Panics If the shard ID derived from the key
crates/qmdb-common/src/utils/changeset.rs:355
↓ 2 callers
Method
add_shard
Adds a shard to the JobManager. # Arguments `update_buffer` - Buffer for updates `entry_file` - File containing entries `done_chan` - Channel for com
crates/qmdb/src/prefetcher/dioprefetcher.rs:605
↓ 2 callers
Method
allocate_big_buf
Allocates a new big buffer, either from the free list or by creating a new one. # Returns A boxed BigBuf either from the free list or newly allocate
crates/qmdb/src/utils/bytescache.rs:127
↓ 2 callers
Method
apply_block
Apply all operations in a block to the bitmap model. This walks over all `ChangeSet`s in the given `task_list` and updates the bitmaps based on the o
bench/src/speed/correctness.rs:91
↓ 2 callers
Method
as_bytes_mut
(&mut self)
crates/qmdb-common/src/utils/hasher.rs:35
↓ 2 callers
Method
batch_write_sync
(&mut self, batch: RocksBatch)
bench/src/speed/rocksdb.rs:84
↓ 2 callers
Function
bitset_len
(bits: u64)
bench/src/speed/correctness.rs:23
↓ 2 callers
Function
calc_n_list
(starting_inactive_twig_id: u64, oldest_active_twig_id: u64)
crates/qmdb/src/merkletree/recover.rs:431
↓ 2 callers
Method
change
(&self, mut x: u64)
bench/src/speed/shuffle_param.rs:25
↓ 2 callers
Method
clear
(&mut self)
crates/qmdb-common/src/entryfile/readbuf.rs:57
↓ 2 callers
Method
close
Closes the twig file
crates/qmdb/src/merkletree/twigfile.rs:323
↓ 2 callers
Function
create_kv
(_: i64, task_list: Vec<RwLock<Option<SimpleTask>>>)
bench/src/speed/mdbx.rs:33
↓ 2 callers
Function
create_kv
(tid: usize, height: i64, task_list: Vec<RwLock<Option<SimpleTask>>>)
bench/src/speed/qmdb.rs:26
↓ 2 callers
Function
create_metadb
(cipher: Option<Aes256Gcm>)
crates/qmdb/src/metadb.rs:1046
↓ 2 callers
Function
cs_add_op
(cs: &mut ChangeSet, op: u8, kh: &[u8; 32], key: &[u8], value: &[u8])
bench/src/bin/crud.rs:488
↓ 2 callers
Method
debug_get_adjacent
(&self, k80: &[u8; 10], k_in: u64)
crates/qmdb/src/indexer/memidx.rs:224
↓ 2 callers
Method
debug_get_values
(&self, k_in: u64)
crates/qmdb/src/indexer/memidx.rs:215
↓ 2 callers
Method
decrypt_entry_in_place
(&self, file_pos: i64, bz: &mut [u8])
crates/qmdb/src/entryfile/entryfile.rs:262
↓ 2 callers
Function
decrypt_page
(page: &mut [u8], off_in_file: usize, cipher: &Option<Aes256Gcm>)
crates/qmdb/src/indexer/hybrid/file_reader.rs:119
↓ 2 callers
Method
decrypt_page
(&mut self)
crates/qmdb/src/indexer/hybrid/file_reader.rs:110
↓ 2 callers
Function
delete_key
(batch: &mut WriteBatch, key: &[u8])
crates/qmdb/src/seqads.rs:329
↓ 2 callers
Method
delete_kv
Deletes a key-value pair from the database. # Arguments `ebw` - Entry buffer writer guard `key_hash` - Hash of the key to delete `key` - Key to delet
crates/qmdb/src/updater.rs:652
↓ 2 callers
Method
disk_sub_ids_mut
(&mut self)
crates/qmdb/src/prefetcher/dioprefetcher.rs:454
↓ 2 callers
Function
drain_channel
(rx: &mut mpsc::Receiver<UringReadRequest>)
crates/qmdb/src/entryfile/uring_reader.rs:657
↓ 2 callers
Method
dump_mem_to_file
(&self, shard_id: usize)
crates/qmdb/src/indexer/hybrid/mod.rs:168
↓ 2 callers
Function
edge_nodes_to_bytes
Serializes a list of edge nodes to bytes The format for each edge node is: - 8 bytes: Position (level and index) - 32 bytes: Hash value # Arguments
crates/qmdb/src/merkletree/recover.rs:45
← previous
next →
301–400 of 1,374, ranked by callers