gouring

package module
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 5, 2023 License: MIT Imports: 4 Imported by: 0

README

gouring

Go Reference

go get github.com/anshulkamath/gouring

Example

// setup
h, err := gouring.New(256, 0)
if err != nil { /*...*/ }
defer h.Close() 

sqe := h.GetSQE()
b := []byte("io_uring!\n")
PrepWrite(sqe, 1, &b[0], len(b), 0)

submitted, err := h.SubmitAndWait(1)
if err != nil { /*...*/ }
println(submitted) // 1

var cqe *gouring.IoUringCqe
err = h.WaitCqe(&cqe) 
if err != nil { /*...*/ } // check also EINTR

_ = cqe.UserData
_ = cqe.Res
_ = cqe.Flags

Graph

SQPOLL non-SQPOLL
sqpoll_fig nonsqpoll_fig
Reference

https://github.com/axboe/liburing

Documentation

Overview

SPDX-License-Identifier: (GPL-2.0 WITH Linux-syscall-note) OR MIT

* Header file for the io_uring interface. * * Copyright (C) 2019 Jens Axboe * Copyright (C) 2019 Christoph Hellwig

Index

Constants

View Source 
const (
	IOSQE_FIXED_FILE_BIT = iota
	IOSQE_IO_DRAIN_BIT
	IOSQE_IO_LINK_BIT
	IOSQE_IO_HARDLINK_BIT
	IOSQE_ASYNC_BIT
	IOSQE_BUFFER_SELECT_BIT
	IOSQE_CQE_SKIP_SUCCESS_BIT
)
View Source 
const (
	/* use fixed fileset */
	IOSQE_FIXED_FILE = (1 << IOSQE_FIXED_FILE_BIT)
	/* issue after inflight IO */
	IOSQE_IO_DRAIN = (1 << IOSQE_IO_DRAIN_BIT)
	/* links next sqe */
	IOSQE_IO_LINK = (1 << IOSQE_IO_LINK_BIT)
	/* like LINK, but stronger */
	IOSQE_IO_HARDLINK = (1 << IOSQE_IO_HARDLINK_BIT)
	/* always go async */
	IOSQE_ASYNC = (1 << IOSQE_ASYNC_BIT)
	/* select buffer from sqe->buf_group */
	IOSQE_BUFFER_SELECT = (1 << IOSQE_BUFFER_SELECT_BIT)
	/* don't post CQE if request succeeded */
	IOSQE_CQE_SKIP_SUCCESS = (1 << IOSQE_CQE_SKIP_SUCCESS_BIT)
)

* sqe->flags

View Source 
const (
	IORING_SETUP_IOPOLL     = (1 << 0) /* io_context is polled */
	IORING_SETUP_SQPOLL     = (1 << 1) /* SQ poll thread */
	IORING_SETUP_SQ_AFF     = (1 << 2) /* sq_thread_cpu is valid */
	IORING_SETUP_CQSIZE     = (1 << 3) /* app defines CQ size */
	IORING_SETUP_CLAMP      = (1 << 4) /* clamp SQ/CQ ring sizes */
	IORING_SETUP_ATTACH_WQ  = (1 << 5) /* attach to existing wq */
	IORING_SETUP_R_DISABLED = (1 << 6) /* start with ring disabled */
	IORING_SETUP_SUBMIT_ALL = (1 << 7) /* continue submit on error */
)

* io_uring_setup() flags

View Source 
const (
	IORING_TIMEOUT_ABS           = (1 << 0)
	IORING_TIMEOUT_UPDATE        = (1 << 1)
	IORING_TIMEOUT_BOOTTIME      = (1 << 2)
	IORING_TIMEOUT_REALTIME      = (1 << 3)
	IORING_LINK_TIMEOUT_UPDATE   = (1 << 4)
	IORING_TIMEOUT_ETIME_SUCCESS = (1 << 5)
	IORING_TIMEOUT_CLOCK_MASK    = (IORING_TIMEOUT_BOOTTIME | IORING_TIMEOUT_REALTIME)
	IORING_TIMEOUT_UPDATE_MASK   = (IORING_TIMEOUT_UPDATE | IORING_LINK_TIMEOUT_UPDATE)
)

* sqe->timeout_flags

View Source 
const (
	IORING_POLL_ADD_MULTI        = (1 << 0)
	IORING_POLL_UPDATE_EVENTS    = (1 << 1)
	IORING_POLL_UPDATE_USER_DATA = (1 << 2)
)

