summaryrefslogtreecommitdiff
path: root/vendor/github.com/ncruces/go-sqlite3/vfs/shm_windows.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-12-01 22:08:04 +0100
commitb1af8fd87760b34e3ff2fd3bda38f211815a0473 (patch)
tree9317fad1a7ec298d7a8d2678e4e422953bbc6f33 /vendor/github.com/ncruces/go-sqlite3/vfs/shm_windows.go
parent[chore] update URLs to forked source (diff)
downloadgotosocial-b1af8fd87760b34e3ff2fd3bda38f211815a0473.tar.xz
[chore] remove vendor
Diffstat (limited to 'vendor/github.com/ncruces/go-sqlite3/vfs/shm_windows.go')
-rw-r--r--vendor/github.com/ncruces/go-sqlite3/vfs/shm_windows.go180
1 files changed, 0 insertions, 180 deletions
diff --git a/vendor/github.com/ncruces/go-sqlite3/vfs/shm_windows.go b/vendor/github.com/ncruces/go-sqlite3/vfs/shm_windows.go
deleted file mode 100644
index 80ddad5df..000000000
--- a/vendor/github.com/ncruces/go-sqlite3/vfs/shm_windows.go
+++ /dev/null
@@ -1,180 +0,0 @@
-//go:build (386 || arm || amd64 || arm64 || riscv64 || ppc64le) && !sqlite3_dotlk
-
-package vfs
-
-import (
- "context"
- "io"
- "os"
- "sync"
-
- "github.com/tetratelabs/wazero/api"
- "golang.org/x/sys/windows"
-
- "github.com/ncruces/go-sqlite3/internal/util"
-)
-
-type vfsShm struct {
- *os.File
- mod api.Module
- alloc api.Function
- free api.Function
- path string
- regions []*util.MappedRegion
- shared [][]byte
- shadow [][_WALINDEX_PGSZ]byte
- ptrs []ptr_t
- stack [1]stk_t
- fileLock bool
- sync.Mutex
-}
-
-func (s *vfsShm) Close() error {
- // Unmap regions.
- for _, r := range s.regions {
- r.Unmap()
- }
- s.regions = nil
-
- // Close the file.
- return s.File.Close()
-}
-
-func (s *vfsShm) shmOpen() error {
- if s.fileLock {
- return nil
- }
- if s.File == nil {
- f, err := os.OpenFile(s.path, os.O_RDWR|os.O_CREATE, 0666)
- if err != nil {
- return sysError{err, _CANTOPEN}
- }
- s.fileLock = false
- s.File = f
- }
-
- // Dead man's switch.
- if osWriteLock(s.File, _SHM_DMS, 1, 0) == nil {
- err := s.Truncate(0)
- osUnlock(s.File, _SHM_DMS, 1)
- if err != nil {
- return sysError{err, _IOERR_SHMOPEN}
- }
- }
- err := osReadLock(s.File, _SHM_DMS, 1, 0)
- s.fileLock = err == nil
- return err
-}
-
-func (s *vfsShm) shmMap(ctx context.Context, mod api.Module, id, size int32, extend bool) (_ ptr_t, err error) {
- // Ensure size is a multiple of the OS page size.
- if size != _WALINDEX_PGSZ || (windows.Getpagesize()-1)&_WALINDEX_PGSZ != 0 {
- return 0, _IOERR_SHMMAP
- }
- if s.mod == nil {
- s.mod = mod
- s.free = mod.ExportedFunction("sqlite3_free")
- s.alloc = mod.ExportedFunction("sqlite3_malloc64")
- }
- if err := s.shmOpen(); err != nil {
- return 0, err
- }
-
- defer s.shmAcquire(&err)
-
- // Check if file is big enough.
- o, err := s.Seek(0, io.SeekEnd)
- if err != nil {
- return 0, sysError{err, _IOERR_SHMSIZE}
- }
- if n := (int64(id) + 1) * int64(size); n > o {
- if !extend {
- return 0, nil
- }
- if err := osAllocate(s.File, n); err != nil {
- return 0, sysError{err, _IOERR_SHMSIZE}
- }
- }
-
- // Maps regions into memory.
- for int(id) >= len(s.shared) {
- r, err := util.MapRegion(s.File, int64(id)*int64(size), size)
- if err != nil {
- return 0, err
- }
- s.regions = append(s.regions, r)
- s.shared = append(s.shared, r.Data)
- }
-
- // Allocate shadow memory.
- if int(id) >= len(s.shadow) {
- s.shadow = append(s.shadow, make([][_WALINDEX_PGSZ]byte, int(id)-len(s.shadow)+1)...)
- }
-
- // Allocate local memory.
- for int(id) >= len(s.ptrs) {
- s.stack[0] = stk_t(size)
- if err := s.alloc.CallWithStack(ctx, s.stack[:]); err != nil {
- panic(err)
- }
- if s.stack[0] == 0 {
- panic(util.OOMErr)
- }
- clear(util.View(s.mod, ptr_t(s.stack[0]), _WALINDEX_PGSZ))
- s.ptrs = append(s.ptrs, ptr_t(s.stack[0]))
- }
-
- s.shadow[0][4] = 1
- return s.ptrs[id], nil
-}
-
-func (s *vfsShm) shmLock(offset, n int32, flags _ShmFlag) (err error) {
- if s.File == nil {
- return _IOERR_SHMLOCK
- }
-
- switch {
- case flags&_SHM_LOCK != 0:
- defer s.shmAcquire(&err)
- case flags&_SHM_EXCLUSIVE != 0:
- s.shmRelease()
- }
-
- switch {
- case flags&_SHM_UNLOCK != 0:
- return osUnlock(s.File, _SHM_BASE+uint32(offset), uint32(n))
- case flags&_SHM_SHARED != 0:
- return osReadLock(s.File, _SHM_BASE+uint32(offset), uint32(n), 0)
- case flags&_SHM_EXCLUSIVE != 0:
- return osWriteLock(s.File, _SHM_BASE+uint32(offset), uint32(n), 0)
- default:
- panic(util.AssertErr())
- }
-}
-
-func (s *vfsShm) shmUnmap(delete bool) {
- if s.File == nil {
- return
- }
-
- s.shmRelease()
-
- // Free local memory.
- for _, p := range s.ptrs {
- s.stack[0] = stk_t(p)
- if err := s.free.CallWithStack(context.Background(), s.stack[:]); err != nil {
- panic(err)
- }
- }
- s.ptrs = nil
- s.shadow = nil
- s.shared = nil
-
- // Close the file.
- s.Close()
- s.File = nil
- s.fileLock = false
- if delete {
- os.Remove(s.path)
- }
-}