java.lang.Runnable
protected abstract class SocketWrapperBase.OperationState<A>
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field | Description |
---|---|---|
protected A |
attachment |
|
protected SocketWrapperBase.BlockingMode |
block |
|
protected java.nio.ByteBuffer[] |
buffers |
|
protected SocketWrapperBase.CompletionCheck |
check |
|
protected SocketWrapperBase.VectoredIOCompletionHandler<A> |
completion |
|
protected boolean |
completionDone |
|
protected java.nio.channels.CompletionHandler<java.lang.Long,? super A> |
handler |
|
protected int |
length |
|
protected long |
nBytes |
|
protected int |
offset |
|
protected boolean |
read |
|
protected java.util.concurrent.Semaphore |
semaphore |
|
protected SocketWrapperBase.CompletionState |
state |
|
protected long |
timeout |
|
protected java.util.concurrent.TimeUnit |
unit |
Modifier | Constructor | Description |
---|---|---|
protected |
OperationState(boolean read,
java.nio.ByteBuffer[] buffers,
int offset,
int length,
SocketWrapperBase.BlockingMode block,
long timeout,
java.util.concurrent.TimeUnit unit,
A attachment,
SocketWrapperBase.CompletionCheck check,
java.nio.channels.CompletionHandler<java.lang.Long,? super A> handler,
java.util.concurrent.Semaphore semaphore,
SocketWrapperBase.VectoredIOCompletionHandler<A> completion) |
Modifier and Type | Method | 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 java.nio.ByteBuffer[] buffers
protected final int offset
protected final int length
protected final A attachment
protected final long timeout
protected final java.util.concurrent.TimeUnit unit
protected final SocketWrapperBase.BlockingMode block
protected final SocketWrapperBase.CompletionCheck check
protected final java.nio.channels.CompletionHandler<java.lang.Long,? super A> handler
protected final java.util.concurrent.Semaphore semaphore
protected final SocketWrapperBase.VectoredIOCompletionHandler<A> completion
protected volatile long nBytes
protected volatile SocketWrapperBase.CompletionState state
protected boolean completionDone
protected OperationState(boolean read, java.nio.ByteBuffer[] buffers, int offset, int length, SocketWrapperBase.BlockingMode block, long timeout, java.util.concurrent.TimeUnit unit, A attachment, SocketWrapperBase.CompletionCheck check, java.nio.channels.CompletionHandler<java.lang.Long,? super A> handler, java.util.concurrent.Semaphore semaphore, SocketWrapperBase.VectoredIOCompletionHandler<A> completion)
protected abstract boolean isInline()
protected boolean process()
protected void start()
protected void end()
Copyright © 2000-2019 Apache Software Foundation. All Rights Reserved.