Class ControlFlusher
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.jetty.util.IteratingCallback
IteratingCallback.Action
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback
Callback.Combination, Callback.Completable, Callback.Completing, Callback.Nested
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable
Invocable.Callable, Invocable.InvocationType, Invocable.ReadyTask, Invocable.Task
-
Field Summary
Fields inherited from interface org.eclipse.jetty.util.Callback
NOOP, NOT_CALLED
Fields inherited from interface org.eclipse.jetty.util.thread.Invocable
__nonBlocking
-
Constructor Summary
ConstructorsConstructorDescriptionControlFlusher
(ByteBufferPool byteBufferPool, StreamEndPoint endPoint, boolean useDirectByteBuffers) -
Method Summary
Modifier and TypeMethodDescriptionboolean
protected void
onCompleteFailure
(Throwable cause) Invoked when the overall task has completed with a failure.protected void
protected void
Invoked when one task has completed successfully, either by the caller thread or by the processing thread.protected IteratingCallback.Action
process()
Method called byIteratingCallback.iterate()
to process the asynchronous sub-task.toString()
Methods inherited from class org.eclipse.jetty.util.IteratingCallback
abort, close, failed, isAborted, isClosed, isFailed, isSucceeded, iterate, onAborted, onCompleted, onCompleteSuccess, reset, succeeded
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.eclipse.jetty.util.Callback
completeWith
-
Constructor Details
-
ControlFlusher
public ControlFlusher(ByteBufferPool byteBufferPool, StreamEndPoint endPoint, boolean useDirectByteBuffers)
-
-
Method Details
-
offer
-
process
Description copied from class:IteratingCallback
Method called byIteratingCallback.iterate()
to process the asynchronous sub-task.Implementations must initiate the asynchronous execution of the sub-task (if any) and return an appropriate action:
IteratingCallback.Action.IDLE
when no sub tasks are available for execution but the overall job is not completed yetIteratingCallback.Action.SCHEDULED
when the sub task asynchronous execution has been startedIteratingCallback.Action.SUCCEEDED
when the overall job is completed
- Specified by:
process
in classIteratingCallback
- Returns:
- the appropriate Action
-
onSuccess
protected void onSuccess()Description copied from class:IteratingCallback
Invoked when one task has completed successfully, either by the caller thread or by the processing thread. This invocation is always serialized w.r.t the execution ofIteratingCallback.process()
.This method is not invoked when a call to
IteratingCallback.abort(Throwable)
is made before theIteratingCallback.succeeded()
callback happens.- Overrides:
onSuccess
in classIteratingCallback
-
onFailure
Description copied from class:IteratingCallback
Invoked when the overall task has beenaborted
orfailed
.Calls to this method are serialized with respect to
IteratingCallback.onAborted(Throwable)
,IteratingCallback.process()
,IteratingCallback.onCompleteFailure(Throwable)
andIteratingCallback.onCompleted(Throwable)
.Because
onFailure
can be called due to anIteratingCallback.abort(Throwable)
orIteratingCallback.close()
operation, it is possible that any resources passed to aIteratingCallback.Action.SCHEDULED
operation may still be in use, and thus should not be recycled by this call. For example any buffers passed to a write operation should not be returned to a buffer pool by implementations ofonFailure
. Such resources may be discarded here, or safely recycled in a subsequent call toIteratingCallback.onCompleted(Throwable)
orIteratingCallback.onCompleteFailure(Throwable)
, when theIteratingCallback.Action.SCHEDULED
operation has completed.- Overrides:
onFailure
in classIteratingCallback
- Parameters:
failure
- The cause of the failure or abort- See Also:
-
onCompleteFailure
Description copied from class:IteratingCallback
Invoked when the overall task has completed with a failure.Calls to this method are serialized with respect to
IteratingCallback.process()
,IteratingCallback.onAborted(Throwable)
andIteratingCallback.onCompleted(Throwable)
. If this method is called, thenIteratingCallback.onCompleteSuccess()
will never be called.- Overrides:
onCompleteFailure
in classIteratingCallback
- Parameters:
cause
- the throwable to indicate cause of failure- See Also:
-
getInvocationType
- Returns:
- The InvocationType of this object
-
toString
- Overrides:
toString
in classIteratingCallback
-