* POLL_ADD flags. Note that since sqe->poll_events is the flag space, the * command flags for POLL_ADD are stored in sqe->len. * * IORING_POLL_ADD_MULTI Multishot poll. Sets IORING_CQE_F_MORE if * the poll handler will continue to report * CQEs on behalf of the same SQE. * * IORING_POLL_UPDATE Update existing poll request, matching * sqe->addr as the old user_data field.

View Source 
const (
	IORING_ASYNC_CANCEL_ALL = (1 << 0)
	IORING_ASYNC_CANCEL_FD  = (1 << 1)
	IORING_ASYNC_CANCEL_ANY = (1 << 2)
)

* ASYNC_CANCEL flags. * * IORING_ASYNC_CANCEL_ALL Cancel all requests that match the given key * IORING_ASYNC_CANCEL_FD Key off 'fd' for cancelation rather than the * request 'user_data' * IORING_ASYNC_CANCEL_ANY Match any request

View Source 
const (
	IORING_CQE_F_BUFFER        = (1 << 0)
	IORING_CQE_F_MORE          = (1 << 1)
	IORING_CQE_F_SOCK_NONEMPTY = (1 << 2)
)
View Source 
const (
	IORING_OFF_SQ_RING = 0
	IORING_OFF_CQ_RING = 0x8000000
	IORING_OFF_SQES    = 0x10000000
)

* Magic offsets for the application to mmap the data it needs

View Source 
const (
	IORING_SQ_NEED_WAKEUP = (1 << 0) /* needs io_uring_enter wakeup */
	IORING_SQ_CQ_OVERFLOW = (1 << 1) /* CQ ring is overflown */
	IORING_SQ_TASKRUN     = (1 << 2) /* task should enter the kernel */
)

* sq_ring->flags

View Source 
const (
	IORING_ENTER_GETEVENTS       = (1 << 0)
	IORING_ENTER_SQ_WAKEUP       = (1 << 1)
	IORING_ENTER_SQ_WAIT         = (1 << 2)
	IORING_ENTER_EXT_ARG         = (1 << 3)
	IORING_ENTER_REGISTERED_RING = (1 << 4)
)

* io_uring_enter(2) flags

View Source 
const (
	IORING_FEAT_SINGLE_MMAP     = (1 << 0)
	IORING_FEAT_NODROP          = (1 << 1)
	IORING_FEAT_SUBMIT_STABLE   = (1 << 2)
	IORING_FEAT_RW_CUR_POS      = (1 << 3)
	IORING_FEAT_CUR_PERSONALITY = (1 << 4)
	IORING_FEAT_FAST_POLL       = (1 << 5)
	IORING_FEAT_POLL_32BITS     = (1 << 6)
	IORING_FEAT_SQPOLL_NONFIXED = (1 << 7)
	IORING_FEAT_EXT_ARG         = (1 << 8)
	IORING_FEAT_NATIVE_WORKERS  = (1 << 9)
	IORING_FEAT_RSRC_TAGS       = (1 << 10)
	IORING_FEAT_CQE_SKIP        = (1 << 11)
	IORING_FEAT_LINKED_FILE     = (1 << 12)
)

* io_uring_params->features flags

View Source 
const (
	IORING_REGISTER_BUFFERS       = 0
	IORING_UNREGISTER_BUFFERS     = 1
	IORING_REGISTER_FILES         = 2
	IORING_UNREGISTER_FILES       = 3
	IORING_REGISTER_EVENTFD       = 4
	IORING_UNREGISTER_EVENTFD     = 5
	IORING_REGISTER_FILES_UPDATE  = 6
	IORING_REGISTER_EVENTFD_ASYNC = 7
	IORING_REGISTER_PROBE         = 8
	IORING_REGISTER_PERSONALITY   = 9
	IORING_UNREGISTER_PERSONALITY = 10
	IORING_REGISTER_RESTRICTIONS  = 11
	IORING_REGISTER_ENABLE_RINGS  = 12

	/* extended with tagging */
	IORING_REGISTER_FILES2         = 13
	IORING_REGISTER_FILES_UPDATE2  = 14
	IORING_REGISTER_BUFFERS2       = 15
	IORING_REGISTER_BUFFERS_UPDATE = 16

	/* set/clear io-wq thread affinities */
	IORING_REGISTER_IOWQ_AFF   = 17
	IORING_UNREGISTER_IOWQ_AFF = 18

	/* set/get max number of io-wq workers */
	IORING_REGISTER_IOWQ_MAX_WORKERS = 19

	/* register/unregister io_uring fd with the ring */
	IORING_REGISTER_RING_FDS   = 20
	IORING_UNREGISTER_RING_FDS = 21

	/* register ring based provide buffer group */
	IORING_REGISTER_PBUF_RING   = 22
	IORING_UNREGISTER_PBUF_RING = 23

	/* this goes last */
	IORING_REGISTER_LAST
)

