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 String	endpoint
private ServerSocketChannel	fd
private Poller.Handle	handle
private final IOObject	ioObject
private static boolean	isWindows
private SocketBase	socket

Fields inherited from class zmq.Own

errno, options

Constructor Summary

Constructors

Constructor	Description
TcpListener(IOThread ioThread, SocketBase socket, Options options)

Method Summary

Modifier and Type	Method	Description
private SocketChannel	accept()
void	acceptEvent()	Called by I/O thread when file descriptor is ready for accept.
protected String	address(Address.IZAddress address)
private void	close()
void	destroy()
String	getAddress()
protected void	processPlug()
protected void	processTerm(int linger)
boolean	setAddress(String addr)
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 Details

isWindows

private static boolean isWindows

address

private TcpAddress address

fd

private ServerSocketChannel fd

handle

private Poller.Handle handle

socket

private SocketBase socket

endpoint

private String endpoint

ioObject

private final IOObject ioObject

Constructor Details

TcpListener

public TcpListener(IOThread ioThread,
 SocketBase socket,
 Options options)

Method Details

destroy

public void destroy()

Specified by:

destroy in class Own

processPlug

protected void processPlug()

Overrides:

processPlug in class ZObject

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

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 interface IPollEvents

close

private void close()

getAddress

public String getAddress()

address

protected String address(Address.IZAddress address)

setAddress

public boolean setAddress(String addr)

accept

private SocketChannel accept()
                      throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object