diff options
author | Josh Rickmar <jrick@conformal.com> | 2014-09-18 15:15:52 -0500 |
---|---|---|
committer | Dave Collins <davec@conformal.com> | 2014-09-18 18:14:50 -0500 |
commit | a2cbaa05f9720b15eb1eee7a05893ab992c289b5 (patch) | |
tree | a69b6978e0c1231f5f051aabe6d16c7e9744c2c6 /db.go | |
parent | Rework build to support more liberal unix variants. (diff) | |
download | dedo-a2cbaa05f9720b15eb1eee7a05893ab992c289b5.tar.gz dedo-a2cbaa05f9720b15eb1eee7a05893ab992c289b5.tar.xz |
Fix bolt on OpenBSD.
OpenBSD does not include a UBC kernel and writes must be synchronized
with the msync(2) syscall. In addition, the NoSync field of the DB
struct should be ignored on OpenBSD, since unlike other platforms,
missing msyncs will result in data corruption.
Depends on PR #258.
Fixes #257.
Diffstat (limited to 'db.go')
-rw-r--r-- | db.go | 12 |
1 files changed, 11 insertions, 1 deletions
@@ -4,6 +4,7 @@ import ( "fmt" "hash/fnv" "os" + "runtime" "runtime/debug" "strings" "sync" @@ -23,6 +24,12 @@ const version = 2 // Represents a marker value to indicate that a file is a Bolt DB. const magic uint32 = 0xED0CDAED +// IgnoreNoSync specifies whether the NoSync field of a DB is ignored when +// syncing changes to a file. This is required as some operating systems, +// such as OpenBSD, do not have a unified buffer cache (UBC) and writes +// must be synchronzied using the msync(2) syscall. +const IgnoreNoSync = runtime.GOOS == "openbsd" + // DB represents a collection of buckets persisted to a file on disk. // All data access is performed through transactions which can be obtained through the DB. // All the functions on DB will return a ErrDatabaseNotOpen if accessed before Open() is called. @@ -39,6 +46,9 @@ type DB struct { // a system failure or database corruption. Do not set this flag for // normal use. // + // If the package global IgnoreNoSync constant is true, this value is + // ignored. See the comment on that constant for more details. + // // THIS IS UNSAFE. PLEASE USE WITH CAUTION. NoSync bool @@ -263,7 +273,7 @@ func (db *DB) init() error { if _, err := db.ops.writeAt(buf, 0); err != nil { return err } - if err := fdatasync(db.file); err != nil { + if err := fdatasync(db); err != nil { return err } |