* io_uring_register(2) opcodes and arguments

View Source 
const (
	IO_WQ_BOUND = iota
	IO_WQ_UNBOUND
)

io-wq worker categories

View Source 
const (
	/* Allow an io_uring_register(2) opcode */
	IORING_RESTRICTION_REGISTER_OP = 0

	/* Allow an sqe opcode */
	IORING_RESTRICTION_SQE_OP = 1

	/* Allow sqe flags */
	IORING_RESTRICTION_SQE_FLAGS_ALLOWED = 2

	/* Require sqe flags (these flags must be set on each submission) */
	IORING_RESTRICTION_SQE_FLAGS_REQUIRED = 3

	IORING_RESTRICTION_LAST
)

* IoUringRestriction->opcode values

View Source 
const (
	SizeofUnsigned   = unsafe.Sizeof(uint32(0))
	SizeofUint32     = unsafe.Sizeof(uint32(0))
	SizeofIoUringSqe = unsafe.Sizeof(IoUringSqe{})
	SizeofIoUringCqe = unsafe.Sizeof(IoUringCqe{})
)
View Source 
const (
	SizeofUint64  = unsafe.Sizeof(uint64(0))
	SIGSET_NWORDS = (1024 / (8 * SizeofUint64))
	SIGTMIN       = 32
	SIGTMAX       = SIGTMIN
	NSIG          = (SIGTMAX + 1)
)
View Source 
const (
	SYS_IO_URING_SETUP    = 425
	SYS_IO_URING_ENTER    = 426
	SYS_IO_URING_REGISTER = 427
)
View Source 
const INT_FLAG_REG_RING uint8 = 1
View Source 
const IORING_ACCEPT_MULTISHOT = (1 << 0)

* accept flags stored in sqe->ioprio

View Source 
const (
	IORING_CQE_BUFFER_SHIFT = 16
)
View Source 
const IORING_CQ_EVENTFD_DISABLED = (1 << 0)

disable eventfd notifications

View Source 
const IORING_FILE_INDEX_ALLOC = ^uint32(0)

* If sqe->file_index is set to this for opcodes that instantiate a new * direct descriptor (like openat/openat2/accept), then io_uring will allocate * an available direct descriptor instead of having the application pass one * in. The picked direct descriptor will be returned in cqe->res, or -ENFILE * if the space is full.

View Source 
const IORING_FSYNC_DATASYNC = (1 << 0)

* sqe->fsync_flags

View Source 
const IORING_RECVSEND_POLL_FIRST = (1 << 0)

* send/sendmsg and recv/recvmsg flags (sqe->addr2) * * IORING_RECVSEND_POLL_FIRST If set, instead of first attempting to send * or receive and arm poll if that yields an * -EAGAIN result, arm poll upfront and skip * the initial transfer attempt.

View Source 
const IORING_REGISTER_FILES_SKIP = (-2)

Skip updating fd indexes set to this value in the fd table

View Source 
const IORING_RSRC_REGISTER_SPARSE = (1 << 0)

* Register a fully sparse file space, rather than pass in an array of all * -1 file descriptors.

View Source 
const IORING_SETUP_COOP_TASKRUN = (1 << 8)

* Cooperative task running. When requests complete, they often require * forcing the submitter to transition to the kernel to complete. If this * flag is set, work will be done when the task transitions anyway, rather * than force an inter-processor interrupt reschedule. This avoids interrupting * a task running in userspace, and saves an IPI.

View Source 
const IORING_SETUP_CQE32 = (1 << 11) /* CQEs are 32 byte */
View Source 
const IORING_SETUP_SQE128 = (1 << 10) /* SQEs are 128 byte */
View Source 
const IORING_SETUP_TASKRUN_FLAG = (1 << 9)

