Orbit Framework
An ultra-modern, asynchronous, cross-platform C++ Web Framework.
Loading...
Searching...
No Matches
network::IoUringProactor Class Reference

#include <IoUringProactor.hpp>

Inheritance diagram for network::IoUringProactor:
Collaboration diagram for network::IoUringProactor:

Public Member Functions

 IoUringProactor (unsigned entries=1024)
 
 ~IoUringProactor () override
 
void run_once (int timeout_ms) override
 
void async_read (socket_t fd, void *buffer, size_t size, std::function< void(ssize_t)> callback) override
 
void async_write (socket_t fd, const void *buffer, size_t size, std::function< void(ssize_t)> callback) override
 
void async_wait_read (socket_t fd, std::function< void()> callback) override
 
void async_wait_write (socket_t fd, std::function< void()> callback) override
 
void async_sendfile (socket_t out_fd, int in_fd, off_t offset, size_t count, std::function< void(ssize_t)> callback) override
 
void async_accept (socket_t fd, std::function< void(socket_t, sockaddr_in)> callback) override
 
void async_connect (socket_t fd, const sockaddr_in &addr, std::function< void(int)> callback) override
 
void remove (socket_t fd) override
 
- Public Member Functions inherited from network::Proactor
virtual ~Proactor ()=default
 
virtual void async_read (socket_t fd, void *buffer, size_t size, std::function< void(ssize_t bytes_read)> callback)=0
 
virtual void async_write (socket_t fd, const void *buffer, size_t size, std::function< void(ssize_t bytes_written)> callback)=0
 
virtual void async_sendfile (socket_t out_fd, int in_fd, off_t offset, size_t count, std::function< void(ssize_t bytes_written)> callback)=0
 
virtual void async_accept (socket_t fd, std::function< void(socket_t new_fd, sockaddr_in addr)> callback)=0
 
virtual void async_connect (socket_t fd, const sockaddr_in &addr, std::function< void(int status)> callback)=0
 

Constructor & Destructor Documentation

◆ IoUringProactor()

network::IoUringProactor::IoUringProactor ( unsigned  entries = 1024)

◆ ~IoUringProactor()

network::IoUringProactor::~IoUringProactor ( )
override

Member Function Documentation

◆ async_accept()

void network::IoUringProactor::async_accept ( socket_t  fd,
std::function< void(socket_t, sockaddr_in)>  callback 
)
override

◆ async_connect()

void network::IoUringProactor::async_connect ( socket_t  fd,
const sockaddr_in &  addr,
std::function< void(int)>  callback 
)
override

◆ async_read()

void network::IoUringProactor::async_read ( socket_t  fd,
void *  buffer,
size_t  size,
std::function< void(ssize_t)>  callback 
)
override

◆ async_sendfile()

void network::IoUringProactor::async_sendfile ( socket_t  out_fd,
int  in_fd,
off_t  offset,
size_t  count,
std::function< void(ssize_t)>  callback 
)
override

◆ async_wait_read()

void network::IoUringProactor::async_wait_read ( socket_t  fd,
std::function< void()>  callback 
)
overridevirtual

Implements network::Proactor.

◆ async_wait_write()

void network::IoUringProactor::async_wait_write ( socket_t  fd,
std::function< void()>  callback 
)
overridevirtual

Implements network::Proactor.

◆ async_write()

void network::IoUringProactor::async_write ( socket_t  fd,
const void *  buffer,
size_t  size,
std::function< void(ssize_t)>  callback 
)
override

◆ remove()

void network::IoUringProactor::remove ( socket_t  fd)
overridevirtual

Implements network::Proactor.

◆ run_once()

void network::IoUringProactor::run_once ( int  timeout_ms)
overridevirtual

Implements network::Proactor.


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