Class SocketWrapperBase.OperationState<A>

  • All Implemented Interfaces:
    Enclosing class:

    protected abstract class SocketWrapperBase.OperationState<A>
    extends java.lang.Object
    implements java.lang.Runnable
    Internal state tracker for vectored operations.
    • Field Detail

      • read

        protected final boolean read
      • buffers

        protected final java.nio.ByteBuffer[] buffers
      • offset

        protected final int offset
      • length

        protected final int length
      • attachment

        protected final A attachment
      • timeout

        protected final long timeout
      • unit

        protected final java.util.concurrent.TimeUnit unit
      • handler

        protected final java.nio.channels.CompletionHandler<java.lang.Long,​? super A> handler
      • semaphore

        protected final java.util.concurrent.Semaphore semaphore
      • callHandler

        protected final java.util.concurrent.atomic.AtomicBoolean callHandler
      • nBytes

        protected volatile long nBytes
      • completionDone

        protected boolean completionDone
    • Method Detail

      • isInline

        protected abstract boolean isInline()
        true if the operation is still inline, false if the operation is running on a thread that is not the original caller
      • hasOutboundRemaining

        protected boolean hasOutboundRemaining()
      • process

        protected boolean process()
        Process the operation using the connector executor.
        true if the operation was accepted, false if the executor rejected execution
      • start

        protected void start()
        Start the operation, this will typically call run.
      • end

        protected void end()
        End the operation.