* If COOP_TASKRUN is set, get notified if task work is available for * running and a kernel transition would be needed to run it. This sets * IORING_SQ_TASKRUN in the sq ring flags. Not valid with COOP_TASKRUN.

View Source 
const IO_URING_OP_SUPPORTED = (1 << 0)
View Source 
const LIBURING_UDATA_TIMEOUT uint64 = ^uint64(0)
View Source 
const SPLICE_F_FD_IN_FIXED = (1 << 31) /* the last bit of __u32 */

* sqe->splice_flags * extends splice(2) flags

Variables

This section is empty.

Functions

func PrepAccept 

func PrepAccept(sqe *IoUringSqe, fd int, rsa *syscall.RawSockaddrAny, rsaSz *uintptr, flags uint)

func PrepClose 

func PrepClose(sqe *IoUringSqe, fd int)

func PrepMultishotAccept 

func PrepMultishotAccept(sqe *IoUringSqe, fd int, rsa *syscall.RawSockaddrAny, rsaSz *uintptr, flags uint)

func PrepNop 

func PrepNop(sqe *IoUringSqe)

func PrepRW 

func PrepRW(op IoUringOp, sqe *IoUringSqe, fd int,
	addr unsafe.Pointer, len int, offset uint64)

func PrepRead 

func PrepRead(sqe *IoUringSqe, fd int, buf *byte, nb int, offset uint64)

func PrepReadv 

func PrepReadv(sqe *IoUringSqe, fd int,
	iov *syscall.Iovec, nrVecs int,
	offset uint64)

func PrepReadv2 

func PrepReadv2(sqe *IoUringSqe, fd int,
	iov *syscall.Iovec, nrVecs int,
	offset uint64, flags uint32)

func PrepRecvmsg 

func PrepRecvmsg(sqe *IoUringSqe, fd int, msg *syscall.Msghdr, flags uint)

func PrepSendmsg 

func PrepSendmsg(sqe *IoUringSqe, fd int, msg *syscall.Msghdr, flags uint)

func PrepTimeout 

func PrepTimeout(sqe *IoUringSqe, ts *syscall.Timespec, count uint32, flags uint32)

func PrepTimeoutRemove 

func PrepTimeoutRemove(sqe *IoUringSqe, userDaata uint64, flags uint32)

func PrepTimeoutUpdate 

func PrepTimeoutUpdate(sqe *IoUringSqe, ts *syscall.Timespec, userData uint64, flags uint32)

func PrepWrite 

func PrepWrite(sqe *IoUringSqe, fd int, buf *byte, nb int, offset uint64)

func PrepWritev 

func PrepWritev(sqe *IoUringSqe, fd int,
	iov *syscall.Iovec, nrVecs int,
	offset uint64)

func PrepWritev2 

func PrepWritev2(sqe *IoUringSqe, fd int,
	iov *syscall.Iovec, nrVecs int,
	offset uint64, flags uint32)

Types

type IoCqringOffsets 

type IoCqringOffsets struct {
	Head        uint32
	Tail        uint32
	RingMask    uint32
	RingEntries uint32
	Overflow    uint32
	Cqes        uint32
	Flags       uint32
	// contains filtered or unexported fields
}

type IoSqringOffsets 

type IoSqringOffsets struct {
	Head        uint32
	Tail        uint32
	RingMask    uint32
	RingEntries uint32
	Flags       uint32
	Dropped     uint32
	Array       uint32
	// contains filtered or unexported fields
}

type IoUring 

type IoUring struct {
	Sq     IoUringSq
	Cq     IoUringCq
	Flags  uint32
	RingFd int

	Features    uint32
	EnterRingFd int
	IntFlags    uint8
	// contains filtered or unexported fields
}

func New 

func New(entries uint32, flags uint32) (*IoUring, error)

func NewWithParams 

func NewWithParams(entries uint32, params *IoUringParams) (*IoUring, error)

func (*IoUring) Close 

func (h *IoUring) Close()

func (*IoUring) GetSqe 

func (h *IoUring) GetSqe() *IoUringSqe

func (*IoUring) PeekCqe added in v0.0.2 

func (h *IoUring) PeekCqe(cqePtr **IoUringCqe) error

func (*IoUring) SeenCqe 

func (h *IoUring) SeenCqe(cqe *IoUringCqe)

func (*IoUring) Submit 

