Package zmq.io.net.tcp
Class TcpListener
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.io.net.tcp.TcpListener
-
- All Implemented Interfaces:
IPollEvents
- Direct Known Subclasses:
IpcListener
,TipcListener
public class TcpListener extends Own implements IPollEvents
-
-
Field Summary
Fields Modifier and Type Field 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
private SocketBase
socket
-
Constructor Summary
Constructors Constructor Description TcpListener(IOThread ioThread, SocketBase socket, Options options)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
boolean
setAddress(java.lang.String addr)
java.lang.String
toString()
-
Methods inherited from class zmq.Own
incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
-
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface zmq.poll.IPollEvents
connectEvent, inEvent, outEvent, timerEvent
-
-
-
-
Field Detail
-
isWindows
private static boolean isWindows
-
address
private TcpAddress address
-
fd
private java.nio.channels.ServerSocketChannel fd
-
handle
private Poller.Handle handle
-
socket
private SocketBase socket
-
endpoint
private java.lang.String endpoint
-
ioObject
private final IOObject ioObject
-
-
Constructor Detail
-
TcpListener
public TcpListener(IOThread ioThread, SocketBase socket, Options options)
-
-
Method Detail
-
processPlug
protected void processPlug()
- Overrides:
processPlug
in classZObject
-
processTerm
protected void processTerm(int linger)
- Overrides:
processTerm
in classOwn
-
acceptEvent
public void acceptEvent()
Description copied from interface:IPollEvents
Called by I/O thread when file descriptor is ready for accept.- Specified by:
acceptEvent
in interfaceIPollEvents
-
close
private void close()
-
getAddress
public java.lang.String getAddress()
-
address
protected java.lang.String address(Address.IZAddress address)
-
setAddress
public boolean setAddress(java.lang.String addr)
-
accept
private java.nio.channels.SocketChannel accept() throws java.io.IOException
- Throws:
java.io.IOException
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-