iouring

package
v1.5.4 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2025 License: LGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CQEFBuffer uint32 = 1 << iota
	CQEFMore
	CQEFSockNonempty
	CQEFNotify
)
View Source 
const (
	// FeatSingleMMap
	// 如果设置了该标志，则只需调用一次 mmap(2)，即可映射两个 SQ 和 CQ 环。
	// SQE 仍需单独分配。这样，所需的 mmap(2) 调用次数就从三次减少到两次。自内核 5.4 起可用。
	FeatSingleMMap uint32 = 1 << iota
	// FeatNoDrop
	// 如果设置了这个标志，io_uring 就几乎不会丢弃完成事件。只有当内核内存耗尽时，才会发生丢弃事件，
	// 在这种情况下，你会遇到比丢失事件更严重的问题。
	// 无论如何，你的应用程序和其他程序都可能会被 OOM 杀掉。
	// 如果发生了完成事件，而 CQ 环已满，内核会在内部存储该事件，直到 CQ 环有空间容纳更多条目。
	// 在早期内核中，如果出现这种溢出情况，尝试提交更多 IO 时，如果无法将溢出的事件刷新到 CQ 环，就会出现 -EBUSY 错误值而失败。
	// 如果出现这种情况，应用程序必须从 CQ 环中获取事件，并再次尝试提交。
	// 如果内核内部没有空闲内存来存储事件，那么 cqring 上的溢出值就会增加。
	// 自内核 5.5 起可用。此外，io_uring_enter(2) 还会在下一次休眠等待完成时返回 -EBADR（自内核 5.19 起）。
	FeatNoDrop
	// FeatSubmitStable
	// 如果设置了该标志，应用程序就可以确定，当内核消耗 SQE 时，任何用于异步卸载的数据都已消耗完毕。自内核 5.5 起可用。
	FeatSubmitStable
	// FeatRWCurPos
	// 如果设置了这个标志，应用程序就可以在 IORING_OP_{READV,WRITEV}、IORING_OP_{READ,WRITE}_FIXED 和 IORING_OP_{READ,WRITE} 中指定偏移量 == -1 表示当前文件位置，
	// 其行为与偏移量 == -1 的 preadv2(2) 和 pwritev2(2) 类似。
	// 它将使用（并更新）当前文件位置。
	// 这显然需要注意的是，如果应用程序在运行过程中进行了多次读取或写入，那么最终结果将不尽如人意。
	// 这与线程共享文件描述符并使用当前文件位置进行 IO 的情况类似。自内核 5.6 起可用。
	FeatRWCurPos
	// FeatCurPersonality
	// 如果设置了这个标志，那么 io_uring 将保证同步和异步执行请求时，都使用调用 io_uring_enter(2) 对请求进行排队的任务的凭据。
	// 如果未设置该标记，则会使用最初注册 io_uring 的任务的凭据发出请求。
	// 如果只有一个任务在使用一个环，那么这个标志并不重要，因为凭据始终是相同的。
	// 请注意，这是默认行为，任务仍然可以通过 io_uring_register(2) 以 IORING_REGISTER_PERSONALITY 注册不同的个性，并在 sqe 中指定要使用的个性。
	// 自内核 5.6 起可用。
	FeatCurPersonality
	// FeatFastPoll
	// 如果设置了这个标志，那么 io_uring 将支持使用内部轮询机制来驱动数据/空间就绪。
	// 这意味着无法读取或写入文件数据的请求不再需要交由异步线程处理，而是会在文件就绪时开始运行。
	// 这类似于在用户空间进行轮询 + 读/写操作，但无需这样做。
	// 如果设置了该标记，等待空间/数据的请求就不会阻塞线程，从而减少了资源消耗。自内核 5.7 起可用。
	FeatFastPoll
	// FeatPoll32Bits
	// 如果设置了该标志，IORING_OP_POLL_ADD 命令将接受全部 32 位的基于 epoll 的标志。
	// 最值得注意的是 EPOLLEXCLUSIVE，它允许独占（唤醒单个等待者）行为。自内核 5.9 起可用。
	FeatPoll32Bits
	// FeatSQPollNonfixed
	// 如果设置了该标志，IORING_SETUP_SQPOLL 功能就不再需要使用固定文件。任何普通文件描述符都可用于 IO 命令，无需注册。
	// 自内核 5.11 起可用。
	FeatSQPollNonfixed
	// FeatExtArg
	// 如果设置了这个标志，io_uring_enter(2) 系统调用就支持传递一个扩展参数，而不仅仅是早期内核的 sigset_t。
	// 这个扩展参数的类型是 struct io_uring_getevents_arg，允许调用者同时传递 sigset_t 和超时参数，以等待事件发生。
	// 结构布局如下
	// struct io_uring_getevents_arg {
	//
	//
	//    __u64 sigmask；
	//
	//
	//    __u32 sigmask_sz；
	//
	//
	//    __u32 pad；
	//
	//
	//    __u64 ts；
	//};
	//如果在 enter 系统调用的标志中设置了 IORING_ENTER_EXT_ARG，则必须传入指向该结构的指针。自内核 5.11 起可用。
	FeatExtArg
	// FeatNativeWorkers
	// 如果设置了这个标志，那么 io_uring 将使用本地 Worker 作为异步助手。
	// 以前的内核使用的内核线程会假定原始 io_uring 拥有任务的身份，但以后的内核会主动创建看起来更像普通进程的线程。
	// 自内核 5.12 起可用。
	FeatNativeWorkers
	// FeatRsrcTags
	// 如果设置了这个标志，那么 io_uring 将支持与固定文件和缓冲区相关的各种功能。
	// 尤其是，它表明已注册的缓冲区可以就地更新，而在此之前，必须先取消注册整个缓冲区。自内核 5.13 起可用。
	FeatRsrcTags
	// FeatCQESkip
	// 如果设置了该标志，io_uring 就支持在提交的 SQE 中设置 IOSQE_CQE_SKIP_SUCCESS，表明如果正常执行，就不会为该 SQE 生成 CQE。
	// 如果在处理 SQE 时发生错误，仍会生成带有相应错误值的 CQE。自内核 5.17 起可用。
	FeatCQESkip
	// FeatLinkedFile
	// 如果设置了这个标志，那么 io_uring 将支持为有依赖关系的 SQE 合理分配文件。
	// 例如，如果使用 IOSQE_IO_LINK 提交了一连串 SQE，那么没有该标志的内核将为每个链接预先准备文件。
	// 如果前一个链接打开了一个已知索引的文件，例如使用直接描述符打开或接受，那么文件分配就需要在执行该 SQE 后进行。
	// 如果设置了该标志，内核将推迟文件分配，直到开始执行给定请求。自内核 5.17 起可用。
	FeatLinkedFile
	// FeatRegRegRing
	// 如果设置了该标志，则 io_uring 支持通过 IORING_REGISTER_USE_REGISTERED_RING，使用注册环 fd 调用 io_uring_register(2)。自内核 6.3 起可用。
	FeatRegRegRing
	FeatRecvSendBundle
	// FeatMinTimeout
	// 如果设置了该标志，则 io_uring 支持传递最小批处理等待超时。详情请参见 io_uring_submit_and_wait_min_timeout(3) 。
	FeatMinTimeout
)
View Source 
const (
	// SetupIOPoll
	// 执行繁忙等待 I/O 完成，而不是通过异步 IRQ（中断请求）获取通知。文件系统（如有）和块设备必须支持轮询，这样才能正常工作。
	// 忙时（Busy-waiting）可提供较低的延迟，但可能比中断驱动的 I/O 消耗更多的 CPU 资源。
	// 目前，该功能仅适用于使用 O_DIRECT 标志打开的文件描述符。
	// 向轮询上下文提交读或写操作时，应用程序必须调用 io_uring_enter(2) 来轮询 CQ 环上的完成情况。在 io_uring 实例上混合匹配轮询和非轮询 I/O 是非法的。
	// 目前这只适用于存储设备，而且存储设备必须配置为轮询。如何配置取决于相关设备的类型。
	// 对于 NVMe 设备，必须加载 nvme 驱动程序，并将 poll_queues 参数设置为所需的轮询队列数。
	// 如果轮询队列的数量少于在线 CPU 线程的数量，系统中的 CPU 将适当共享轮询队列。
	SetupIOPoll uint32 = 1 << iota
	// SetupSQPoll
	// 它会使用很多cpu资源。
	// 指定该标志后，将创建一个内核线程来执行提交队列轮询。以这种方式配置的 io_uring 实例能让应用程序在不切换内核上下文的情况下发出 I/O。
	// 通过使用提交队列填写新的提交队列条目，并观察完成队列上的完成情况，应用程序可以在不执行单个系统调用的情况下提交和获取 I/O。
	// 如果内核线程空闲时间超过 sq_thread_idle 毫秒，就会设置结构 io_sq_ring 的 flags 字段中的 IORING_SQ_NEED_WAKEUP 位。
	// 出现这种情况时，应用程序必须调用 io_uring_enter(2) 来唤醒内核线程。
	// 如果 I/O 一直处于繁忙状态，内核线程将永远不会休眠。使用此功能的应用程序需要用以下代码序列来保护 io_uring_enter(2) 调用：
	// unsigned flags = atomic_load_relaxed(sq_ring->flags);
	// if flags & IORING_SQ_NEED_WAKEUP {
	//    io_uring_enter(fd, 0, 0, IORING_ENTER_SQ_WAKEUP);
	// }
	// 其中，sq_ring 是使用下述结构 io_sqring_offsets 设置的提交队列环。
	//
	// 请注意，在使用 IORING_SETUP_SQPOLL 进行环形设置时，千万不要直接调用 io_uring_enter(2) 系统调用。
	// 这通常由 liburing 的 io_uring_submit(3) 函数负责。它会自动判断你是否在使用轮询模式，并在你的程序需要调用 io_uring_enter(2) 时进行处理，无需你费心。
	// 在 Linux 内核 5.11 版本之前，要成功使用这一功能，应用程序必须使用 IORING_REGISTER_FILES 操作码通过 io_uring_register(2) 注册一组用于 IO 的文件。
	// 否则，提交的 IO 将出现 EBADF 错误。可以通过 IORING_FEAT_SQPOLL_NONFIXED 功能标志检测该功能是否存在。
	// 在 5.11 及更高版本中，使用此功能不再需要注册文件。
	// 如果用户具有 CAP_SYS_NICE 功能，5.11 还允许以非 root 身份使用此功能。
	// 在 5.13 中，这一要求也被放宽，在较新的内核中，SQPOLL 不需要特殊权限。
	// 某些比 5.13 版本更早的稳定内核也可能支持非特权 SQPOLL。
	SetupSQPoll
	// SetupSQAff
	// 如果指定了这个标志，那么轮询线程将绑定到结构 io_uring_params 的 sq_thread_cpu 字段中设置的 cpu。
	// 该标志只有在指定 IORING_SETUP_SQPOLL 时才有意义。
	// 当 cgroup 设置 cpuset.cpus 发生变化时（通常是在容器环境中），绑定的 cpu 集也会发生变化。
	SetupSQAff
	// SetupCQSize
	// 使用 struct io_uring_params.cq_entries 条目创建完成队列。值必须大于条目数，并可四舍五入为下一个 2 的幂次。
	SetupCQSize
	// SetupClamp
	// 如果指定了该标志，且条目数超过 IORING_MAX_ENTRIES，那么条目数将被箝位在 IORING_MAX_ENTRIES。
	// 如果设置了标志 IORING_SETUP_CQSIZE，且 struct io_uring_params.cq_entries 的值超过了 IORING_MAX_CQ_ENTRIES，则将以 IORING_MAX_CQ_ENTRIES 的值箝位。
	SetupClamp
	// SetupAttachWQ
	// 设置该标志时，应同时将 struct io_uring_params.wq_fd 设置为现有的 io_uring ring 文件描述符。
	// 设置后，创建的 io_uring 实例将共享指定 io_uring ring 的异步工作线程后端，而不是创建一个新的独立线程池。
	// 此外，如果设置了 IORING_SETUP_SQPOLL，还将共享 sq 轮询线程。
	SetupAttachWQ
	// SetupRDisabled
	// 如果指定了该标记，io_uring 环将处于禁用状态。在这种状态下，可以注册限制，但不允许提交。有关如何启用环的详细信息，请参见 io_uring_register(2)。自 5.10 版起可用。
	SetupRDisabled
	// SetupSubmitAll
	// 通常情况下，如果其中一个请求出现错误，io_uring 就会停止提交一批请求。
	// 如果一个请求在提交过程中出错，这可能会导致提交的请求少于预期。
	// 如果在创建环时使用了此标记，那么即使在提交请求时遇到错误，io_uring_enter(2) 也会继续提交请求。
	// 无论在创建环时是否设置了此标记，都会为出错的请求发布 CQE，唯一的区别在于当发现错误时，提交序列是停止还是继续。
	// 自 5.18 版起可用。
	SetupSubmitAll
	// SetupCoopTaskRun
	// 默认情况下，当有完成事件发生时，io_uring 会中断在用户空间运行的任务。
	// 这是为了确保完成任务及时运行。
	// 对于很多用例来说，这样做有些矫枉过正，会导致性能下降，包括用于中断的处理器间中断、内核/用户转换、对任务用户空间活动的无谓中断，以及如果完成事件来得太快，批处理能力下降。
	// 大多数应用程序不需要强制中断，因为事件会在任何内核/用户转换时得到处理。
	// 例外情况是，应用程序使用多个线程在同一环上运行，在这种情况下，等待完成的应用程序并不是提交完成的应用程序。
	// 对于大多数其他使用情况，设置此标志将提高性能。自 5.19 版起可用。
	SetupCoopTaskRun
	// SetupTaskRunFlag
	// 与 IORING_SETUP_COOP_TASKRUN 结合使用，它提供了一个标志 IORING_SQ_TASKRUN，
	// 每当有应该处理的完成等待时，它就会在 SQ 环标志中被设置。即使在执行 io_uring_peek_cqe(3) 时，
	// uring 也会检查该标志，并进入内核处理它们，应用程序也可以这样做。
	// 这使得 IORING_SETUP_TASKRUN_FLAG 可以安全使用，即使应用程序依赖于 CQ 环上的偷看式操作来查看是否有任何待收获。自 5.19 版起可用。
	SetupTaskRunFlag
	// SetupSQE128
	// 如果设置了该选项，io_uring 将使用 128 字节的 SQE，而不是正常的 64 字节大小的 SQE。
	// 这是使用某些请求类型的要求，截至 5.19 版，只有用于 NVMe 直通的 IORING_OP_URING_CMD 直通命令需要使用此功能。自 5.19 版起可用。
	SetupSQE128
	// SetupCQE32
	// 如果设置了该选项，io_uring 将使用 32 字节的 CQE，而非通常的 16 字节大小。
	// 这是使用某些请求类型的要求，截至 5.19 版，只有用于 NVMe 直通的 IORING_OP_URING_CMD 直通命令需要使用此功能。自 5.19 版起可用。
	SetupCQE32
	// SetupSingleIssuer
	// 提示内核只有一个任务（或线程）提交请求，用于内部优化。
	// 提交任务要么是创建环的任务，要么是通过 io_uring_register(2) 启用环的任务（如果指定了 IORING_SETUP_R_DISABLED）。
	// 内核会强制执行这一规则，如果违反限制，会以 -EEXIST 失败请求。
	// 需要注意的是，当设置了 IORING_SETUP_SQPOLL 时，轮询任务将被视为代表用户空间完成所有提交工作，
	// 因此无论有多少用户空间任务执行 io_uring_enter(2)，轮询任务都会遵守该规则。
	// 自 6.0 版起可用。
	SetupSingleIssuer
	// SetupDeferTaskRun
	// 默认情况下，io_uring 会在任何系统调用或线程中断结束时处理所有未完成的工作。这可能会延迟应用程序取得其他进展。
	// 设置该标志将提示 io_uring 将工作推迟到设置了 IORING_ENTER_GETEVENTS 标志的 io_uring_enter(2) 调用。
	// 这样，应用程序就可以在处理完成之前请求运行工作。
	// 该标志要求设置 IORING_SETUP_SINGLE_ISSUER 标志，并强制要求从提交请求的同一线程调用 io_uring_enter(2)。
	// 请注意，如果设置了该标记，应用程序就有责任定期触发工作（例如通过任何 CQE 等待函数），否则可能无法交付完成。自 6.1 版起可用。
	SetupDeferTaskRun
	// SetupNoMmap
	// 默认情况下，io_uring 会分配内核内存，调用者必须随后使用 mmap(2)。
	// 如果设置了该标记，io_uring 将使用调用者分配的缓冲区；p->cq_off.user_addr 必须指向 sq/cq ring 的内存，p->sq_off.user_addr 必须指向 sqes 的内存。
	// 每次分配的内存必须是连续的。通常情况下，调用者应使用 mmap(2) 分配大页面来分配这些内存。
	// 如果设置了此标记，那么随后尝试 mmap(2) io_uring 文件描述符的操作将失败。自 6.5 版起可用。
	SetupNoMmap
	// SetupRegisteredFdOnly
	// 如果设置了这个标志，io_uring 将注册环形文件描述符，并返回已注册的描述符索引，而不会分配一个未注册的文件描述符。
	// 调用者在调用 io_uring_register(2) 时需要使用 IORING_REGISTER_USE_REGISTERED_RING。
	// 该标记只有在与 IORING_SETUP_NO_MMAP 同时使用时才有意义，后者也需要设置。自 6.5 版起可用。
	SetupRegisteredFdOnly
	// SetupNoSQArray
	// 如果设置了该标志，提交队列中的条目将按顺序提交，并在到达队列末尾后绕到第一个条目。
	// 换句话说，将不再通过提交条目数组进行间接处理，而是直接通过提交队列尾部和它所代表的索引范围（队列大小的模数）对队列进行索引。
	// 随后，用户不应映射提交队列条目数组，结构 io_sqring_offsets 中的相应偏移量将被设置为零。
	// 自 6.6 版起可用。
	SetupNoSQArray
	// SetupHybridIOPoll
	// 此标志必须与IORING_SETUP_IOPOLL标志一起使用。
	// 混合io轮询是基于iopoll的一项功能，它与严格轮询的不同之处在于，在进行完成侧轮询之前，它会延迟一点，以避免浪费太多的CPU资源。与IOPOLL一样，它要求设备支持轮询。
	SetupHybridIOPoll
)
View Source 
const (
	MaxEntries     = 32768
	DefaultEntries = MaxEntries / 2
)
View Source 
const (
	EnterGetEvents uint32 = 1 << iota
	EnterSQWakeup
	EnterSQWait
	EnterExtArg
	EnterRegisteredRing
)
View Source 
const (
	RegisterBuffers uint32 = iota
	UnregisterBuffers
	RegisterFiles
	UnregisterFiles
	RegisterEventFd
	UnregisterEventFd
	RegisterFilesUpdate
	RegisterEventFDAsync
	RegisterProbe
	RegisterPersonality
	UnregisterPersonality
	RegisterRestrictions
	RegisterEnableRings
	RegisterFiles2
	RegisterFilesUpdate2
	RegisterBuffers2
	RegisterBuffersUpdate
	RegisterIOWQAff
	UnregisterIOWQAff
	RegisterIOWQMaxWorkers
	RegisterRingFDs
	UnregisterRingFDs
	RegisterPbufRing
	UnregisterPbufRing
	RegisterSyncCancel
	RegisterFileAllocRange
	RegisterLast
	RegisterUseRegisteredRing = 1 << 31
)
View Source 
const (
	RestrictionRegisterOp uint32 = iota
	RestrictionSQEOp
	RestrictionSQEFlagsAllowed
	RestrictionSQEFlagsRequired
	RestrictionLast
)
View Source 
const (
	IOWQBound uint = iota
	IOWQUnbound
)
View Source 
const (
	OpNop uint8 = iota
	OpReadv
	OpWritev
	OpFsync
	OpReadFixed
	OpWriteFixed
	OpPollAdd
	OpPollRemove
	OpSyncFileRange
	OpSendmsg
	OpRecvmsg
	OpTimeout
	OpTimeoutRemove
	OpAccept
	OpAsyncCancel
	OpLinkTimeout
	OpConnect
	OpFallocate
	OpOpenat
	OpClose
	OpFilesUpdate
	OpStatx
	OpRead
	OpWrite
	OpFadvise
	OpMadvise
	OpSend
	OpRecv
	OpOpenat2
	OpEpollCtl
	OpSplice
	OpProvideBuffers
	OpRemoveBuffers
	OpTee
	OpShutdown
	OpRenameat
	OpUnlinkat
	OpMkdirat
	OpSymlinkat
	OpLinkat
	OpMsgRing
	OpFsetxattr
	OpSetxattr
	OpFgetxattr
	OpGetxattr
	OpSocket
	OpUringCmd
	OpSendZC
	OpSendMsgZC
	OpReadMultishot
	OpWaitId
	OpFutexWait
	OpFutexWake
	OpFutexWaitv
	OPFixedFdInstall
	OpFtuncate
	OpBind
	OpListen
	OpRecvZC
	OpEpollWait
	OpReadvFixed
	OpWritevFixed
	OpLast
)
View Source 
const (
	TimeoutAbs uint32 = 1 << iota
	TimeoutUpdate
	TimeoutBoottime
	TimeoutRealtime
	LinkTimeoutUpdate
	TimeoutETimeSuccess
	TimeoutMultishot
	TimeoutClockMask  = TimeoutBoottime | TimeoutRealtime
	TimeoutUpdateMask = TimeoutUpdate | LinkTimeoutUpdate
)
View Source 
const (
	PollAddMulti uint32 = 1 << iota
	PollUpdateEvents
	PollUpdateUserData
	PollAddLevel
)
View Source 
const (
	AsyncCancelAll uint32 = 1 << iota
	AsyncCancelFd
	AsyncCancelAny
	AsyncCancelFdFixed
)
View Source 
const (
	RecvsendPollFirst uint16 = 1 << iota
	RecvMultishot
	RecvsendFixedBuf
	SendZCReportUsage
)
View Source 
const (
	MsgData uint32 = iota
	MsgSendFd
)
View Source 
const (
	MsgRingCQESkip uint32 = 1 << iota
	MsgRingFlagsPass
)
View Source 
const (
	SocketUringOpSiocinq = iota
	SocketUringOpSiocoutq
)
View Source 
const (
	SQEFixedFile uint8 = 1 << iota
	SQEIODrain
	SQEIOLink
	SQEIOHardlink
	SQEAsync
	SQEBufferSelect
	SQECQESkipSuccess
)
View Source 
const (
	SQNeedWakeup uint32 = 1 << iota
	SQCQOverflow
	SQTaskRun
)
View Source 
const (
	AcceptMultishot uint16 = 1 << iota
)
View Source 
const CQEBufferShift uint32 = 16
View Source 
const CQEventFdDisabled uint32 = 1 << 0
View Source 
const FileIndexAlloc uint32 = 4294967295
View Source 
const FsyncDatasync uint32 = 1 << 0
View Source 
const NotifyUsageZCCopied uint32 = 1 << 31
View Source 
const PbufRingMMap = 1
View Source 
const RegisterFilesSkip int = -2
View Source 
const RsrcRegisterSparse uint32 = 1 << iota
View Source 
const SpliceFFdInFixed uint32 = 1 << 31
View Source 
const UringCmdFixed uint32 = 1 << 0