func (h *IoUring) Submit() (int, error)

func (*IoUring) SubmitAndWait 

func (h *IoUring) SubmitAndWait(waitNr uint32) (int, error)

func (*IoUring) WaitCqe 

func (h *IoUring) WaitCqe(cqePtr **IoUringCqe) error

type IoUringBuf 

type IoUringBuf struct {
	Addr uint64
	Len  uint32
	Bid  uint16
	// contains filtered or unexported fields
}

type IoUringBufReg 

type IoUringBufReg struct {
	RingAddr    uint64
	RingEntries uint32
	Bgid        uint16
	Pad         uint16
	// contains filtered or unexported fields
}

argument for IORING_(UN)REGISTER_PBUF_RING

type IoUringBufRing 

type IoUringBufRing struct {
	//  union {
	/*
	 * To avoid spilling into more pages than we need to, the
	 * ring tail is overlaid with the IoUringBuf->resv field.
	 */
	Anon0 struct {
		Tail uint16
		// contains filtered or unexported fields
	}
}

type IoUringCq 

type IoUringCq struct {
	Cqes ioUringCqeArray //ptr arith

	RingSz  uint32
	RingPtr unsafe.Pointer
	// contains filtered or unexported fields
}

type IoUringCqe 

type IoUringCqe struct {
	UserData UserData /* sqe->data submission passed back */
	Res      int32    /* result code for this event */
	Flags    uint32
}

* IO completion data structure (Completion Queue Entry)

type IoUringFilesUpdate 

type IoUringFilesUpdate struct {
	Offset uint32

	Fds uint64 // __aligned_u64/* __s32 * */
	// contains filtered or unexported fields
}

deprecated, see struct IoUringRsrcUpdate

type IoUringGeteventsArg 

type IoUringGeteventsArg struct {
	Sigmask   uint64
	SigmaskSz uint32
	Pad       uint32
	Ts        uint64
}

type IoUringOp 

type IoUringOp = uint8
const (
	IORING_OP_NOP IoUringOp = iota
	IORING_OP_READV
	IORING_OP_WRITEV
	IORING_OP_FSYNC
	IORING_OP_READ_FIXED
	IORING_OP_WRITE_FIXED
	IORING_OP_POLL_ADD
	IORING_OP_POLL_REMOVE
	IORING_OP_SYNC_FILE_RANGE
	IORING_OP_SENDMSG
	IORING_OP_RECVMSG
	IORING_OP_TIMEOUT
	IORING_OP_TIMEOUT_REMOVE
	IORING_OP_ACCEPT
	IORING_OP_ASYNC_CANCEL
	IORING_OP_LINK_TIMEOUT
	IORING_OP_CONNECT
	IORING_OP_FALLOCATE
	IORING_OP_OPENAT
	IORING_OP_CLOSE
	IORING_OP_FILES_UPDATE
	IORING_OP_STATX
	IORING_OP_READ
	IORING_OP_WRITE
	IORING_OP_FADVISE
	IORING_OP_MADVISE
	IORING_OP_SEND
	IORING_OP_RECV
	IORING_OP_OPENAT2
	IORING_OP_EPOLL_CTL
	IORING_OP_SPLICE
	IORING_OP_PROVIDE_BUFFERS
	IORING_OP_REMOVE_BUFFERS
	IORING_OP_TEE
	IORING_OP_SHUTDOWN
	IORING_OP_RENAMEAT
	IORING_OP_UNLINKAT
	IORING_OP_MKDIRAT
	IORING_OP_SYMLINKAT
	IORING_OP_LINKAT
	IORING_OP_MSG_RING
	IORING_OP_FSETXATTR
	IORING_OP_SETXATTR
	IORING_OP_FGETXATTR
	IORING_OP_GETXATTR
	IORING_OP_SOCKET
	IORING_OP_URING_CMD

	/* this goes last, obviously */
	IORING_OP_LAST
)

type IoUringParams 

type IoUringParams struct {
	SqEntries    uint32
	CqEntries    uint32
	Flags        uint32
	SqThreadCpu  uint32
	SqThreadIdle uint32
	Features     uint32
	WqFd         uint32

	SqOff IoSqringOffsets
	CqOff IoCqringOffsets
	// contains filtered or unexported fields
}

type IoUringProbe 

type IoUringProbe struct {
	// contains filtered or unexported fields
}

type IoUringProbeOp 

