From 2f782a9cbbdc5073e3eabb8b1b67a70d19968de4 Mon Sep 17 00:00:00 2001
From: DvirYo-starkware <115620476+DvirYo-starkware@users.noreply.github.com>
Date: Fri, 30 Aug 2024 13:29:00 +0300
Subject: [PATCH] feat(storage): add `opt_sync_bytes` and `opt_sync_period`
 options to MDBX (#10612)

---
 crates/storage/libmdbx-rs/src/environment.rs | 23 ++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/crates/storage/libmdbx-rs/src/environment.rs b/crates/storage/libmdbx-rs/src/environment.rs
index 1549d42e18..f243c7da18 100644
--- a/crates/storage/libmdbx-rs/src/environment.rs
+++ b/crates/storage/libmdbx-rs/src/environment.rs
@@ -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