Variables

This section is empty.

Functions

func BufferRingMask 

func BufferRingMask(entries uint32) int

func MLockSize 

func MLockSize(entries, flags uint32) (uint64, error)

func MLockSizeParams 

func MLockSizeParams(entries uint32, p *Params) (uint64, error)

func ParseSetupFlags added in v1.2.0 

func ParseSetupFlags(s string) uint32

func RoundupPow2 added in v0.7.0 

func RoundupPow2(n uint32) uint32

Types

type BufReg 

type BufReg struct {
	RingAddr    uint64
	RingEntries uint32
	Bgid        uint16
	Pad         uint16
	Resv        [3]uint64
}

type BufferAndRing 

type BufferAndRing struct {
	Addr uint64
	Len  uint32
	Bid  uint16
	Tail uint16
}

func (*BufferAndRing) BufRingAdd 

func (br *BufferAndRing) BufRingAdd(addr uintptr, length uint32, bid uint16, mask, bufOffset int)

func (*BufferAndRing) BufRingAdvance 

func (br *BufferAndRing) BufRingAdvance(count int)

func (*BufferAndRing) BufRingInit 

func (br *BufferAndRing) BufRingInit()

type CQRingOffsets 

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

type CompletionQueue 

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

type CompletionQueueEvent 

type CompletionQueueEvent struct {
	UserData uint64
	Res      int32
	Flags    uint32
}

