Field Detail

• read

  protected final boolean read

• buffers

  protected final 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 TimeUnit unit

• block

  protected final SocketWrapperBase.BlockingMode block

• check

  protected final SocketWrapperBase.CompletionCheck check

• handler

  protected final CompletionHandler<Long,? super A> handler

• semaphore

  protected final Semaphore semaphore

• completion

  protected final SocketWrapperBase.VectoredIOCompletionHandler<A> completion

• callHandler

  protected final AtomicBoolean callHandler

• nBytes

  protected volatile long nBytes

• state

  protected volatile SocketWrapperBase.CompletionState state

• completionDone

  protected boolean completionDone

Constructor Detail

• SocketWrapperBase.OperationState

  protected SocketWrapperBase.OperationState(boolean read,
                                  ByteBuffer[] buffers,
                                  int offset,
                                  int length,
                                  SocketWrapperBase.BlockingMode block,
                                  long timeout,
                                  TimeUnit unit,
                                  A attachment,
                                  SocketWrapperBase.CompletionCheck check,
                                  CompletionHandler<Long,? super A> handler,
                                  Semaphore semaphore,
                                  SocketWrapperBase.VectoredIOCompletionHandler<A> completion)

Method Detail

• isInline

  protected abstract boolean isInline()

  Returns:

  true if the operation is still inline, false if the operation is running on a thread that is not the original caller

• process

  protected boolean process()

  Process the operation using the connector executor.

  Returns:

  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.