Struct BasicMioDriver

pub struct BasicMioDriver<N, P>
where
    N: Clone,
    P: Clone,
{ /* private fields */ }

Implementations

impl<N, P> BasicMioDriver<N, P>

where N: MioNotifier + Default + Clone, P: MioPoller + Default + Clone,

pub fn new() -> Self

Trait Implementations

impl<N, P> Clone for BasicMioDriver<N, P>

where N: Clone, P: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<N, P> RawDriverExt for BasicMioDriver<N, P>

where N: MioNotifier + Clone, P: MioPoller + Default + Clone,

fn fd_user_define_open(&self, id: usize, _buf: &[u8]) -> Result<Handle>

fn fd_user_define_close(&self, id: usize, _handle: Handle) -> Result<()>

fn fd_user_define_clone(&self, handle: Handle) -> Result<Handle>

fn file_open(&self, _path: &str, _mode: FileMode) -> Result<Handle>

Create new file

fn file_write( &self, _waker: Waker, _handle: Handle, _buf: &[u8], ) -> Result<usize>

fn file_read( &self, _waker: Waker, _handle: Handle, _buf: &mut [u8], ) -> Result<usize>

fn file_close(&self, _handle: Handle) -> Result<()>

Close file handle

fn timeout_open(&self, duration: Duration) -> Result<Handle>

fn timeout(&self, waker: Waker, handle: Handle) -> Result<bool>

fn timeout_close(&self, handle: Handle) -> Result<()>

fn tcp_listener_bind(&self, laddrs: &[SocketAddr]) -> Result<Handle>

Create new TcpListener socket and bound to laddrs

fn tcp_listener_accept( &self, waker: Waker, handle: Handle, ) -> Result<(Handle, SocketAddr)>

Accept one incoming TcpStream socket, may returns WOULD_BLOCK

fn tcp_listener_close(&self, handle: Handle) -> Result<()>

Close TcpListener socket.

fn tcp_stream_connect(&self, raddrs: &[SocketAddr]) -> Result<Handle>

Create new TcpStream socket and try connect to remote peer.

fn tcp_stream_write( &self, waker: Waker, handle: Handle, buf: &[u8], ) -> Result<usize>

Write data to underly TcpStream

fn tcp_stream_read( &self, waker: Waker, handle: Handle, buf: &mut [u8], ) -> Result<usize>

Read data from underly TcpStream

fn tcp_stream_close(&self, handle: Handle) -> Result<()>

Close TcpStream socket.

fn udp_socket_bind(&self, laddrs: &[SocketAddr]) -> Result<Handle>

Create a new UdpSocket and bind to laddrs

fn udp_socket_sendto( &self, waker: Waker, handle: Handle, buf: &[u8], raddr: SocketAddr, ) -> Result<usize>

Send one datagram to raddr peer

fn udp_socket_recv_from( &self, waker: Waker, handle: Handle, buf: &mut [u8], ) -> Result<(usize, SocketAddr)>

Recv one datagram from peer.

fn udp_socket_close(&self, handle: Handle) -> Result<()>

Close UdpSocket

fn poller_open(&self) -> Result<Handle>

Create new readiness io event poller.

fn poller_clone(&self, handle: Handle) -> Result<Handle>

Clone pller handle.

fn poller_register( &self, poller: Handle, source: Handle, interests: Interest, ) -> Result<()>

Register interests events of one source.

fn poller_reregister( &self, poller: Handle, source: Handle, interests: Interest, ) -> Result<()>

Re-register interests events of one source.

fn poller_deregister(&self, poller: Handle, source: Handle) -> Result<()>

Deregister interests events of one source.

fn poller_poll_once( &self, poller: Handle, timeout: Option<Duration>, ) -> Result<()>

fn poller_close(&self, poller: Handle) -> Result<()>

Close poller

fn tcp_listener_local_addr(&self, handle: Handle) -> Result<SocketAddr>

fn tcp_stream_local_addr(&self, handle: Handle) -> Result<SocketAddr>

fn tcp_stream_remote_addr(&self, handle: Handle) -> Result<SocketAddr>

fn udp_local_addr(&self, handle: Handle) -> Result<SocketAddr>