func (*CompletionQueueEvent) GetData 

func (c *CompletionQueueEvent) GetData() unsafe.Pointer

type FileIndexRange 

type FileIndexRange struct {
	Off  uint32
	Len  uint32
	Resv uint64
}

type FilesUpdate 

type FilesUpdate struct {
	Offset uint32
	Resv   uint32
	Fds    uint64
}

type GetEventsArg 

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

type Option added in v1.2.0 

type Option func(*Options) error

func WithAttachWQFd added in v1.5.0 

func WithAttachWQFd(fd uint32) Option

func WithEntries added in v1.2.0 

func WithEntries(entries uint32) Option

func WithFlags added in v1.2.0 

func WithFlags(flags uint32) Option

WithFlags see https://manpages.debian.org/unstable/liburing-dev/io_uring_setup.2.en.html

func WithMemoryBuffer added in v1.2.0 

func WithMemoryBuffer(memoryBuffer []byte) Option

func WithSQThreadCPU added in v1.2.0 

func WithSQThreadCPU(cpuId uint32) Option

func WithSQThreadIdle added in v1.2.0 

func WithSQThreadIdle(n uint32) Option

type Options added in v1.2.0 

type Options struct {
	Entries      uint32
	Flags        uint32
	SQThreadCPU  uint32
	SQThreadIdle uint32
	WQFd         uint32
	MemoryBuffer []byte
}

