Package zmq

Class SocketBase

    • Field Detail

      • inprocs

        private final MultiMap<java.lang.String,​Pipe> inprocs
      • active

        private boolean active
      • ctxTerminated

        private java.util.concurrent.atomic.AtomicBoolean ctxTerminated
      • isInEventThreadLocal

        private java.lang.ThreadLocal<java.lang.Boolean> isInEventThreadLocal
      • destroyed

        private java.util.concurrent.atomic.AtomicBoolean destroyed
      • mailbox

        private final IMailbox mailbox
      • pipes

        private final java.util.Set<Pipe> pipes
      • poller

        private Poller poller
      • lastTsc

        private long lastTsc
      • ticks

        private int ticks
      • rcvmore

        private boolean rcvmore
      • fileDesc

        private java.nio.channels.SocketChannel fileDesc
      • monitorEvents

        private int monitorEvents
      • connectRid

        protected java.lang.String connectRid
      • monitorSync

        private final java.util.concurrent.locks.ReentrantLock monitorSync
      • threadSafe

        private final boolean threadSafe
      • threadSafeSync

        private final java.util.concurrent.locks.ReentrantLock threadSafeSync
      • reaperSignaler

        private Signaler reaperSignaler
    • Constructor Detail

      • SocketBase

        protected SocketBase​(Ctx parent,
                             int tid,
                             int sid)
      • SocketBase

        protected SocketBase​(Ctx parent,
                             int tid,
                             int sid,
                             boolean threadSafe)
    • Method Detail

      • xattachPipe

        protected abstract void xattachPipe​(Pipe pipe,
                                            boolean subscribe2all,
                                            boolean isLocallyInitiated)
      • xpipeTerminated

        protected abstract void xpipeTerminated​(Pipe pipe)
      • isActive

        boolean isActive()
        Returns:
        false if object is not a socket.
      • destroy

        protected void destroy()
        Specified by:
        destroy in class Own
      • getMailbox

        final IMailbox getMailbox()
      • stop

        final void stop()
      • checkProtocol

        private NetProtocol checkProtocol​(java.lang.String protocol)
      • attachPipe

        private void attachPipe​(Pipe pipe,
                                boolean isLocallyInitiated)
      • attachPipe

        private void attachPipe​(Pipe pipe,
                                boolean subscribe2all,
                                boolean isLocallyInitiated)
      • setSocketOpt

        public final boolean setSocketOpt​(int option,
                                          java.lang.Object optval)
      • getSocketOpt

        public final int getSocketOpt​(int option)
      • getSocketOptx

        public final java.lang.Object getSocketOptx​(int option)
      • bind

        public final boolean bind​(java.lang.String addr)
      • connect

        public final boolean connect​(java.lang.String addr)
      • connectPeer

        public final int connectPeer​(java.lang.String addr)
      • connectInternal

        private boolean connectInternal​(java.lang.String addr)
      • disconnectPeer

        public boolean disconnectPeer​(int routingId)
      • addEndpoint

        private void addEndpoint​(java.lang.String addr,
                                 Own endpoint,
                                 Pipe pipe)
      • termEndpoint

        public final boolean termEndpoint​(java.lang.String addr)
      • send

        public final boolean send​(Msg msg,
                                  int flags)
      • send

        public final boolean send​(Msg msg,
                                  int flags,
                                  java.util.concurrent.atomic.AtomicBoolean canceled)
      • recv

        public final Msg recv​(int flags)
      • recv

        public final Msg recv​(int flags,
                              java.util.concurrent.atomic.AtomicBoolean canceled)
      • join

        public final boolean join​(java.lang.String group)
      • leave

        public final boolean leave​(java.lang.String group)
      • cancel

        public final void cancel​(java.util.concurrent.atomic.AtomicBoolean canceled)
      • poll

        public final int poll​(int interest,
                              int timeout,
                              java.util.concurrent.atomic.AtomicBoolean canceled)
      • close

        public final void close()
      • hasIn

        final boolean hasIn()
      • hasOut

        final boolean hasOut()
      • startReaping

        final void startReaping​(Poller poller)
      • isInEvent

        private boolean isInEvent()
      • processCommands

        private boolean processCommands​(int timeout,
                                        boolean throttle,
                                        java.util.concurrent.atomic.AtomicBoolean canceled)
      • processStop

        protected final void processStop()
        Overrides:
        processStop in class ZObject
      • processTerm

        protected final void processTerm​(int linger)
        Overrides:
        processTerm in class Own
      • processDestroy

        protected final void processDestroy()
        Overrides:
        processDestroy in class Own
      • xsetsockopt

        protected boolean xsetsockopt​(int option,
                                      java.lang.Object optval)
      • xhasOut

        protected boolean xhasOut()
      • xsend

        protected boolean xsend​(Msg msg)
      • xhasIn

        protected boolean xhasIn()
      • xrecv

        protected Msg xrecv()
      • getCredential

        protected Blob getCredential()
      • xreadActivated

        protected void xreadActivated​(Pipe pipe)
      • xwriteActivated

        protected void xwriteActivated​(Pipe pipe)
      • xhiccuped

        protected void xhiccuped​(Pipe pipe)
      • xjoin

        protected boolean xjoin​(java.lang.String group)
      • xleave

        protected boolean xleave​(java.lang.String group)
      • xdisconnectPeer

        protected boolean xdisconnectPeer​(int routingId)
      • enterInEvent

        private void enterInEvent()
      • leaveInEvent

        private void leaveInEvent()
      • inEvent

        public final void inEvent()
        Description copied from interface: IPollEvents
        Called by I/O thread when file descriptor is ready for reading.
        Specified by:
        inEvent in interface IPollEvents
      • checkDestroy

        private void checkDestroy()
      • extractFlags

        private void extractFlags​(Msg msg)
      • monitor

        public final boolean monitor​(java.lang.String addr,
                                     int events)
        Register the address for a monitor. It must be a inproc PAIR.
        Parameters:
        addr - or null for unregister.
        events - an event mask to monitor.
        Returns:
        true if creation succeeded.
        Throws:
        java.lang.IllegalStateException - if a previous monitor was already registered.
      • eventHandshaken

        public final void eventHandshaken​(java.lang.String addr,
                                          int zmtpVersion)
      • eventConnected

        public final void eventConnected​(java.lang.String addr,
                                         java.nio.channels.SelectableChannel ch)
      • eventConnectDelayed

        public final void eventConnectDelayed​(java.lang.String addr,
                                              int errno)
      • eventConnectRetried

        public final void eventConnectRetried​(java.lang.String addr,
                                              int interval)
      • eventListening

        public final void eventListening​(java.lang.String addr,
                                         java.nio.channels.SelectableChannel ch)
      • eventBindFailed

        public final void eventBindFailed​(java.lang.String addr,
                                          int errno)
      • eventAccepted

        public final void eventAccepted​(java.lang.String addr,
                                        java.nio.channels.SelectableChannel ch)
      • eventAcceptFailed

        public final void eventAcceptFailed​(java.lang.String addr,
                                            int errno)
      • eventClosed

        public final void eventClosed​(java.lang.String addr,
                                      java.nio.channels.SelectableChannel ch)
      • eventCloseFailed

        public final void eventCloseFailed​(java.lang.String addr,
                                           int errno)
      • eventDisconnected

        public final void eventDisconnected​(java.lang.String addr,
                                            java.nio.channels.SelectableChannel ch)
      • eventHandshakeFailedNoDetail

        public final void eventHandshakeFailedNoDetail​(java.lang.String addr,
                                                       int errno)
      • eventHandshakeFailedProtocol

        public final void eventHandshakeFailedProtocol​(java.lang.String addr,
                                                       int errno)
      • eventHandshakeFailedAuth

        public final void eventHandshakeFailedAuth​(java.lang.String addr,
                                                   int errno)
      • eventHandshakeSucceeded

        public final void eventHandshakeSucceeded​(java.lang.String addr,
                                                  int errno)
      • event

        private void event​(java.lang.String addr,
                           java.lang.Object arg,
                           int event)
      • monitorEvent

        protected final void monitorEvent​(ZMQ.Event event)
      • stopMonitor

        private void stopMonitor()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • getFD

        public final java.nio.channels.SelectableChannel getFD()
      • typeString

        public java.lang.String typeString()
      • errno

        public final int errno()
      • lock

        private void lock()
      • unlock

        private void unlock()