Package zmq

Class ZObject

java.lang.Object
zmq.ZObject
Direct Known Subclasses:
IOThread, Own, Pipe, Reaper

public abstract class ZObject extends Object
  • Field Details

    • ctx

      private final Ctx ctx
    • tid

      private int tid
  • Constructor Details

    • ZObject

      protected ZObject(Ctx ctx, int tid)
    • ZObject

      protected ZObject(ZObject parent)
  • Method Details

    • 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(String addr, Ctx.Endpoint endpoint)
    • unregisterEndpoint

      protected final boolean unregisterEndpoint(String addr, SocketBase socket)
    • unregisterEndpoints

      protected final void unregisterEndpoints(SocketBase socket)
    • findEndpoint

      protected final Ctx.Endpoint findEndpoint(String addr)
    • pendConnection

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

      protected final void connectPending(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)