Package zmq
Class ZObject
- java.lang.Object
-
- zmq.ZObject
-
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
-
-
-
Field Detail
-
ctx
private final Ctx ctx
-
tid
private int tid
-
-
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)
-
sendAttach
protected final void sendAttach(SessionBase destination, IEngine engine)
-
sendAttach
protected final void sendAttach(SessionBase destination, IEngine engine, boolean incSeqnum)
-
sendActivateRead
protected final void sendActivateRead(Pipe destination)
-
sendActivateWrite
protected final void sendActivateWrite(Pipe destination, long msgsRead)
-
sendPipeTerm
protected final void sendPipeTerm(Pipe destination)
-
sendPipeTermAck
protected final void sendPipeTermAck(Pipe destination)
-
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)
-
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)
-
-