TCPSocket

Undocumented in source.

@trusted

class TCPSocket : AsyncTransport , EventCallInterface {

this(EventLoop loop, bool isIpV6);

this(EventLoop loop, AddressFamily family);

this(EventLoop loop, Socket sock);

int fd [@property getter];

bool start();

void close();

bool isAlive [@property getter];

void write(const(ubyte)[] data, TCPWriteCallBack cback);

void write(TCPWriteBuffer buffer);

mixin TransportSocketOption ;

void setKeepAlive(int time, int interval);

void setReadCallBack(TCPReadCallBack cback);

void setCloseCallBack(CallBack cback);

bool alive [@property getter];

void onWrite();

void onClose();

void onRead();

static if(IOMode == IO_MODE.iocp)

bool doRead();

static if(IOMode == IO_MODE.iocp)

bool doWrite();

void clearWriteQueue();

import std.experimental.allocator.gc_allocator;;

Socket _socket;

WriteBufferQueue _writeQueue;

AsyncEvent _event;

ubyte[] _readBuffer;

CallBack _unActive;

TCPReadCallBack _readCallBack;

static if(IO_MODE.iocp == IOMode)

IOCP_DATA _iocpread;

static if(IO_MODE.iocp == IOMode)

IOCP_DATA _iocpwrite;

static if(IO_MODE.iocp == IOMode)

WSABUF _iocpBuffer;

static if(IO_MODE.iocp == IOMode)

WSABUF _iocpWBuf;

}

Constructors

this this(EventLoop loop, bool isIpV6): Undocumented in source.
this this(EventLoop loop, AddressFamily family): Undocumented in source.
this this(EventLoop loop, Socket sock): Undocumented in source.

Destructor

~this ~this(): Undocumented in source.

Members

Functions

clearWriteQueue void clearWriteQueue(): Undocumented in source. Be warned that the author may not have intended to support it.
close void close(): Undocumented in source. Be warned that the author may not have intended to support it.
doRead bool doRead(): Undocumented in source. Be warned that the author may not have intended to support it.
doWrite bool doWrite(): Undocumented in source. Be warned that the author may not have intended to support it.
onClose void onClose(): Undocumented in source. Be warned that the author may not have intended to support it.
onRead void onRead(): Undocumented in source. Be warned that the author may not have intended to support it.
onWrite void onWrite(): Undocumented in source. Be warned that the author may not have intended to support it.
setCloseCallBack void setCloseCallBack(CallBack cback): Undocumented in source. Be warned that the author may not have intended to support it.
setKeepAlive void setKeepAlive(int time, int interval): Undocumented in source. Be warned that the author may not have intended to support it.
setReadCallBack void setReadCallBack(TCPReadCallBack cback): Undocumented in source. Be warned that the author may not have intended to support it.
start bool start(): Undocumented in source. Be warned that the author may not have intended to support it.
write void write(const(ubyte)[] data, TCPWriteCallBack cback): Undocumented in source. Be warned that the author may not have intended to support it.
write void write(TCPWriteBuffer buffer): Undocumented in source. Be warned that the author may not have intended to support it.

Mixins

__anonymous mixin TransportSocketOption: Undocumented in source.

Properties

alive bool alive [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
fd int fd [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
isAlive bool isAlive [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.

Variables

_event AsyncEvent _event;: Undocumented in source.
_iocpBuffer WSABUF _iocpBuffer;: Undocumented in source.
_iocpWBuf WSABUF _iocpWBuf;: Undocumented in source.
_iocpread IOCP_DATA _iocpread;: Undocumented in source.
_iocpwrite IOCP_DATA _iocpwrite;: Undocumented in source.
_readBuffer ubyte[] _readBuffer;: Undocumented in source.
_readCallBack TCPReadCallBack _readCallBack;: Undocumented in source.
_socket Socket _socket;: Undocumented in source.
_unActive CallBack _unActive;: Undocumented in source.
_writeQueue WriteBufferQueue _writeQueue;: Undocumented in source.

Mixed In Members

From `mixin TransportSocketOption`

getOption int getOption(SocketOptionLevel level, SocketOption option, void[] result): Get a socket option.
getOption int getOption(SocketOptionLevel level, SocketOption option, int32_t result): Common case of getting integer and boolean options.
getOption int getOption(SocketOptionLevel level, SocketOption option, Linger result): Get the linger option.
getOption void getOption(SocketOptionLevel level, SocketOption option, Duration result): Get a timeout (duration) option.
setOption void setOption(SocketOptionLevel level, SocketOption option, void[] value): Set a socket option.
setOption void setOption(SocketOptionLevel level, SocketOption option, int32_t value): Common case for setting integer and boolean options.
setOption void setOption(SocketOptionLevel level, SocketOption option, Linger value): Set the linger option.
setOption void setOption(SocketOptionLevel level, SocketOption option, Duration value): Undocumented in source. Be warned that the author may not have intended to support it.
remoteAddress Address remoteAddress [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
localAddress Address localAddress [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
createAddress Address createAddress(): Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From AsyncTransport

close void close(): Undocumented in source.
start bool start(): Undocumented in source.
isAlive bool isAlive [@property getter]: Undocumented in source.
fd int fd [@property getter]: Undocumented in source.
transportType transportType [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
eventLoop eventLoop [@property getter]: Undocumented in source. Be warned that the author may not have intended to support it.
_loop EventLoop _loop;: Undocumented in source.
_type TransportType _type;: Undocumented in source.

Meta

Source

See Implementation

yu asyncsocket tcpsocket aliases

classes

structs

WriteBufferQueue