Struct IoBufferQueue

struct IoBufferQueue {
    socket: UnixSeqpacket,
    file: File,
    mmap: MemoryMapping,
    size: usize,
    next: Mutex<usize>,
}

Fields

socket: UnixSeqpacket

file: File

mmap: MemoryMapping

size: usize

next: Mutex<usize>

Implementations

impl IoBufferQueue

fn new(socket: UnixSeqpacket, file: File) -> Result<IoBufferQueue, Error>

fn allocate_buffer(&self, size: usize) -> Result<usize, Error>

fn buffer_at( &self, offset: usize, len: usize, ) -> Result<VolatileSlice<'_>, Error>

fn try_clone_socket(&self) -> Result<UnixSeqpacket, Error>

fn send_buffer( &self, stream_id: u32, offset: usize, size: usize, ) -> Result<(), Error>

fn keep_rds(&self) -> Vec<RawDescriptor>