go/sqlite3
1
0
Fork 0
mirror of https://github.com/ncruces/go-sqlite3.git synced 2026-01-12 05:59:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

VFS xWrite and xSync.

Browse Source
This commit is contained in:
Nuno Cruces
2023-01-19 00:58:57 +00:00
parent eba9febdde
commit 21e0f7860a
1 changed files with 31 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
vfs.go
View File

@@ -224,11 +224,40 @@ func vfsRead(ctx context.Context, mod api.Module, file, buf, iAmt uint32, iOfst
return uint32(IOERR_SHORT_READ)
}
func vfsWrite(file, buf, iAmt uint32, iOfst uint64) uint32 { panic("vfsWrite") }
func vfsWrite(ctx context.Context, mod api.Module, file, buf, iAmt uint32, iOfst uint64) uint32 {
id, ok := mod.Memory().ReadUint32Le(file + ptrSize)
if !ok {
panic("sqlite: out-of-range")
}
mem, ok := mod.Memory().Read(buf, iAmt)
if !ok {
panic("sqlite: out-of-range")
}
c := ctx.Value(connContext{}).(*Conn)
_, err := c.files[id].WriteAt(mem, int64(iOfst))
if err != nil {
return uint32(IOERR_WRITE)
}
return _OK
}
func vfsTruncate(file uint32, size uint64) uint32 { panic("vfsTruncate") }
func vfsSync(file, flags uint32) uint32 { panic("vfsSync") }
func vfsSync(ctx context.Context, mod api.Module, file, flags uint32) uint32 {
id, ok := mod.Memory().ReadUint32Le(file + ptrSize)
if !ok {
panic("sqlite: out-of-range")
}
c := ctx.Value(connContext{}).(*Conn)
err := c.files[id].Sync()
if err != nil {
return uint32(IOERR_FSYNC)
}
return _OK
}
func vfsFileSize(ctx context.Context, mod api.Module, file, pSize uint32) uint32 {
id, ok := mod.Memory().ReadUint32Le(file + ptrSize)