Trait PollOpCode 

pub unsafe trait PollOpCode {
    // Required methods
    fn pre_submit(self: Pin<&mut Self>) -> Result<Decision>;
    fn operate(self: Pin<&mut Self>) -> Poll<Result<usize>>;

    // Provided method
    fn op_type(self: Pin<&mut Self>) -> Option<OpType> { ... }
}

Abstraction of operations.

Safety

If pre_submit returns Decision::Wait, op_type must also return Some(OpType::Fd) with same fds as the WaitArgs. Similarly, if pre_submit returns Decision::Aio, op_type must return Some(OpType::Aio) with the correct aiocb pointer.

Required Methods

fn pre_submit(self: Pin<&mut Self>) -> Result<Decision>

Perform the operation before submit, and return Decision to indicate whether submitting the operation to polling is required.

fn operate(self: Pin<&mut Self>) -> Poll<Result<usize>>

Perform the operation after received corresponding event. If this operation is blocking, the return value should be Poll::Ready.

Provided Methods

fn op_type(self: Pin<&mut Self>) -> Option<OpType>

Get the operation type when an event is occurred.

Implementors

impl OpCode for CloseFile

impl OpCode for CloseSocket

impl OpCode for CreateDir

impl OpCode for CreateSocket

impl OpCode for HardLink

impl OpCode for OpenFile

impl OpCode for PathStat

impl OpCode for Rename

impl OpCode for Symlink

impl OpCode for Unlink

impl<D: Send + 'static, F: FnOnce() -> BufResult<usize, D> + Send + 'static> OpCode for Asyncify<F, D>

impl<S1: AsFd, S2: AsFd> OpCode for Splice<S1, S2>

Available on linux_all only.

impl<S, D: Send + 'static, F: FnOnce(&S) -> BufResult<usize, D> + Send + 'static> OpCode for AsyncifyFd<S, F, D>

impl<S: AsFd> OpCode for Accept<S>

impl<S: AsFd> OpCode for Connect<S>

impl<S: AsFd> OpCode for FileStat<S>

impl<S: AsFd> OpCode for PollOnce<S>

impl<S: AsFd> OpCode for ReadManaged<S>

impl<S: AsFd> OpCode for ReadManagedAt<S>

impl<S: AsFd> OpCode for RecvManaged<S>

impl<S: AsFd> OpCode for ShutdownSocket<S>

impl<S: AsFd> OpCode for Sync<S>

impl<S: AsFd> OpCode for TruncateFile<S>

impl<T: IoBuf, S: AsFd> OpCode for Send<T, S>

impl<T: IoBuf, S: AsFd> OpCode for SendTo<T, S>

impl<T: IoBuf, S: AsFd> OpCode for Write<T, S>

impl<T: IoBuf, S: AsFd> OpCode for WriteAt<T, S>

impl<T: IoBufMut, S: AsFd> OpCode for Read<T, S>

impl<T: IoBufMut, S: AsFd> OpCode for ReadAt<T, S>

impl<T: IoBufMut, S: AsFd> OpCode for Recv<T, S>

impl<T: IoBufMut, S: AsFd> OpCode for RecvFrom<T, S>

impl<T: IoVectoredBuf, C: IoBuf, S: AsFd> OpCode for SendMsg<T, C, S>

impl<T: IoVectoredBuf, S: AsFd> OpCode for SendToVectored<T, S>

impl<T: IoVectoredBuf, S: AsFd> OpCode for SendVectored<T, S>

impl<T: IoVectoredBuf, S: AsFd> OpCode for WriteVectored<T, S>

impl<T: IoVectoredBuf, S: AsFd> OpCode for WriteVectoredAt<T, S>

impl<T: IoVectoredBufMut, C: IoBufMut, S: AsFd> OpCode for RecvMsg<T, C, S>

impl<T: IoVectoredBufMut, S: AsFd> OpCode for ReadVectored<T, S>

impl<T: IoVectoredBufMut, S: AsFd> OpCode for ReadVectoredAt<T, S>

impl<T: IoVectoredBufMut, S: AsFd> OpCode for RecvFromVectored<T, S>

impl<T: IoVectoredBufMut, S: AsFd> OpCode for RecvVectored<T, S>