URING++
Loading...
Searching...
No Matches
Classes | Public Member Functions | Static Public Member Functions | List of all members
uringpp::event_loop Class Reference
Inheritance diagram for uringpp::event_loop:
Inheritance graph
[legend]
Collaboration diagram for uringpp::event_loop:
Collaboration graph
[legend]

Public Member Functions

 event_loop (unsigned int entries=128, uint32_t flags=0, int wq_fd=-1, int sq_thread_cpu=-1, int sq_thread_idle=-1)
 
template<class T >
void block_on (task< T > t)
 
int fd () const
 
int process_cqe ()
 
int poll_no_wait ()
 
void poll ()
 
sqe_awaitable openat (int dfd, const char *path, int flags, mode_t mode, uint8_t sqe_flags=0)
 
sqe_awaitable openat2 (int dfd, const char *path, struct open_how *how, uint8_t sqe_flags=0)
 
sqe_awaitable readv (int fd, const iovec *iovecs, unsigned nr_vecs, off_t offset=0, uint8_t sqe_flags=0)
 
sqe_awaitable writev (int fd, const iovec *iovecs, unsigned nr_vecs, off_t offset=0, uint8_t sqe_flags=0)
 
sqe_awaitable read (int fd, void *buf, unsigned nbytes, off_t offset=0, uint8_t sqe_flags=0)
 
sqe_awaitable write (int fd, const void *buf, unsigned nbytes, off_t offset=0, uint8_t sqe_flags=0)
 
sqe_awaitable read_fixed (int fd, void *buf, unsigned nbytes, off_t offset, int buf_index, uint8_t sqe_flags=0)
 
sqe_awaitable write_fixed (int fd, const void *buf, unsigned nbytes, off_t offset, int buf_index, uint8_t sqe_flags=0)
 
sqe_awaitable fsync (int fd, unsigned fsync_flags, uint8_t sqe_flags=0)
 
sqe_awaitable sync_file_range (int fd, off64_t offset, off64_t nbytes, unsigned sync_range_flags, uint8_t sqe_flags=0)
 
sqe_awaitable recvmsg (int sockfd, msghdr *msg, uint32_t flags, uint8_t sqe_flags=0)
 
sqe_awaitable sendmsg (int sockfd, const msghdr *msg, uint32_t flags, uint8_t sqe_flags=0)
 
sqe_awaitable recv (int sockfd, void *buf, unsigned nbytes, uint32_t flags, uint8_t sqe_flags=0)
 
sqe_awaitable send (int sockfd, const void *buf, unsigned nbytes, uint32_t flags, uint8_t sqe_flags=0)
 
sqe_awaitable poll_add (int fd, short poll_mask, uint8_t sqe_flags=0)
 
sqe_awaitable nop (uint8_t sqe_flags=0)
 
sqe_awaitable accept (int fd, sockaddr *addr, socklen_t *addrlen, int flags=0, uint8_t sqe_flags=0)
 
sqe_awaitable connect (int fd, sockaddr *addr, socklen_t addrlen, uint8_t sqe_flags=0)
 
sqe_awaitable timeout (__kernel_timespec *ts, uint8_t sqe_flags=0)
 
sqe_awaitable close (int fd, uint8_t sqe_flags=0)
 
void close_detach (int fd, uint8_t sqe_flags=0)
 
sqe_awaitable statx (int dfd, const char *path, int flags, unsigned mask, struct statx *statxbuf, uint8_t sqe_flags=0)
 
sqe_awaitable splice (int fd_in, loff_t off_in, int fd_out, loff_t off_out, size_t nbytes, unsigned flags, uint8_t sqe_flags=0)
 
sqe_awaitable tee (int fd_in, int fd_out, size_t nbytes, unsigned flags, uint8_t sqe_flags=0)
 
sqe_awaitable shutdown (int fd, int how, uint8_t sqe_flags=0)
 
sqe_awaitable renameat (int olddfd, const char *oldpath, int newdfd, const char *newpath, unsigned flags, uint8_t sqe_flags=0)
 
sqe_awaitable mkdirat (int dirfd, const char *pathname, mode_t mode, uint8_t sqe_flags=0)
 
sqe_awaitable symlinkat (const char *target, int newdirfd, const char *linkpath, uint8_t sqe_flags=0)
 
sqe_awaitable linkat (int olddirfd, const char *oldpath, int newdirfd, const char *newpath, int flags, uint8_t sqe_flags=0)
 
sqe_awaitable unlinkat (int dfd, const char *path, unsigned flags, uint8_t sqe_flags=0)
 
void update_files (unsigned off, int *fds, size_t nfds)
 
void register_files (int const *fds, size_t nfds)
 
int unregister_files ()
 
void register_buffers (struct iovec const *iovecs, unsigned nr_iovecs)
 
int unregister_buffers () noexcept
 
- Public Member Functions inherited from uringpp::noncopyable
 noncopyable (noncopyable &&)=default
 
 noncopyable (noncopyable const &)=delete
 
noncopyableoperator= (noncopyable const &)=delete
 
noncopyableoperator= (noncopyable &&)=default
 

Static Public Member Functions

static std::shared_ptr< event_loopcreate (unsigned int entries=128, uint32_t flags=0, int wq_fd=-1)
 

The documentation for this class was generated from the following files: