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)