type Params 

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

func (*Params) Validate added in v1.5.0 

func (params *Params) Validate() error

type Probe 

type Probe struct {
	LastOp uint8
	OpsLen uint8
	Res    uint16
	Res2   [3]uint32
	Ops    [probeOpsSize]ProbeOp
}

func GetProbe 

func GetProbe() (*Probe, error)

func (*Probe) IsSupported 

func (p *Probe) IsSupported(op uint8) bool

type ProbeOp 

type ProbeOp struct {
	Op    uint8
	Res   uint8
	Flags uint16
	Res2  uint32
}

type RecvmsgOut 

type RecvmsgOut struct {
	Namelen    uint32
	ControlLen uint32
	PayloadLen uint32
	Flags      uint32
}

func RecvmsgValidate 

func RecvmsgValidate(buf unsafe.Pointer, bufLen int, msgh *syscall.Msghdr) *RecvmsgOut

func (*RecvmsgOut) CmsgFirsthdr 

func (o *RecvmsgOut) CmsgFirsthdr(msgh *syscall.Msghdr) *syscall.Cmsghdr

func (*RecvmsgOut) CmsgNexthdr 

func (o *RecvmsgOut) CmsgNexthdr(msgh *syscall.Msghdr, cmsg *syscall.Cmsghdr) *syscall.Cmsghdr

