TaskSelectTransceiver

ditto

class TaskSelectTransceiver {

import ocean.io.select.protocol.task.TaskSelectClient;;

import ocean.io.select.protocol.task.internal.BufferedReader;;

import core.stdc.errno : errno, EAGAIN, EWOULDBLOCK, EINTR;;

import core.stdc.errno : errno, EAGAIN, EWOULDBLOCK, EINTR;;

import core.stdc.errno : errno, EAGAIN, EWOULDBLOCK, EINTR;;

import core.stdc.errno : errno, EAGAIN, EWOULDBLOCK, EINTR;;

import core.sys.posix.sys.uio : iovec, readv;;

import core.sys.posix.sys.uio : iovec, readv;;

import core.sys.posix.sys.socket : setsockopt;;

import core.sys.posix.netinet.in_ : IPPROTO_TCP;;

import core.sys.linux.netinet.tcp : TCP_CORK;;

struct epoll_event_t via import ocean.sys.Epoll : epoll_event_t;;

alias Event = epoll_event_t.Event;

class IOWarning via import ocean.io.select.protocol.generic.ErrnoIOException : IOWarning, IOError;;

class IOError via import ocean.io.select.protocol.generic.ErrnoIOException : IOWarning, IOError;;

TerminalOutput Stdout; via import ocean.io.Stdout : Stdout;;

void enforce(E e, T1 a, T2 b) via import ocean.core.Enforce : enforce;;

import ocean.meta.types.Qualifiers;;

IODevice iodev;

TaskSelectClient select_client;

this(IODevice iodev, IOWarning warning_e, IOError error_e, size_t read_buffer_size);

void read(void[] data);

void readValue(T value);

void readConsume(size_t delegate(void[] data) consume);

void writeValue(T value);

void write(const(void)[] data);

void flush();

void reset();

}

Constructors

this this(IODevice iodev, IOWarning warning_e, IOError error_e, size_t read_buffer_size): Constructor.

Members

Aliases

Event alias Event = epoll_event_t.Event: Undocumented in source.

Functions

flush void flush(): Sends all pending output data immediately. Calling this method has an effect only if the I/O device is a TCP socket.
read void read(void[] data): Populates data with data read from the I/O device.
readConsume void readConsume(size_t delegate(void[] data) consume): Calls consume with data read from the I/O device.
readValue void readValue(T value): Populates value with value.sizeof bytes read from the I/O device.
reset void reset(): Removes any remaining data from I/O buffers, sends any pending output data immediately if possible, and removes the epoll registration of the I/O device, if any.
write void write(const(void)[] data): Writes data to the I/O device. If the I/O device is a TCP socket then data may be buffered for at most 200ms using the TCP Cork feature of Linux. In this case call flush() to write all pending data immediately.
writeValue void writeValue(T value): Writes the byte data of value to the I/O device. If the I/O device is a TCP socket then the data may be buffered for at most 200ms using the TCP Cork feature of Linux. In this case call flush() to write all pending data immediately.

Variables

iodev IODevice iodev;: I/O device
select_client TaskSelectClient select_client;: Task select client to wait for I/O events

Meta

Source

See Implementation

ocean io select protocol task TaskSelectTransceiver classes

TaskSelectTransceiver

functions

connect