Package zmq

Class ZObject

  • Direct Known Subclasses:
    IOThread, Own, Pipe, Reaper

    public abstract class ZObject
    extends java.lang.Object
    • 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)
      • sendReaped

        protected final void sendReaped()
      • sendInprocConnected

        protected final void sendInprocConnected​(SocketBase socket)
      • sendDone

        protected final void sendDone()
      • 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)
      • processReaped

        protected void processReaped()
      • processSeqnum

        protected void processSeqnum()
      • sendCommand

        private void sendCommand​(Command cmd)