Class FrameFlusher
java.lang.Object
org.eclipse.jetty.util.IteratingCallback
org.eclipse.jetty.websocket.common.io.FrameFlusher
- All Implemented Interfaces:
org.eclipse.jetty.util.Callback
,org.eclipse.jetty.util.thread.Invocable
- Direct Known Subclasses:
AbstractWebSocketConnection.Flusher
public class FrameFlusher
extends org.eclipse.jetty.util.IteratingCallback
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class org.eclipse.jetty.util.IteratingCallback
org.eclipse.jetty.util.IteratingCallback.Action
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.Callback
org.eclipse.jetty.util.Callback.Completable, org.eclipse.jetty.util.Callback.Completing, org.eclipse.jetty.util.Callback.Nested
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.Invocable
org.eclipse.jetty.util.thread.Invocable.InvocationType
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate ByteBuffer
private BatchMode
private final org.eclipse.jetty.io.ByteBufferPool
private final List
<ByteBuffer> private final int
private final LongAdder
private boolean
private boolean
private final org.eclipse.jetty.io.EndPoint
private final List
<FrameFlusher.FrameEntry> static final BinaryFrame
private final Generator
private static final org.eclipse.jetty.util.log.Logger
private final int
private final LongAdder
private final Deque
<FrameFlusher.FrameEntry> private Throwable
Fields inherited from interface org.eclipse.jetty.util.Callback
NOOP
Fields inherited from interface org.eclipse.jetty.util.thread.Invocable
__nonBlocking
-
Constructor Summary
ConstructorsConstructorDescriptionFrameFlusher
(org.eclipse.jetty.io.ByteBufferPool bufferPool, Generator generator, org.eclipse.jetty.io.EndPoint endPoint, int bufferSize, int maxGather) -
Method Summary
Modifier and TypeMethodDescriptionprivate org.eclipse.jetty.util.IteratingCallback.Action
batch()
boolean
enqueue
(Frame frame, WriteCallback callback, BatchMode batchMode) private org.eclipse.jetty.util.IteratingCallback.Action
flush()
long
long
private int
protected void
notifyCallbackFailure
(WriteCallback callback, Throwable failure) protected void
notifyCallbackSuccess
(WriteCallback callback) void
onCompleteFailure
(Throwable failure) protected org.eclipse.jetty.util.IteratingCallback.Action
process()
private void
void
private void
(package private) void
toString()
Methods inherited from class org.eclipse.jetty.util.IteratingCallback
close, failed, isClosed, isFailed, isSucceeded, iterate, onCompleteSuccess, reset
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.thread.Invocable
getInvocationType
-
Field Details
-
FLUSH_FRAME
-
LOG
private static final org.eclipse.jetty.util.log.Logger LOG -
bufferPool
private final org.eclipse.jetty.io.ByteBufferPool bufferPool -
endPoint
private final org.eclipse.jetty.io.EndPoint endPoint -
bufferSize
private final int bufferSize -
generator
-
maxGather
private final int maxGather -
queue
-
entries
-
buffers
-
messagesOut
-
bytesOut
-
closed
private boolean closed -
canEnqueue
private boolean canEnqueue -
terminated
-
aggregate
-
batchMode
-
-
Constructor Details
-
FrameFlusher
public FrameFlusher(org.eclipse.jetty.io.ByteBufferPool bufferPool, Generator generator, org.eclipse.jetty.io.EndPoint endPoint, int bufferSize, int maxGather)
-
-
Method Details
-
enqueue
-
process
- Specified by:
process
in classorg.eclipse.jetty.util.IteratingCallback
- Throws:
Throwable
-
batch
private org.eclipse.jetty.util.IteratingCallback.Action batch() -
flush
private org.eclipse.jetty.util.IteratingCallback.Action flush() -
getQueueSize
private int getQueueSize() -
succeeded
public void succeeded()- Specified by:
succeeded
in interfaceorg.eclipse.jetty.util.Callback
- Overrides:
succeeded
in classorg.eclipse.jetty.util.IteratingCallback
-
succeedEntries
private void succeedEntries() -
onCompleteFailure
- Overrides:
onCompleteFailure
in classorg.eclipse.jetty.util.IteratingCallback
-
releaseAggregate
private void releaseAggregate() -
terminate
-
notifyCallbackSuccess
-
notifyCallbackFailure
-
getMessagesOut
public long getMessagesOut() -
getBytesOut
public long getBytesOut() -
toString
- Overrides:
toString
in classorg.eclipse.jetty.util.IteratingCallback
-