summaryrefslogtreecommitdiff
path: root/vendor/github.com/ncruces/go-sqlite3/vfs/shm_ofd.go
diff options
context:
space:
mode:
authorLibravatar Terin Stock <terinjokes@gmail.com>2025-03-09 17:47:56 +0100
committerLibravatar Terin Stock <terinjokes@gmail.com>2025-03-10 01:59:49 +0100
commit3ac1ee16f377d31a0fb80c8dae28b6239ac4229e (patch)
treef61faa581feaaeaba2542b9f2b8234a590684413 /vendor/github.com/ncruces/go-sqlite3/vfs/shm_ofd.go
parent[chore] update URLs to forked source (diff)
downloadgotosocial-3ac1ee16f377d31a0fb80c8dae28b6239ac4229e.tar.xz
[chore] remove vendor
Diffstat (limited to 'vendor/github.com/ncruces/go-sqlite3/vfs/shm_ofd.go')
-rw-r--r--vendor/github.com/ncruces/go-sqlite3/vfs/shm_ofd.go176
1 files changed, 0 insertions, 176 deletions
diff --git a/vendor/github.com/ncruces/go-sqlite3/vfs/shm_ofd.go b/vendor/github.com/ncruces/go-sqlite3/vfs/shm_ofd.go
deleted file mode 100644
index b0f50fcb5..000000000
--- a/vendor/github.com/ncruces/go-sqlite3/vfs/shm_ofd.go
+++ /dev/null
@@ -1,176 +0,0 @@
-//go:build (linux || darwin) && (386 || arm || amd64 || arm64 || riscv64 || ppc64le) && !(sqlite3_flock || sqlite3_dotlk)
-
-package vfs
-
-import (
- "context"
- "io"
- "os"
- "sync"
- "time"
-
- "github.com/tetratelabs/wazero/api"
- "golang.org/x/sys/unix"
-
- "github.com/ncruces/go-sqlite3/internal/util"
-)
-
-type vfsShm struct {
- *os.File
- path string
- regions []*util.MappedRegion
- readOnly bool
- fileLock bool
- blocking bool
- sync.Mutex
-}
-
-var _ blockingSharedMemory = &vfsShm{}
-
-func (s *vfsShm) shmOpen() _ErrorCode {
- if s.File == nil {
- f, err := os.OpenFile(s.path,
- os.O_RDWR|os.O_CREATE|_O_NOFOLLOW, 0666)
- if err != nil {
- f, err = os.OpenFile(s.path,
- os.O_RDONLY|os.O_CREATE|_O_NOFOLLOW, 0666)
- s.readOnly = true
- }
- if err != nil {
- return _CANTOPEN
- }
- s.File = f
- }
- if s.fileLock {
- return _OK
- }
-
- // Dead man's switch.
- if lock, rc := osTestLock(s.File, _SHM_DMS, 1); rc != _OK {
- return _IOERR_LOCK
- } else if lock == unix.F_WRLCK {
- return _BUSY
- } else if lock == unix.F_UNLCK {
- if s.readOnly {
- return _READONLY_CANTINIT
- }
- // Do not use a blocking lock here.
- // If the lock cannot be obtained immediately,
- // it means some other connection is truncating the file.
- // And after it has done so, it will not release its lock,
- // but only downgrade it to a shared lock.
- // So no point in blocking here.
- // The call below to obtain the shared DMS lock may use a blocking lock.
- if rc := osWriteLock(s.File, _SHM_DMS, 1, 0); rc != _OK {
- return rc
- }
- if err := s.Truncate(0); err != nil {
- return _IOERR_SHMOPEN
- }
- }
- rc := osReadLock(s.File, _SHM_DMS, 1, time.Millisecond)
- s.fileLock = rc == _OK
- return rc
-}
-
-func (s *vfsShm) shmMap(ctx context.Context, mod api.Module, id, size int32, extend bool) (ptr_t, _ErrorCode) {
- // Ensure size is a multiple of the OS page size.
- if int(size)&(unix.Getpagesize()-1) != 0 {
- return 0, _IOERR_SHMMAP
- }
-
- if rc := s.shmOpen(); rc != _OK {
- return 0, rc
- }
-
- // Check if file is big enough.
- o, err := s.Seek(0, io.SeekEnd)
- if err != nil {
- return 0, _IOERR_SHMSIZE
- }
- if n := (int64(id) + 1) * int64(size); n > o {
- if !extend {
- return 0, _OK
- }
- if s.readOnly || osAllocate(s.File, n) != nil {
- return 0, _IOERR_SHMSIZE
- }
- }
-
- r, err := util.MapRegion(ctx, mod, s.File, int64(id)*int64(size), size, s.readOnly)
- if err != nil {
- return 0, _IOERR_SHMMAP
- }
- s.regions = append(s.regions, r)
- if s.readOnly {
- return r.Ptr, _READONLY
- }
- return r.Ptr, _OK
-}
-
-func (s *vfsShm) shmLock(offset, n int32, flags _ShmFlag) _ErrorCode {
- // Argument check.
- switch {
- case n <= 0:
- panic(util.AssertErr())
- case offset < 0 || offset+n > _SHM_NLOCK:
- panic(util.AssertErr())
- case n != 1 && flags&_SHM_EXCLUSIVE == 0:
- panic(util.AssertErr())
- }
- switch flags {
- case
- _SHM_LOCK | _SHM_SHARED,
- _SHM_LOCK | _SHM_EXCLUSIVE,
- _SHM_UNLOCK | _SHM_SHARED,
- _SHM_UNLOCK | _SHM_EXCLUSIVE:
- //
- default:
- panic(util.AssertErr())
- }
-
- var timeout time.Duration
- if s.blocking {
- timeout = time.Millisecond
- }
-
- switch {
- case flags&_SHM_UNLOCK != 0:
- return osUnlock(s.File, _SHM_BASE+int64(offset), int64(n))
- case flags&_SHM_SHARED != 0:
- return osReadLock(s.File, _SHM_BASE+int64(offset), int64(n), timeout)
- case flags&_SHM_EXCLUSIVE != 0:
- return osWriteLock(s.File, _SHM_BASE+int64(offset), int64(n), timeout)
- default:
- panic(util.AssertErr())
- }
-}
-
-func (s *vfsShm) shmUnmap(delete bool) {
- if s.File == nil {
- return
- }
-
- // Unmap regions.
- for _, r := range s.regions {
- r.Unmap()
- }
- s.regions = nil
-
- // Close the file.
- if delete {
- os.Remove(s.path)
- }
- s.Close()
- s.File = nil
-}
-
-func (s *vfsShm) shmBarrier() {
- s.Lock()
- //lint:ignore SA2001 memory barrier.
- s.Unlock()
-}
-
-func (s *vfsShm) shmEnableBlocking(block bool) {
- s.blocking = block
-}