func (*RecvmsgOut) Name 

func (o *RecvmsgOut) Name() unsafe.Pointer

func (*RecvmsgOut) Payload 

func (o *RecvmsgOut) Payload(msgh *syscall.Msghdr) unsafe.Pointer

func (*RecvmsgOut) PayloadLength 

func (o *RecvmsgOut) PayloadLength(bufLen int, msgh *syscall.Msghdr) uint32

type Restriction 

type Restriction struct {
	OpCode  uint16
	OpFlags uint8
	Resv    uint8
	Resv2   [3]uint32
}

type Ring 

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

func New 

func New(options ...Option) (ring *Ring, err error)

func (*Ring) BufRingCQAdvance 

func (ring *Ring) BufRingCQAdvance(br *BufferAndRing, count int)

func (*Ring) CQAdvance 

func (ring *Ring) CQAdvance(numberOfCQEs uint32)

func (*Ring) CQESeen 

func (ring *Ring) CQESeen(event *CompletionQueueEvent)

func (*Ring) CQEntries 

func (ring *Ring) CQEntries() uint32

func (*Ring) CQEventFdEnabled 

func (ring *Ring) CQEventFdEnabled() bool

func (*Ring) CQEventFdToggle 

func (ring *Ring) CQEventFdToggle(enabled bool) error

func (*Ring) CQHasOverflow 

func (ring *Ring) CQHasOverflow() bool

func (*Ring) CQReady 

func (ring *Ring) CQReady() uint32

func (*Ring) Close 

func (ring *Ring) Close() (err error)

func (*Ring) CloseFd 

func (ring *Ring) CloseFd() error

func (*Ring) DontFork 

func (ring *Ring) DontFork() error

func (*Ring) EnableRings 

func (ring *Ring) EnableRings() (uint, error)

func (*Ring) Enter 

func (ring *Ring) Enter(submitted uint32, waitNr uint32, flags uint32, sig unsafe.Pointer) (uint, error)

func (*Ring) Enter2 

func (ring *Ring) Enter2(submitted uint32, waitNr uint32, flags uint32, sig unsafe.Pointer, size int) (uint, error)

func (*Ring) Fd 

func (ring *Ring) Fd() int

func (*Ring) Features added in v1.5.0 

func (ring *Ring) Features() uint32

func (*Ring) Flags added in v1.5.0 

func (ring *Ring) Flags() uint32

func (*Ring) ForEachCQE 

func (ring *Ring) ForEachCQE(callback func(cqe *CompletionQueueEvent))

func (*Ring) GetEvents 

func (ring *Ring) GetEvents() (uint, error)

func (*Ring) GetSQE 

func (ring *Ring) GetSQE() *SubmissionQueueEntry

func (*Ring) PeekBatchCQE 

func (ring *Ring) PeekBatchCQE(cqes []*CompletionQueueEvent) uint32

func (*Ring) PeekCQE 

func (ring *Ring) PeekCQE() (*CompletionQueueEvent, error)

func (*Ring) Probe 

func (ring *Ring) Probe() (*Probe, error)

func (*Ring) Register 

func (ring *Ring) Register(fd int, opcode uint32, arg unsafe.Pointer, nrArgs uint32) (uint, syscall.Errno)

func (*Ring) RegisterBufferRing 

func (ring *Ring) RegisterBufferRing(reg *BufReg, _ uint32) (uint, error)

func (*Ring) RegisterBuffers 

func (ring *Ring) RegisterBuffers(iovecs []syscall.Iovec) (uint, error)

func (*Ring) RegisterBuffersSparse 

func (ring *Ring) RegisterBuffersSparse(nr uint32) (uint, error)

func (*Ring) RegisterBuffersTags 

func (ring *Ring) RegisterBuffersTags(iovecs []syscall.Iovec, tags []uint64) (uint, error)

func (*Ring) RegisterBuffersUpdateTag 

func (ring *Ring) RegisterBuffersUpdateTag(off uint32, iovecs []syscall.Iovec, tags *uint64, nr uint32) (uint, error)

func (*Ring) RegisterEventFd 

func (ring *Ring) RegisterEventFd(fd int) (uint, error)

func (*Ring) RegisterEventFdAsync 

func (ring *Ring) RegisterEventFdAsync(fd int) (uint, error)

func (*Ring) RegisterFileAllocRange 

func (ring *Ring) RegisterFileAllocRange(off, length uint32) (uint, error)

func (*Ring) RegisterFiles 

func (ring *Ring) RegisterFiles(files []int) (uint, error)

func (*Ring) RegisterFilesSparse 

func (ring *Ring) RegisterFilesSparse(nr uint32) (uint, error)

func (*Ring) RegisterFilesTags 

func (ring *Ring) RegisterFilesTags(files []int, tags []uint64) (uint, error)

func (*Ring) RegisterFilesUpdate 

func (ring *Ring) RegisterFilesUpdate(off uint, files []int) (uint, error)

func (*Ring) RegisterFilesUpdateTag 

