protected abstract class SocketWrapperBase.OperationState<A> extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
protected A |
attachment |
protected SocketWrapperBase.BlockingMode |
block |
protected ByteBuffer[] |
buffers |
protected AtomicBoolean |
callHandler |
protected SocketWrapperBase.CompletionCheck |
check |
protected SocketWrapperBase.VectoredIOCompletionHandler<A> |
completion |
protected boolean |
completionDone |
protected CompletionHandler<Long,? super A> |
handler |
protected int |
length |
protected long |
nBytes |
protected int |
offset |
protected boolean |
read |
protected Semaphore |
semaphore |
protected SocketWrapperBase.CompletionState |
state |
protected long |
timeout |
protected TimeUnit |
unit |
Modifier | Constructor and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
protected void |
end()
End the operation.
|
protected abstract boolean |
isInline() |
protected boolean |
process()
Process the operation using the connector executor.
|
protected void |
start()
Start the operation, this will typically call run.
|
protected final boolean read
protected final ByteBuffer[] buffers
protected final int offset
protected final int length
protected final A attachment
protected final long timeout
protected final TimeUnit unit
protected final SocketWrapperBase.BlockingMode block
protected final SocketWrapperBase.CompletionCheck check
protected final CompletionHandler<Long,? super A> handler
protected final Semaphore semaphore
protected final SocketWrapperBase.VectoredIOCompletionHandler<A> completion
protected final AtomicBoolean callHandler
protected volatile long nBytes
protected volatile SocketWrapperBase.CompletionState state
protected boolean completionDone
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)
protected abstract boolean isInline()
protected boolean process()
protected void start()
protected void end()
Copyright © 2000-2020 Apache Software Foundation. All Rights Reserved.