Xeffy/gouring
1
0
Fork 0
mirror of https://github.com/ii64/gouring.git synced 2025-04-26 05:42:48 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat(register): io uring register implemented

Browse source 
Signed-off-by: MastahSenpai <26342994+ii64@users.noreply.github.com>
This commit is contained in:
MastahSenpai 2021-12-20 18:54:39 +07:00
parent 85e03649ba
commit d360145934
Signed by untrusted user who does not match committer: Xeffy
GPG key ID: E41C08AD390E7C49
3 changed files with 15 additions and 2 deletions

2
const_value.go
View file

@ -152,7 +152,7 @@ const (
//
type UringRegisterOpcode = uint32
type UringRegisterOpcode = uint
const (
IORING_REGISTER_BUFFERS UringRegisterOpcode = iota

9
core.go
View file

@ -26,6 +26,15 @@ func (r *Ring) Close() (err error) {
return
}
func (r *Ring) Register(opcode UringRegisterOpcode, arg uintptr, nrArg uint) (ret int, err error) {
ret, err = register(r, opcode, arg, nrArg)
if err != nil {
err = errors.Wrap(err, "register")
return
}
return
}
func (r *Ring) Enter(toSubmit, minComplete uint, flags UringEnterFlag, sig *Sigset_t) (ret int, err error) {
ret, err = enter(r, toSubmit, minComplete, flags, sig)
if err != nil {

6
mem_util.go
View file

@ -121,7 +121,11 @@ func unsetup(r *Ring) (err error) {
return
}
func register(r *Ring) (err error) {
func register(r *Ring, opcode UringRegisterOpcode, arg uintptr, nrArg uint) (ret int, err error) {
if ret, err = io_uring_register(r.fd, opcode, arg, nrArg); err != nil {
err = errors.Wrap(err, "io_uring_register")
return
}
return
}