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 TcpAddressaddressprivate java.lang.Stringendpointprivate java.nio.channels.ServerSocketChannelfdprivate Poller.Handlehandleprivate IOObjectioObjectprivate static booleanisWindowsprivate SocketBasesocket
-
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.SocketChannelaccept()voidacceptEvent()Called by I/O thread when file descriptor is ready for accept.protected java.lang.Stringaddress(Address.IZAddress address)private voidclose()voiddestroy()java.lang.StringgetAddress()protected voidprocessPlug()protected voidprocessTerm(int linger)booleansetAddress(java.lang.String addr)java.lang.StringtoString()-
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:
processPlugin classZObject
-
processTerm
protected void processTerm(int linger)
- Overrides:
processTermin classOwn
-
acceptEvent
public void acceptEvent()
Description copied from interface:IPollEventsCalled by I/O thread when file descriptor is ready for accept.- Specified by:
acceptEventin 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:
toStringin classjava.lang.Object
-
-