Merge pull request #76 from benbjohnson/fsync

fdatasync

syscall.go

@@ -0,0 +1,9 @@
+// +build !linux
+
+package bolt
+
+import "os"
+
+func fdatasync(f *os.File) error {
+	return f.Sync()
+}

syscall_linux.go

@@ -0,0 +1,10 @@
+package bolt
+
+import (
+	"os"
+	"syscall"
+)
+
+func fdatasync(f *os.File) error {
+	return syscall.Fdatasync(int(f.Fd()))
+}

tx.go

@@ -329,6 +329,9 @@ func (t *Tx) write() error {
 			return err
 		}
 	}
+	if err := fdatasync(t.db.file); err != nil {
+		return err
+	}
 
 	// Clear out page cache.
 	t.pages = make(map[pgid]*page)