Package zmq

Class ZObject

java.lang.Object

zmq.ZObject

Direct Known Subclasses:

IOThread, Own, Pipe, Reaper

public abstract class ZObject
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private Ctx	ctx
private int	tid

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ZObject(Ctx ctx, int tid)
protected	ZObject(ZObject parent)

Method Summary

Modifier and Type	Method	Description
protected IOThread	chooseIoThread(long affinity)
protected void	connectPending(java.lang.String addr, SocketBase bindSocket)
protected void	destroySocket(SocketBase socket)
protected Ctx.Endpoint	findEndpoint(java.lang.String addr)
protected Ctx	getCtx()
int	getTid()
protected void	pendConnection(java.lang.String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
protected void	processActivateRead()
protected void	processActivateWrite(long msgsRead)
protected void	processAttach(IEngine engine)
protected void	processBind(Pipe pipe)
protected void	processCancel()
(package private) void	processCommand(Command cmd)
protected void	processHiccup(YPipeBase<Msg> hiccupPipe)
protected void	processOwn(Own object)
protected void	processPipeTerm()
protected void	processPipeTermAck()
protected void	processPlug()
protected void	processReap(SocketBase socket)
protected void	processReapAck()
protected void	processReaped()
protected void	processSeqnum()
protected void	processStop()
protected void	processTerm(int linger)
protected void	processTermAck()
protected void	processTermReq(Own object)
protected boolean	registerEndpoint(java.lang.String addr, Ctx.Endpoint endpoint)
protected void	sendActivateRead(Pipe destination)
protected void	sendActivateWrite(Pipe destination, long msgsRead)
protected void	sendAttach(SessionBase destination, IEngine engine)
protected void	sendAttach(SessionBase destination, IEngine engine, boolean incSeqnum)
protected void	sendBind(Own destination, Pipe pipe)
protected void	sendBind(Own destination, Pipe pipe, boolean incSeqnum)
protected void	sendCancel()
private void	sendCommand(Command cmd)
protected void	sendDone()
protected void	sendHiccup(Pipe destination, YPipeBase<Msg> pipe)
protected void	sendInprocConnected(SocketBase socket)
protected void	sendOwn(Own destination, Own object)
protected void	sendPipeTerm(Pipe destination)
protected void	sendPipeTermAck(Pipe destination)
protected void	sendPlug(Own destination)
protected void	sendPlug(Own destination, boolean incSeqnum)
protected void	sendReap(SocketBase socket)
protected void	sendReapAck()
protected void	sendReaped()
protected void	sendStop()
protected void	sendTerm(Own destination, int linger)
protected void	sendTermAck(Own destination)
protected void	sendTermReq(Own destination, Own object)
protected void	setTid(int tid)
protected boolean	unregisterEndpoint(java.lang.String addr, SocketBase socket)
protected void	unregisterEndpoints(SocketBase socket)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

ctx

private final Ctx ctx

tid

private int tid

Constructor Detail

ZObject

protected ZObject(Ctx ctx,
                  int tid)

ZObject

protected ZObject(ZObject parent)

Method Detail

getTid

public final int getTid()

setTid

protected final void setTid(int tid)

getCtx

protected final Ctx getCtx()

processCommand

final void processCommand(Command cmd)

registerEndpoint

protected final boolean registerEndpoint(java.lang.String addr,
                                         Ctx.Endpoint endpoint)

unregisterEndpoint

protected final boolean unregisterEndpoint(java.lang.String addr,
                                           SocketBase socket)

unregisterEndpoints

protected final void unregisterEndpoints(SocketBase socket)

findEndpoint

protected final Ctx.Endpoint findEndpoint(java.lang.String addr)

pendConnection

protected final void pendConnection(java.lang.String addr,
                                    Ctx.Endpoint endpoint,
                                    Pipe[] pipes)

connectPending

protected final void connectPending(java.lang.String addr,
                                    SocketBase bindSocket)

destroySocket

protected final void destroySocket(SocketBase socket)

chooseIoThread

protected final IOThread chooseIoThread(long affinity)

sendStop

protected final void sendStop()

sendPlug

protected final void sendPlug(Own destination)

sendPlug

protected final void sendPlug(Own destination,
                              boolean incSeqnum)

sendOwn

protected final void sendOwn(Own destination,
                             Own object)

sendAttach

protected final void sendAttach(SessionBase destination,
                                IEngine engine)

sendAttach

protected final void sendAttach(SessionBase destination,
                                IEngine engine,
                                boolean incSeqnum)

sendBind

protected final void sendBind(Own destination,
                              Pipe pipe)

sendBind

protected final void sendBind(Own destination,
                              Pipe pipe,
                              boolean incSeqnum)

sendActivateRead

protected final void sendActivateRead(Pipe destination)

sendActivateWrite

protected final void sendActivateWrite(Pipe destination,
                                       long msgsRead)

sendHiccup

protected final void sendHiccup(Pipe destination,
                                YPipeBase<Msg> pipe)

sendPipeTerm

protected final void sendPipeTerm(Pipe destination)

sendPipeTermAck

protected final void sendPipeTermAck(Pipe destination)

sendTermReq

protected final void sendTermReq(Own destination,
                                 Own object)

sendTerm

protected final void sendTerm(Own destination,
                              int linger)

sendTermAck

protected final void sendTermAck(Own destination)

sendReap

protected final void sendReap(SocketBase socket)

sendReapAck

protected final void sendReapAck()

sendReaped

protected final void sendReaped()

sendInprocConnected

protected final void sendInprocConnected(SocketBase socket)

sendDone

protected final void sendDone()

sendCancel

protected final void sendCancel()

processStop

protected void processStop()

processPlug

protected void processPlug()

processOwn

protected void processOwn(Own object)

processAttach

protected void processAttach(IEngine engine)

processBind

protected void processBind(Pipe pipe)

processActivateRead

protected void processActivateRead()

processActivateWrite

protected void processActivateWrite(long msgsRead)

processHiccup

protected void processHiccup(YPipeBase<Msg> hiccupPipe)

processPipeTerm

protected void processPipeTerm()

processPipeTermAck

protected void processPipeTermAck()

processTermReq

protected void processTermReq(Own object)

processTerm

protected void processTerm(int linger)

processTermAck

protected void processTermAck()

processReap

protected void processReap(SocketBase socket)

processReapAck

protected void processReapAck()

processReaped

protected void processReaped()

processSeqnum

protected void processSeqnum()

processCancel

protected void processCancel()

sendCommand

private void sendCommand(Command cmd)