Xeffy/gouring
1
0
Fork 0
mirror of https://github.com/ii64/gouring.git synced 2024-12-18 02:58:49 +01:00
Code Issues Projects Releases Packages Wiki Activity

fix: minor code typo (#5)

Browse source 
* fix: minor code typo
This commit is contained in:
fzn0x 2022-10-02 19:20:08 +07:00 committed by GitHub
parent d0c4e7f98f
commit 4ed8bc99bd
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
queue.go
View file

@ -234,7 +234,7 @@ func (ring *IoUring) io_uring_wait_cqes_new(cqePtr **IoUringCqe, waitNtr uint32,
func (ring *IoUring) __io_uring_submit_timeout(waitNr uint32, ts *syscall.Timespec) (ret int, err error) { func (ring *IoUring) __io_uring_submit_timeout(waitNr uint32, ts *syscall.Timespec) (ret int, err error) {
sqe := ring.io_uring_get_sqe() sqe := ring.io_uring_get_sqe()
if sqe == nil { if sqe == nil {
ret, err = ring.io_uringn_submit() ret, err = ring.io_uring_submit()
if err != nil { if err != nil {
return return
} }
@ -309,7 +309,7 @@ func (ring *IoUring) io_uring_wait_cqe_timeout(cqePtr **IoUringCqe, ts *syscall.
* *
* Returns number of sqes submitted * Returns number of sqes submitted
*/ */
func (ring *IoUring) io_uringn_submit() (int, error) { func (ring *IoUring) io_uring_submit() (int, error) {
return ring.__io_uring_submit_and_wait(0) return ring.__io_uring_submit_and_wait(0)
} }

2
uring.go
View file

@ -40,7 +40,7 @@ func (h *IoUring) SeenCqe(cqe *IoUringCqe) {
} }
func (h *IoUring) Submit() (int, error) { func (h *IoUring) Submit() (int, error) {
return h.io_uringn_submit() return h.io_uring_submit()
} }
func (h *IoUring) SubmitAndWait(waitNr uint32) (int, error) { func (h *IoUring) SubmitAndWait(waitNr uint32) (int, error) {