func (ring *Ring) RegisterFilesUpdateTag(off uint, files []int, tags []uint64) (uint, error)

func (*Ring) RegisterIOWQAff 

func (ring *Ring) RegisterIOWQAff(cpusz uint64, mask *unix.CPUSet) error

func (*Ring) RegisterIOWQMaxWorkers 

func (ring *Ring) RegisterIOWQMaxWorkers(val []uint) (uint, error)

func (*Ring) RegisterPersonality 

func (ring *Ring) RegisterPersonality() (uint, error)

func (*Ring) RegisterProbe 

func (ring *Ring) RegisterProbe(probe *Probe, nrOps int) (uint, error)

func (*Ring) RegisterRestrictions 

func (ring *Ring) RegisterRestrictions(res []Restriction) (uint, error)

func (*Ring) RegisterRingFd 

func (ring *Ring) RegisterRingFd() (uint, error)

func (*Ring) RegisterSyncCancel 

func (ring *Ring) RegisterSyncCancel(reg *SyncCancelReg) (uint, error)

func (*Ring) SQEntries 

func (ring *Ring) SQEntries() uint32

func (*Ring) SQReady 

func (ring *Ring) SQReady() uint32

func (*Ring) SQRingWait 

func (ring *Ring) SQRingWait() (uint, error)

func (*Ring) SQSpaceLeft 

func (ring *Ring) SQSpaceLeft() uint32

func (*Ring) SetupBufRing 

func (ring *Ring) SetupBufRing(entries uint32, bgid int, flags uint32) (*BufferAndRing, error)

func (*Ring) Submit 

func (ring *Ring) Submit() (uint, error)

func (*Ring) SubmitAndGetEvents 

func (ring *Ring) SubmitAndGetEvents() (uint, error)

func (*Ring) SubmitAndWait 

func (ring *Ring) SubmitAndWait(waitNr uint32) (uint, error)

func (*Ring) SubmitAndWaitTimeout 

func (ring *Ring) SubmitAndWaitTimeout(waitNr uint32, ts *syscall.Timespec, sigmask *unix.Sigset_t) (*CompletionQueueEvent, error)

func (*Ring) UnregisterBufferRing 

func (ring *Ring) UnregisterBufferRing(bgid int) (uint, error)

func (*Ring) UnregisterBuffers 

func (ring *Ring) UnregisterBuffers() (uint, error)

func (*Ring) UnregisterEventFd 

func (ring *Ring) UnregisterEventFd(fd int) (uint, error)

func (*Ring) UnregisterFiles 

func (ring *Ring) UnregisterFiles() (uint, error)

func (*Ring) UnregisterIOWQAff 

func (ring *Ring) UnregisterIOWQAff() (uint, error)

func (*Ring) UnregisterPersonality 

func (ring *Ring) UnregisterPersonality() (uint, error)

func (*Ring) UnregisterRingFd 

func (ring *Ring) UnregisterRingFd() (uint, error)

func (*Ring) WaitCQE 

func (ring *Ring) WaitCQE() (*CompletionQueueEvent, error)

func (*Ring) WaitCQENr 

func (ring *Ring) WaitCQENr(waitNr uint32) (*CompletionQueueEvent, error)

func (*Ring) WaitCQETimeout 

func (ring *Ring) WaitCQETimeout(ts *syscall.Timespec) (*CompletionQueueEvent, error)

func (*Ring) WaitCQEs 

func (ring *Ring) WaitCQEs(waitNr uint32, ts *syscall.Timespec, sigmask *unix.Sigset_t) (*CompletionQueueEvent, error)

func (*Ring) WaitCQEsNew 

func (ring *Ring) WaitCQEsNew(waitNr uint32, ts *syscall.Timespec, sigmask *unix.Sigset_t) (*CompletionQueueEvent, error)

type RsrcRegister 

type RsrcRegister struct {
	Nr    uint32
	Flags uint32
	Resv2 uint64
	Data  uint64
	Tags  uint64
}

type RsrcUpdate 

type RsrcUpdate struct {
	Offset uint32
	Resv   uint32
	Data   uint64
}

type RsrcUpdate2 

type RsrcUpdate2 struct {
	Offset uint32
	Resv   uint32
	Data   uint64
	Tags   uint64
	Nr     uint32
	Resv2  uint32
}

type SQRingOffsets 

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

type SubmissionQueue 

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

type SubmissionQueueEntry 

type SubmissionQueueEntry struct {
	OpCode      uint8
	Flags       uint8
	IoPrio      uint16
	Fd          int32
	Off         uint64
	Addr        uint64
	Len         uint32
	OpcodeFlags uint32
	UserData    uint64
	BufIG       uint16
	Personality uint16
	SpliceFdIn  int32
	Addr3       uint64
	// contains filtered or unexported fields
}

func (*SubmissionQueueEntry) PrepareAccept 

func (entry *SubmissionQueueEntry) PrepareAccept(fd int, addr *syscall.RawSockaddrAny, addrLen uint64, flags uint32)

func (*SubmissionQueueEntry) PrepareAcceptDirect 

func (entry *SubmissionQueueEntry) PrepareAcceptDirect(fd int, addr *syscall.RawSockaddrAny, addrLen uint64, flags uint32, fileIndex uint32)

func (*SubmissionQueueEntry) PrepareBind added in v1.5.3 

func (entry *SubmissionQueueEntry) PrepareBind(fd int, addr *syscall.RawSockaddrAny, addrLen uint64)

func (*SubmissionQueueEntry) PrepareCancel 

func (entry *SubmissionQueueEntry) PrepareCancel(userData uintptr, flags uint32)

func (*SubmissionQueueEntry) PrepareCancel64 

func (entry *SubmissionQueueEntry) PrepareCancel64(userData uint64, flags uint32)

func (*SubmissionQueueEntry) PrepareCancelALL added in v1.5.3 

func (entry *SubmissionQueueEntry) PrepareCancelALL()

func (*SubmissionQueueEntry) PrepareCancelFd 

func (entry *SubmissionQueueEntry) PrepareCancelFd(fd int, flags uint32)

func (*SubmissionQueueEntry) PrepareClose 

func (entry *SubmissionQueueEntry) PrepareClose(fd int)

func (*SubmissionQueueEntry) PrepareCloseDirect 

func (entry *SubmissionQueueEntry) PrepareCloseDirect(fileIndex uint32)

func (*SubmissionQueueEntry) PrepareConnect 

func (entry *SubmissionQueueEntry) PrepareConnect(fd int, addr *syscall.RawSockaddrAny, addrLen uint64)

func (*SubmissionQueueEntry) PrepareFadvise 

