sync every txn

serai-dex · Mar 9, 2024 · 68dc872 · 68dc872
1 parent 89b237a
commit 68dc872
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/common/db/src/rocks.rs b/common/db/src/rocks.rs
@@ -1,7 +1,8 @@
 use std::sync::Arc;
 
 use rocksdb::{
-  DBCompressionType, ThreadMode, SingleThreaded, LogLevel, Options, Transaction, TransactionDB,
+  DBCompressionType, ThreadMode, SingleThreaded, LogLevel, WriteOptions, Transaction, Options,
+  TransactionDB,
 };
 
 use crate::*;
@@ -31,7 +32,9 @@ impl<T: ThreadMode> Get for Arc<TransactionDB<T>> {
 impl<T: ThreadMode + 'static> Db for Arc<TransactionDB<T>> {
   type Transaction<'a> = Transaction<'a, TransactionDB<T>>;
   fn txn(&mut self) -> Self::Transaction<'_> {
-    self.transaction()
+    let mut opts = WriteOptions::default();
+    opts.set_sync(true);
+    self.transaction_opt(&opts, &Default::default())
   }
 }