mirror of
https://github.com/ii64/gouring.git
synced 2024-10-18 07:01:09 +02:00
Nugraha
7eedf9754b
There's other adjustment/addition: * Function name CQE/SQE renamed to Cqe/Sqe. * SQ entry union sets value withput util to reduce function complexity, so leaving function budget for another stuff. * UserData has its own type, implement for uint64, uintptr, and unsafe. * TODO: decide what to use `Syscall` or `RawSyscall`. * Exposed `SeenCqe`. * Ignore *.test file extension. * Inline cost tool. Signed-off-by: Nugraha <richiisei@gmail.com>
63 lines
1.6 KiB
Go
63 lines
1.6 KiB
Go
package gouring
|
|
|
|
import (
|
|
"syscall"
|
|
"unsafe"
|
|
)
|
|
|
|
func io_uring_setup(entries uintptr, params *IoUringParams) (ret int, err error) {
|
|
r1, _, e1 := syscall.Syscall(SYS_IO_URING_SETUP, entries, uintptr(unsafe.Pointer(params)), 0)
|
|
ret = int(r1)
|
|
if e1 < 0 {
|
|
err = e1
|
|
}
|
|
return
|
|
}
|
|
|
|
func io_uring_enter(fd int, toSubmit uint32, minComplete uint32, flags uint32, sig *Sigset_t) (ret int, err error) {
|
|
return io_uring_enter2(fd, toSubmit, minComplete, flags, sig, NSIG/8)
|
|
}
|
|
|
|
// TODO: decide to use Syscall or RawSyscall
|
|
|
|
func io_uring_enter2(fd int, toSubmit uint32, minComplete uint32, flags uint32, sig *Sigset_t, sz int32) (ret int, err error) {
|
|
r1, _, e1 := syscall.Syscall6(SYS_IO_URING_ENTER,
|
|
uintptr(fd),
|
|
uintptr(toSubmit), uintptr(minComplete),
|
|
uintptr(flags), uintptr(unsafe.Pointer(sig)), uintptr(sz))
|
|
ret = int(r1)
|
|
if e1 != 0 {
|
|
err = e1
|
|
}
|
|
return
|
|
}
|
|
|
|
func io_uring_register(fd int, opcode uint32, arg unsafe.Pointer, nrArgs uintptr) (ret int, err error) {
|
|
r1, _, e1 := syscall.Syscall6(SYS_IO_URING_REGISTER, uintptr(fd), uintptr(opcode), uintptr(arg), uintptr(nrArgs), 0, 0)
|
|
ret = int(r1)
|
|
if e1 != 0 {
|
|
err = e1
|
|
}
|
|
return
|
|
}
|
|
|
|
//go:linkname mmap syscall.mmap
|
|
func mmap(addr unsafe.Pointer, length uintptr, prot int, flags int, fd int, offset int64) (xaddr unsafe.Pointer, err error)
|
|
|
|
//go:linkname munmap syscall.munmap
|
|
func munmap(addr unsafe.Pointer, length uintptr) (err error)
|
|
|
|
//
|
|
|
|
func increase_rlimit_nofile(nr uint64) error {
|
|
var rlim syscall.Rlimit
|
|
err := syscall.Getrlimit(syscall.RLIMIT_NOFILE, &rlim)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if rlim.Cur < nr {
|
|
rlim.Cur += nr
|
|
err = syscall.Setrlimit(syscall.RLIMIT_NOFILE, &rlim)
|
|
}
|
|
return err
|
|
}
|