Use a non-mmap backend for Plan9

db_mmap_test.go

@@ -0,0 +1,10 @@
+//go:build !plan9
+// +build !plan9
+
+package pogreb
+
+import (
+	"github.com/akrylysov/pogreb/fs"
+)
+
+var testFileSystems = []fs.FileSystem{fs.Mem, fs.OSMMap, fs.OS}

db_rpc_test.go

@@ -0,0 +1,10 @@
+//go:build plan9
+// +build plan9
+
+package pogreb
+
+import (
+	"github.com/akrylysov/pogreb/fs"
+)
+
+var testFileSystems = []fs.FileSystem{fs.Mem, fs.OS}

db_test.go

@@ -32,7 +32,7 @@ func TestMain(m *testing.M) {
 		SetLogger(log.New(io.Discard, "", 0))
 	}
 	// Run tests against all file systems.
-	for _, fsys := range []fs.FileSystem{fs.Mem, fs.OSMMap, fs.OS} {
+	for _, fsys := range testFileSystems {
 		var tmpDir string
 		if fsys == fs.Mem {
 			testFS = fsys

fs/os_mmap.go

@@ -1,3 +1,5 @@
+//go:build !plan9
+
 package fs
 
 import (
@@ -161,3 +163,8 @@ func (f *osMMapFile) Close() error {
 	}
 	return f.File.Close()
 }
+
+// Return a default FileSystem for this platform.
+func DefaultFileSystem() FileSystem {
+	return OSMMap
+}

fs/os_mmap_unix.go

@@ -1,4 +1,5 @@
-//go:build !windows
+//go:build !(plan9 || windows)
+// +build !plan9,!windows
 
 package fs
 

fs/os_mmap_windows.go

@@ -1,4 +1,5 @@
 //go:build windows
+// +build windows
 
 package fs
 

fs/os_plan9.go

@@ -0,0 +1,26 @@
+//go:build plan9
+// +build plan9
+
+package fs
+
+import (
+	"os"
+	"syscall"
+)
+
+func createLockFile(name string, perm os.FileMode) (LockFile, bool, error) {
+	acquiredExisting := false
+	if _, err := os.Stat(name); err == nil {
+		acquiredExisting = true
+	}
+	f, err := os.OpenFile(name, os.O_RDWR|os.O_CREATE, syscall.DMEXCL|perm)
+	if err != nil {
+		return nil, false, err
+	}
+	return &osLockFile{f, name}, acquiredExisting, nil
+}
+
+// Return a default FileSystem for this platform.
+func DefaultFileSystem() FileSystem {
+	return OS
+}

fs/os_unix.go

@@ -1,4 +1,5 @@
-//go:build !windows
+//go:build !(plan9 || windows)
+// +build !plan9,!windows
 
 package fs
 

fs/os_windows.go

@@ -1,4 +1,5 @@
 //go:build windows
+// +build windows
 
 package fs
 

options.go

@@ -26,7 +26,7 @@ type Options struct {
 	//
 	// Default: fs.OSMMap.
 	FileSystem fs.FileSystem
-	rootFS     fs.FileSystem
+	rootFS fs.FileSystem
 
 	maxSegmentSize             uint32
 	compactionMinSegmentSize   uint32
@@ -39,7 +39,7 @@ func (src *Options) copyWithDefaults(path string) *Options {
 		opts = *src
 	}
 	if opts.FileSystem == nil {
-		opts.FileSystem = fs.OSMMap
+		opts.FileSystem = fs.DefaultFileSystem()
 	}
 	opts.rootFS = opts.FileSystem
 	opts.FileSystem = fs.Sub(opts.FileSystem, path)