type IoUringProbeOp struct {
	// contains filtered or unexported fields
}

type IoUringRestriction 

type IoUringRestriction struct {

	//  union {
	// 	 __u8 register_op; /* IORING_RESTRICTION_REGISTER_OP */
	// 	 __u8 sqe_op;      /* IORING_RESTRICTION_SQE_OP */
	// 	 __u8 sqe_flags;   /* IORING_RESTRICTION_SQE_FLAGS_* */
	//  };
	Union1 uint8
	// contains filtered or unexported fields
}

type IoUringRsrcRegister 

type IoUringRsrcRegister struct {
	Nr    uint32
	Flags uint32

	Data uint64 // __aligned_u64
	Tags uint64 // __aligned_u64
	// contains filtered or unexported fields
}

type IoUringRsrcUpdate 

type IoUringRsrcUpdate struct {
	Offset uint32

	Data uint64 // __aligned_u64
	// contains filtered or unexported fields
}

type IoUringRsrcUpdate2 

type IoUringRsrcUpdate2 struct {
	Offset uint32

	Data uint64 // __aligned_u64
	Tags uint64 // __aligned_u64
	Nr   uint32
	// contains filtered or unexported fields
}

type IoUringSq 

type IoUringSq struct {
	Array uint32Array     //ptr arith
	Sqes  ioUringSqeArray //ptr arith

	SqeHead uint32
	SqeTail uint32

	RingSz  uint32
	RingPtr unsafe.Pointer
	// contains filtered or unexported fields
}

type IoUringSqe 

type IoUringSqe struct {
	Opcode IoUringOp /* type of operation for this sqe */
	Flags  uint8     /* IOSQE_ flags */
	IoPrio uint16    /* ioprio for the request */
	Fd     int32     /* file descriptor to do IO on */

	//  union {
	// 	 __u64	off;	/* offset into file */
	// 	 __u64	addr2;
	//  };
	IoUringSqe_Union1

	//  union {
	// 	 __u64	addr;	/* pointer to buffer or iovecs */
	// 	 __u64	splice_off_in;
	//  };
	IoUringSqe_Union2

	Len uint32 /* buffer size or number of iovecs */

	//  union {
	// 	 __kernel_rwf_t	rw_flags;
	// 	 __u32		fsync_flags;
	// 	 __u16		poll_events;	/* compatibility */
	// 	 __u32		poll32_events;	/* word-reversed for BE */
	// 	 __u32		sync_range_flags;
	// 	 __u32		msg_flags;
	// 	 __u32		timeout_flags;
	// 	 __u32		accept_flags;
	// 	 __u32		cancel_flags;
	// 	 __u32		open_flags;
	// 	 __u32		statx_flags;
	// 	 __u32		fadvise_advice;
	// 	 __u32		splice_flags;
	// 	 __u32		rename_flags;
	// 	 __u32		unlink_flags;
	// 	 __u32		hardlink_flags;
	// 	 __u32		xattr_flags;
	//  };
	IoUringSqe_Union3

	UserData UserData /* data to be passed back at completion time */

	/* pack this to avoid bogus arm OABI complaints */
	//  union {
	// 	 /* index into fixed buffers, if used */
	// 	 __u16	buf_index;
	// 	 /* for grouped buffer selection */
	// 	 __u16	buf_group;
	//  } __attribute__((packed));
	IoUringSqe_Union4

	/* personality to use, if used */
	Personality uint16

	//  union {
	// 	 __s32	splice_fd_in;
	// 	 __u32	file_index;
	//  };
	IoUringSqe_Union5

	Addr3 uint64
	// contains filtered or unexported fields
}

type IoUringSqe_Union1 

type IoUringSqe_Union1 uint64

* IO submission data structure (Submission Queue Entry)

func (*IoUringSqe_Union1) SetAddr2 

func (u *IoUringSqe_Union1) SetAddr2(v uint64)

func (*IoUringSqe_Union1) SetOffset 

func (u *IoUringSqe_Union1) SetOffset(v uint64)

type IoUringSqe_Union2 

type IoUringSqe_Union2 uint64

func (*IoUringSqe_Union2) SetAddr 

func (u *IoUringSqe_Union2) SetAddr(v unsafe.Pointer)

func (*IoUringSqe_Union2) SetAddr_Value 

func (u *IoUringSqe_Union2) SetAddr_Value(v uint64)

