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

chore(): clean prints

Browse source 
Signed-off-by: MastahSenpai <26342994+ii64@users.noreply.github.com>
This commit is contained in:
MastahSenpai 2021-12-23 00:34:14 +07:00
parent 4742c90656
commit b19e609515
Signed by untrusted user who does not match committer: Xeffy
GPG key ID: E41C08AD390E7C49
2 changed files with 1 additions and 5 deletions

3
mem_util.go
View file

@ -1,7 +1,6 @@
package gouring
import (
"fmt"
"syscall"
"unsafe"
@ -96,8 +95,6 @@ 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
}

3
queue/queue.go
View file

@ -5,7 +5,6 @@ package queue
import (
"errors"
"fmt"
"runtime"
"sync"
"sync/atomic"
@ -184,7 +183,7 @@ func (q *Queue) Run(f func(cqe *gouring.CQEntry)) {
for q.precheck() == nil {
cqe, err := q.getCQEvent(true)
if cqe == nil || err != nil {
fmt.Printf("run error: %+#v\n", err)
// fmt.Printf("run error: %+#v\n", err)
if err == ErrQueueClosed {
return
}