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(): expose GetCQEvent

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

4
queue/queue.go
View file

@ -146,7 +146,7 @@ func (q *Queue) cqAdvance(d uint32) {
}
}
func (q *Queue) getCQEvent(wait bool) (cqe *gouring.CQEntry, err error) {
func (q *Queue) GetCQEvent(wait bool) (cqe *gouring.CQEntry, err error) {
if err = q.precheck(); err != nil {
return
}
@ -181,7 +181,7 @@ func (q *Queue) getCQEvent(wait bool) (cqe *gouring.CQEntry, err error) {
func (q *Queue) Run(f func(cqe *gouring.CQEntry)) {
for q.precheck() == nil {
cqe, err := q.getCQEvent(true)
cqe, err := q.GetCQEvent(true)
if cqe == nil || err != nil {
// fmt.Printf("run error: %+#v\n", err)
if err == ErrQueueClosed {