func (*IoUringSqe_Union2) SetSpliceOffsetIn 

func (u *IoUringSqe_Union2) SetSpliceOffsetIn(v uint64)

type IoUringSqe_Union3 

type IoUringSqe_Union3 uint32

func (IoUringSqe_Union3) GetOpFlags 

func (u IoUringSqe_Union3) GetOpFlags() uint32

func (*IoUringSqe_Union3) SetAcceptFlags 

func (u *IoUringSqe_Union3) SetAcceptFlags(v uint32)

func (*IoUringSqe_Union3) SetCancelFlags 

func (u *IoUringSqe_Union3) SetCancelFlags(v uint32)

func (*IoUringSqe_Union3) SetFadviseAdvice 

func (u *IoUringSqe_Union3) SetFadviseAdvice(v uint32)

func (*IoUringSqe_Union3) SetHardlinkFlags 

func (u *IoUringSqe_Union3) SetHardlinkFlags(v uint32)

func (*IoUringSqe_Union3) SetMsgFlags 

func (u *IoUringSqe_Union3) SetMsgFlags(v uint32)

func (*IoUringSqe_Union3) SetOpFlags 

func (u *IoUringSqe_Union3) SetOpFlags(v uint32)

func (*IoUringSqe_Union3) SetOpenFlags 

func (u *IoUringSqe_Union3) SetOpenFlags(v uint32)

func (*IoUringSqe_Union3) SetPoll32Events 

func (u *IoUringSqe_Union3) SetPoll32Events(v uint32)

func (*IoUringSqe_Union3) SetPollEvents 

func (u *IoUringSqe_Union3) SetPollEvents(v uint16)

func (*IoUringSqe_Union3) SetRenameFlags 

func (u *IoUringSqe_Union3) SetRenameFlags(v uint32)

func (*IoUringSqe_Union3) SetRwFlags 

func (u *IoUringSqe_Union3) SetRwFlags(v uint32)

func (*IoUringSqe_Union3) SetSpliceFlags 

func (u *IoUringSqe_Union3) SetSpliceFlags(v uint32)

func (*IoUringSqe_Union3) SetStatxFlags 

func (u *IoUringSqe_Union3) SetStatxFlags(v uint32)

func (*IoUringSqe_Union3) SetSyncRangeFlags 

func (u *IoUringSqe_Union3) SetSyncRangeFlags(v uint32)

func (*IoUringSqe_Union3) SetTimeoutFlags 

func (u *IoUringSqe_Union3) SetTimeoutFlags(v uint32)

func (*IoUringSqe_Union3) SetUnlinkFlags 

func (u *IoUringSqe_Union3) SetUnlinkFlags(v uint32)

func (*IoUringSqe_Union3) SetXattrFlags 

func (u *IoUringSqe_Union3) SetXattrFlags(v uint32)

type IoUringSqe_Union4 

type IoUringSqe_Union4 uint16

func (*IoUringSqe_Union4) SetBufGroup 

func (u *IoUringSqe_Union4) SetBufGroup(v uint16)

func (*IoUringSqe_Union4) SetBufIndex 

func (u *IoUringSqe_Union4) SetBufIndex(v uint16)

type IoUringSqe_Union5 

type IoUringSqe_Union5 uint32

func (*IoUringSqe_Union5) SetFileIndex 

func (u *IoUringSqe_Union5) SetFileIndex(v uint32)

func (*IoUringSqe_Union5) SetSpliceFdIn 

func (u *IoUringSqe_Union5) SetSpliceFdIn(v int32)

type Sigset_t 

type Sigset_t struct {
	Val [SIGSET_NWORDS]uint64
}

type UserData 

type UserData [8]byte // uint64

func (UserData) GetUint64 

func (u UserData) GetUint64() uint64

func (UserData) GetUintptr 

func (u UserData) GetUintptr() uintptr

func (UserData) GetUnsafe 

func (u UserData) GetUnsafe() unsafe.Pointer

func (UserData) IsZero 

func (u UserData) IsZero() bool

func (*UserData) SetUint64 

func (u *UserData) SetUint64(v uint64)

func (*UserData) SetUintptr 

func (u *UserData) SetUintptr(v uintptr)

func (*UserData) SetUnsafe 

func (u *UserData) SetUnsafe(ptr unsafe.Pointer)

Source Files

View all Source files

Directories

Path Synopsis
bench
perf

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.