public class TcpListener extends Listener
Modifier and Type | Field and Description |
---|---|
private TcpAddress |
address |
private java.lang.String |
endpoint |
private java.nio.channels.ServerSocketChannel |
fd |
private Poller.Handle |
handle |
private IOObject |
ioObject |
private static boolean |
isWindows |
Constructor and Description |
---|
TcpListener(IOThread ioThread,
SocketBase socket,
Options options) |
Modifier and Type | Method and Description |
---|---|
private java.nio.channels.SocketChannel |
accept() |
void |
acceptEvent()
Called by I/O thread when file descriptor is ready for accept.
|
protected java.lang.String |
address(Address.IZAddress address) |
private void |
close() |
void |
destroy() |
java.lang.String |
getAddress() |
protected void |
processPlug() |
protected void |
processTerm(int linger) |
private boolean |
setAddress() |
protected boolean |
setAddress(java.net.InetSocketAddress addr) |
boolean |
setAddress(java.lang.String addr) |
java.lang.String |
toString() |
incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processCancel, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReapAck, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendCancel, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReapAck, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
connectEvent, inEvent, outEvent, timerEvent
private static final boolean isWindows
private TcpAddress address
private java.nio.channels.ServerSocketChannel fd
private Poller.Handle handle
private java.lang.String endpoint
private final IOObject ioObject
public TcpListener(IOThread ioThread, SocketBase socket, Options options)
protected void processPlug()
processPlug
in class ZObject
protected void processTerm(int linger)
processTerm
in class Own
public void acceptEvent()
IPollEvents
private void close()
public java.lang.String getAddress()
getAddress
in class Listener
protected java.lang.String address(Address.IZAddress address)
public boolean setAddress(java.lang.String addr)
setAddress
in class Listener
protected boolean setAddress(java.net.InetSocketAddress addr)
private boolean setAddress()
private java.nio.channels.SocketChannel accept() throws java.io.IOException
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object