io_uring

Documentation

Index

• Variables
• type CompletionQueue
• type IOUring
  • func New(entries uint, params *iouring_syscall.IOURingParams) (*IOUring, error)
  • func (iour *IOUring) Close() error
  • func (iouring *IOUring) GetCQE(wait bool) (cqe *iouring_syscall.IOUringCQE, err error)
  • func (iouring *IOUring) GetCQEData()
  • func (iouring *IOUring) GetSQE() *iouring_syscall.IOUringSQE
  • func (iouring *IOUring) SetIOPoll()
  • func (iouring *IOUring) SetSQEData(data uint64)
  • func (iouring *IOUring) Submit() (submitted int, err error)
• type SubmissionQueue

Variables

var (
	ErrIOURingClosed = errors.New("iouring closed")

	ErrRequestCanceled     = errors.New("request is canceled")
	ErrRequestNotFound     = errors.New("request is not found")
	ErrRequestCompleted    = errors.New("request has already been completed")
	ErrRequestNotCompleted = errors.New("request is not completed")
	ErrNoRequestCallback   = errors.New("no request callback")

	ErrUnregisteredFile = errors.New("file is unregistered")
)

Types

type CompletionQueue

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

CompletionQueue ...

type IOUring

type IOUring struct {
	Flags uint
	// contains filtered or unexported fields
}

IOUring ...

func New

func New(entries uint, params *iouring_syscall.IOURingParams) (*IOUring, error)

New 新建IoUring

func (*IOUring) Close

func (iour *IOUring) Close() error

Close IOURing

func (*IOUring) GetCQE

func (iouring *IOUring) GetCQE(wait bool) (cqe *iouring_syscall.IOUringCQE, err error)

GetCQE ...

func (*IOUring) GetCQEData

func (iouring *IOUring) GetCQEData()

GetCQEData

func (*IOUring) GetSQE

func (iouring *IOUring) GetSQE() *iouring_syscall.IOUringSQE

GetSQE ...

func (*IOUring) SetIOPoll

func (iouring *IOUring) SetIOPoll()

SetIOPoll ...

func (*IOUring) SetSQEData

func (iouring *IOUring) SetSQEData(data uint64)

SetSQEData ...

func (*IOUring) Submit

func (iouring *IOUring) Submit() (submitted int, err error)

Submit ...

type SubmissionQueue

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

SubmissionQueue ...