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

fix(): mmap sqe size

Browse source 
Signed-off-by: MastahSenpai <26342994+ii64@users.noreply.github.com>
This commit is contained in:
MastahSenpai 2021-12-23 00:05:42 +07:00
parent b6aaab0abc
commit 3661a48501
Signed by untrusted user who does not match committer: Xeffy
GPG key ID: E41C08AD390E7C49
1 changed files with 4 additions and 1 deletions

5
mem_util.go
View file

@ -1,6 +1,7 @@
package gouring
import (
"fmt"
"syscall"
"unsafe"
@ -77,7 +78,7 @@ func setup(r *Ring, entries uint, parmas *IOUringParams) (ringFd int, err error)
sq.ringEntries = sqRingPtr + uintptr(p.SQOff.RingEntries)
sq.flags = sqRingPtr + uintptr(p.SQOff.Flags)
sq.array = uint32Array(sqRingPtr + uintptr(p.SQOff.Array))
r.sqesPtr, err = mmap(0, uintptr(p.SQEntries),
r.sqesPtr, err = mmap(0, uintptr(p.SQEntries*uint32(_sz_sqe)),
syscall.PROT_READ|syscall.PROT_WRITE,
syscall.MAP_SHARED|syscall.MAP_POPULATE,
ringFd, IORING_OFF_SQES)
@ -95,6 +96,8 @@ func setup(r *Ring, entries uint, parmas *IOUringParams) (ringFd int, err error)
cq.ringEntries = cqRingPtr + uintptr(p.CQOff.RingEntries)
cq.cqes = cqeArray(cqRingPtr + uintptr(p.CQOff.CQEs))
fmt.Printf("sq entries %d cq entries %d\n", *sq.RingEntries(), *cq.RingEntries())
return
}