jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(storage): add opt_sync_bytes and opt_sync_period options to MDBX (#10612)

Browse Source
This commit is contained in:
DvirYo-starkware
2024-08-30 13:29:00 +03:00
committed by GitHub
parent 28e46bfd48
commit 2f782a9cbb
1 changed files with 23 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
crates/storage/libmdbx-rs/src/environment.rs
View File

@ -41,6 +41,8 @@ impl Environment {
flags: EnvironmentFlags::default(),
max_readers: None,
max_dbs: None,
sync_bytes: None,
sync_period: None,
rp_augment_limit: None,
loose_limit: None,
dp_reserve_limit: None,
@ -566,6 +568,8 @@ pub struct EnvironmentBuilder {
flags: EnvironmentFlags,
max_readers: Option<u64>,
max_dbs: Option<u64>,
sync_bytes: Option<u64>,
sync_period: Option<u64>,
rp_augment_limit: Option<u64>,
loose_limit: Option<u64>,
dp_reserve_limit: Option<u64>,
@ -639,6 +643,8 @@ impl EnvironmentBuilder {
}
for (opt, v) in [
(ffi::MDBX_opt_max_db, self.max_dbs),
(ffi::MDBX_opt_sync_bytes, self.sync_bytes),
(ffi::MDBX_opt_sync_period, self.sync_period),
(ffi::MDBX_opt_rp_augment_limit, self.rp_augment_limit),
(ffi::MDBX_opt_loose_limit, self.loose_limit),
(ffi::MDBX_opt_dp_reserve_limit, self.dp_reserve_limit),
@ -767,6 +773,23 @@ impl EnvironmentBuilder {
self
}
/// Sets the interprocess/shared threshold to force flush the data buffers to disk, if
/// [`SyncMode::SafeNoSync`](crate::flags::SyncMode::SafeNoSync) is used.
pub fn set_sync_bytes(&mut self, v: usize) -> &mut Self {
self.sync_bytes = Some(v as u64);
self
}
/// Sets the interprocess/shared relative period since the last unsteady commit to force flush
/// the data buffers to disk, if [`SyncMode::SafeNoSync`](crate::flags::SyncMode::SafeNoSync) is
/// used.
pub fn set_sync_period(&mut self, v: Duration) -> &mut Self {
// For this option, mdbx uses units of 1/65536 of a second.
let as_mdbx_units = (v.as_secs_f64() * 65536f64) as u64;
self.sync_period = Some(as_mdbx_units);
self
}
pub fn set_rp_augment_limit(&mut self, v: u64) -> &mut Self {
self.rp_augment_limit = Some(v);
self