Documentation
¶
Overview ¶
Package iouringfs provides a filesystem implementation for IO_URING basing it on anonfs. Currently, we don't support neither IOPOLL nor SQPOLL modes. Thus, user needs to set up IO_URING first with io_uring_setup(2) syscall and then issue submission request using io_uring_enter(2).
Another important note, as of now, we don't support deferred CQE. In other words, the size of the backlogged set of CQE is zero. Whenever, completion queue ring buffer is full, we drop the subsequent completion queue entries.
Index ¶
- func New(ctx context.Context, vfsObj *vfs.VirtualFilesystem, entries uint32, ...) (*vfs.FileDescription, error)
- type FileDescription
- func (fd *FileDescription) ConfigureMMap(ctx context.Context, opts *memmap.MMapOpts) error
- func (fd *FileDescription) ProcessSubmission(t *kernel.Task, sqe *linux.IOUringSqe, flags uint32) *linux.IOUringCqe
- func (fd *FileDescription) ProcessSubmissions(t *kernel.Task, toSubmit uint32, minComplete uint32, flags uint32) (int, error)
- func (fd *FileDescription) Release(ctx context.Context)
- func (fd *FileDescription) StateFields() []string
- func (fd *FileDescription) StateLoad(stateSourceObject state.Source)
- func (fd *FileDescription) StateSave(stateSinkObject state.Sink)
- func (fd *FileDescription) StateTypeName() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(ctx context.Context, vfsObj *vfs.VirtualFilesystem, entries uint32, params *linux.IOUringParams) (*vfs.FileDescription, error)
New creates a new iouring fd.
Types ¶
type FileDescription ¶
type FileDescription struct {
vfs.FileDescriptionDefaultImpl
vfs.DentryMetadataFileDescriptionImpl
vfs.NoLockFD
// contains filtered or unexported fields
}
FileDescription implements vfs.FileDescriptionImpl for file-based IO_URING. It is based on io_rings struct. See io_uring/io_uring.c.
+stateify savable
func (*FileDescription) ConfigureMMap ¶
ConfigureMMap implements vfs.FileDescriptionImpl.ConfigureMMap.
func (*FileDescription) ProcessSubmission ¶
func (fd *FileDescription) ProcessSubmission(t *kernel.Task, sqe *linux.IOUringSqe, flags uint32) *linux.IOUringCqe
ProcessSubmission processes a single submission request.
func (*FileDescription) ProcessSubmissions ¶
func (fd *FileDescription) ProcessSubmissions(t *kernel.Task, toSubmit uint32, minComplete uint32, flags uint32) (int, error)
ProcessSubmissions processes the submission queue. Concurrent calls to ProcessSubmissions serialize, yielding task goroutines with Task.Block since processing can take a long time.
func (*FileDescription) Release ¶
func (fd *FileDescription) Release(ctx context.Context)
Release implements vfs.FileDescriptionImpl.Release.
func (*FileDescription) StateFields ¶
func (fd *FileDescription) StateFields() []string
func (*FileDescription) StateLoad ¶
func (fd *FileDescription) StateLoad(stateSourceObject state.Source)
+checklocksignore
func (*FileDescription) StateSave ¶
func (fd *FileDescription) StateSave(stateSinkObject state.Sink)
+checklocksignore
func (*FileDescription) StateTypeName ¶
func (fd *FileDescription) StateTypeName() string
Source Files