func (entry *SubmissionQueueEntry) PrepareFadvise(fd int, offset uint64, length int, advise uint32)

func (*SubmissionQueueEntry) PrepareFallocate 

func (entry *SubmissionQueueEntry) PrepareFallocate(fd int, mode int, offset, length uint64)

func (*SubmissionQueueEntry) PrepareFgetxattr 

func (entry *SubmissionQueueEntry) PrepareFgetxattr(fd int, name, value []byte)

func (*SubmissionQueueEntry) PrepareFilesUpdate 

func (entry *SubmissionQueueEntry) PrepareFilesUpdate(fds []int, offset int)

func (*SubmissionQueueEntry) PrepareFixedFdInstall added in v1.5.3 

func (entry *SubmissionQueueEntry) PrepareFixedFdInstall(fd int, flags uint32)

func (*SubmissionQueueEntry) PrepareFsetxattr 

func (entry *SubmissionQueueEntry) PrepareFsetxattr(fd int, name, value []byte, flags int)

func (*SubmissionQueueEntry) PrepareFsync 

func (entry *SubmissionQueueEntry) PrepareFsync(fd int, flags uint32)

func (*SubmissionQueueEntry) PrepareGetxattr 

func (entry *SubmissionQueueEntry) PrepareGetxattr(name, value, path []byte)
func (entry *SubmissionQueueEntry) PrepareLink(oldPath, newPath []byte, flags int)

func (*SubmissionQueueEntry) PrepareLinkTimeout 

func (entry *SubmissionQueueEntry) PrepareLinkTimeout(duration time.Duration, flags uint32)

func (*SubmissionQueueEntry) PrepareLinkat 

func (entry *SubmissionQueueEntry) PrepareLinkat(oldFd int, oldPath []byte, newFd int, newPath []byte, flags int)

func (*SubmissionQueueEntry) PrepareListen added in v1.5.3 

func (entry *SubmissionQueueEntry) PrepareListen(fd int, backlog uint32)

func (*SubmissionQueueEntry) PrepareMadvise 

func (entry *SubmissionQueueEntry) PrepareMadvise(addr uintptr, length uint, advice int)

func (*SubmissionQueueEntry) PrepareMkdir 

func (entry *SubmissionQueueEntry) PrepareMkdir(path []byte, mode uint32)

func (*SubmissionQueueEntry) PrepareMkdirat 

func (entry *SubmissionQueueEntry) PrepareMkdirat(dfd int, path []byte, mode uint32)

func (*SubmissionQueueEntry) PrepareMsgRing 

func (entry *SubmissionQueueEntry) PrepareMsgRing(fd int, length uint32, data uint64, flags uint32)

func (*SubmissionQueueEntry) PrepareMsgRingCqeFlags 

func (entry *SubmissionQueueEntry) PrepareMsgRingCqeFlags(fd int, length uint32, data uint64, flags, cqeFlags uint32)

func (*SubmissionQueueEntry) PrepareMsgRingFd 

func (entry *SubmissionQueueEntry) PrepareMsgRingFd(fd int, sourceFd int, targetFd int, data uint64, flags uint32)

func (*SubmissionQueueEntry) PrepareMsgRingFdAlloc 

func (entry *SubmissionQueueEntry) PrepareMsgRingFdAlloc(fd int, sourceFd int, data uint64, flags uint32)

func (*SubmissionQueueEntry) PrepareMultishotAccept 

func (entry *SubmissionQueueEntry) PrepareMultishotAccept(fd int, addr *syscall.RawSockaddrAny, addrLen uint64, flags int)

func (*SubmissionQueueEntry) PrepareMultishotAcceptDirect 

func (entry *SubmissionQueueEntry) PrepareMultishotAcceptDirect(fd int, addr *syscall.RawSockaddrAny, addrLen uint64, flags int)

func (*SubmissionQueueEntry) PrepareNop 

func (entry *SubmissionQueueEntry) PrepareNop()

func (*SubmissionQueueEntry) PrepareOpenat 

func (entry *SubmissionQueueEntry) PrepareOpenat(dfd int, path []byte, flags int, mode uint32)

func (*SubmissionQueueEntry) PrepareOpenat2 

func (entry *SubmissionQueueEntry) PrepareOpenat2(dfd int, path []byte, openHow *unix.OpenHow)

func (*SubmissionQueueEntry) PrepareOpenat2Direct 

func (entry *SubmissionQueueEntry) PrepareOpenat2Direct(dfd int, path []byte, openHow *unix.OpenHow, fileIndex uint32)

func (*SubmissionQueueEntry) PrepareOpenatDirect 

func (entry *SubmissionQueueEntry) PrepareOpenatDirect(dfd int, path []byte, flags int, mode uint32, fileIndex uint32)

func (*SubmissionQueueEntry) PreparePollAdd 

func (entry *SubmissionQueueEntry) PreparePollAdd(fd int, pollMask uint32)

func (*SubmissionQueueEntry) PreparePollMultishot 

func (entry *SubmissionQueueEntry) PreparePollMultishot(fd int, pollMask uint32)

func (*SubmissionQueueEntry) PreparePollRemove 

func (entry *SubmissionQueueEntry) PreparePollRemove(userData uint64)

func (*SubmissionQueueEntry) PreparePollUpdate 

func (entry *SubmissionQueueEntry) PreparePollUpdate(oldUserData, newUserData uint64, pollMask, flags uint32)

func (*SubmissionQueueEntry) PrepareProvideBuffers 

func (entry *SubmissionQueueEntry) PrepareProvideBuffers(addr uintptr, length, nr, bgid, bid int)

func (*SubmissionQueueEntry) PrepareRead 

func (entry *SubmissionQueueEntry) PrepareRead(fd int, buf uintptr, nbytes uint32, offset uint64)

func (*SubmissionQueueEntry) PrepareReadFixed 

func (entry *SubmissionQueueEntry) PrepareReadFixed(fd int, buf uintptr, nbytes uint32, offset uint64, bufIndex int)

func (*SubmissionQueueEntry) PrepareReadv 

func (entry *SubmissionQueueEntry) PrepareReadv(fd int, iovecs uintptr, nrVecs uint32, offset uint64)

func (*SubmissionQueueEntry) PrepareReadv2 

func (entry *SubmissionQueueEntry) PrepareReadv2(fd int, iovecs uintptr, nrVecs uint32, offset uint64, flags int)

func (*SubmissionQueueEntry) PrepareRecv 

func (entry *SubmissionQueueEntry) PrepareRecv(fd int, buf uintptr, length uint32, flags int)

func (*SubmissionQueueEntry) PrepareRecvMsg 

