Fix sync data to disk

drpcorg · Apr 18, 2024 · 80130b6 · 80130b6
1 parent 5bea542
commit 80130b6
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/chotki.go b/chotki.go
@@ -379,10 +379,6 @@ func (cho *Chotki) Drain(recs toyqueue.Records) (err error) {
 		}
 	}
 
-	if err := cho.db.Flush(); err != nil {
-		return err
-	}
-
 	if err != nil { // fixme separate packets
 		return
 	}
@@ -409,7 +405,7 @@ func (cho *Chotki) VersionVector() (vv rdx.VV, err error) {
 	return
 }
 
-var WriteOptions = pebble.WriteOptions{Sync: false}
+var WriteOptions = pebble.WriteOptions{Sync: true}
 
 var KeyLogLen = []byte("Mloglen")