func (entry *SubmissionQueueEntry) PrepareRecvMsg(fd int, msg *syscall.Msghdr, flags uint32)

func (*SubmissionQueueEntry) PrepareRecvMsgMultishot 

func (entry *SubmissionQueueEntry) PrepareRecvMsgMultishot(fd int, msg *syscall.Msghdr, flags uint32)

func (*SubmissionQueueEntry) PrepareRecvMultishot 

func (entry *SubmissionQueueEntry) PrepareRecvMultishot(fd int, addr uintptr, length uint32, flags int)

func (*SubmissionQueueEntry) PrepareRemoveBuffers 

func (entry *SubmissionQueueEntry) PrepareRemoveBuffers(nr int, bgid int)

func (*SubmissionQueueEntry) PrepareRename 

func (entry *SubmissionQueueEntry) PrepareRename(oldPath, netPath []byte)

func (*SubmissionQueueEntry) PrepareRenameat 

func (entry *SubmissionQueueEntry) PrepareRenameat(oldFd int, oldPath []byte, newFd int, newPath []byte, flags uint32)

func (*SubmissionQueueEntry) PrepareSend 

func (entry *SubmissionQueueEntry) PrepareSend(fd int, addr uintptr, length uint32, flags int)

func (*SubmissionQueueEntry) PrepareSendMsg 

func (entry *SubmissionQueueEntry) PrepareSendMsg(fd int, msg *syscall.Msghdr, flags uint32)

func (*SubmissionQueueEntry) PrepareSendZC 

func (entry *SubmissionQueueEntry) PrepareSendZC(sockFd int, addr uintptr, length uint32, flags int, zcFlags uint32)

func (*SubmissionQueueEntry) PrepareSendZCFixed 

func (entry *SubmissionQueueEntry) PrepareSendZCFixed(sockFd int, addr uintptr, length uint32, flags int, zcFlags, bufIndex uint32)

func (*SubmissionQueueEntry) PrepareSendmsgZC 

func (entry *SubmissionQueueEntry) PrepareSendmsgZC(fd int, msg *syscall.Msghdr, flags uint32)

func (*SubmissionQueueEntry) PrepareSendto 

func (entry *SubmissionQueueEntry) PrepareSendto(sockFd int, buf []byte, flags int, addr *syscall.Sockaddr, addrLen uint32)

func (*SubmissionQueueEntry) PrepareSetxattr 

func (entry *SubmissionQueueEntry) PrepareSetxattr(name, value, path []byte, flags int, length uint32)

func (*SubmissionQueueEntry) PrepareShutdown 

func (entry *SubmissionQueueEntry) PrepareShutdown(fd, how int)

func (*SubmissionQueueEntry) PrepareSocket 

func (entry *SubmissionQueueEntry) PrepareSocket(domain, socketType, protocol int, flags uint32)

func (*SubmissionQueueEntry) PrepareSocketDirect 

func (entry *SubmissionQueueEntry) PrepareSocketDirect(domain, socketType, protocol int, fileIndex, flags uint32)

func (*SubmissionQueueEntry) PrepareSocketDirectAlloc 

func (entry *SubmissionQueueEntry) PrepareSocketDirectAlloc(domain, socketType, protocol int, flags uint32)

func (*SubmissionQueueEntry) PrepareSplice 

func (entry *SubmissionQueueEntry) PrepareSplice(fdIn int, offIn int64, fdOut int, offOut int64, nbytes, spliceFlags uint32)

func (*SubmissionQueueEntry) PrepareStatx 

func (entry *SubmissionQueueEntry) PrepareStatx(dfd int, path []byte, flags int, mask uint32, statx *unix.Statx_t)
func (entry *SubmissionQueueEntry) PrepareSymlink(target, linkpath []byte)

func (*SubmissionQueueEntry) PrepareSymlinkat 

func (entry *SubmissionQueueEntry) PrepareSymlinkat(target []byte, newdirfd int, linkpath []byte)

func (*SubmissionQueueEntry) PrepareSyncFileRange 

func (entry *SubmissionQueueEntry) PrepareSyncFileRange(fd int, length uint32, offset uint64, flags int)

func (*SubmissionQueueEntry) PrepareTee 

func (entry *SubmissionQueueEntry) PrepareTee(fdIn, fdOut int, nbytes, spliceFlags uint32)

func (*SubmissionQueueEntry) PrepareTimeout 

func (entry *SubmissionQueueEntry) PrepareTimeout(spec *syscall.Timespec, count, flags uint32)

func (*SubmissionQueueEntry) PrepareTimeoutRemove 

func (entry *SubmissionQueueEntry) PrepareTimeoutRemove(duration time.Duration, count uint64, flags uint32)

func (*SubmissionQueueEntry) PrepareTimeoutUpdate 

func (entry *SubmissionQueueEntry) PrepareTimeoutUpdate(duration time.Duration, count uint64, flags uint32)
func (entry *SubmissionQueueEntry) PrepareUnlink(path uintptr, flags int)

func (*SubmissionQueueEntry) PrepareUnlinkat 

func (entry *SubmissionQueueEntry) PrepareUnlinkat(dfd int, path uintptr, flags int)

func (*SubmissionQueueEntry) PrepareWrite 

func (entry *SubmissionQueueEntry) PrepareWrite(fd int, buf uintptr, nbytes uint32, offset uint64)

func (*SubmissionQueueEntry) PrepareWriteFixed 

func (entry *SubmissionQueueEntry) PrepareWriteFixed(
	fd int, vectors uintptr, length uint32, offset uint64, index int)

func (*SubmissionQueueEntry) PrepareWritev 

func (entry *SubmissionQueueEntry) PrepareWritev(
	fd int, iovecs uintptr, nrVecs uint32, offset uint64)

func (*SubmissionQueueEntry) PrepareWritev2 

func (entry *SubmissionQueueEntry) PrepareWritev2(
	fd int, iovecs uintptr, nrVecs uint32, offset uint64, flags int)

func (*SubmissionQueueEntry) SetData 

func (entry *SubmissionQueueEntry) SetData(data unsafe.Pointer)

func (*SubmissionQueueEntry) SetData64 

func (entry *SubmissionQueueEntry) SetData64(data uint64)

func (*SubmissionQueueEntry) SetFlags 

func (entry *SubmissionQueueEntry) SetFlags(flags uint32)

type SyncCancelReg 

type SyncCancelReg struct {
	Addr    uint64
	Fd      int32
	Flags   uint32
	Timeout syscall.Timespec
	Pad     [4]uint64
}

Source Files

View all Source files

Directories

Path Synopsis

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.