Top Fields Constructors Methods
org.eclipse.jetty.http2

public abstract Class AbstractFlowControlStrategy

extends Object
implements FlowControlStrategy, Dumpable
Class Inheritance
All Implemented Interfaces
org.eclipse.jetty.util.component.Dumpable, org.eclipse.jetty.http2.FlowControlStrategy
Known Direct Subclasses
org.eclipse.jetty.http2.BufferingFlowControlStrategy, org.eclipse.jetty.http2.SimpleFlowControlStrategy
Annotations
@ManagedObject
Imports
java.io.IOException, java.util.List, .Map, java.util.concurrent.ConcurrentHashMap, .TimeUnit, java.util.concurrent.atomic.AtomicLong, org.eclipse.jetty.http2.api.Session, .Stream, org.eclipse.jetty.http2.frames.WindowUpdateFrame, org.eclipse.jetty.util.Callback, .NanoTime, org.eclipse.jetty.util.annotation.ManagedAttribute, .ManagedObject, .ManagedOperation, org.eclipse.jetty.util.component.Dumpable, org.slf4j.Logger, .LoggerFactory

Field Summary

Modifier and TypeField and Description
private int
initialStreamRecvWindow

private int
initialStreamSendWindow

private static final Logger
LOG

private final AtomicLong
sessionStall

private final AtomicLong
sessionStallTime

private final Map<Stream, Long>
streamsStalls

private final AtomicLong
streamsStallTime

Constructor Summary

AccessConstructor and Description
public
AbstractFlowControlStrategy(int initialStreamSendWindow)

Method Summary

Modifier and TypeMethod and Description
public String
dump()

Overrides default org.eclipse.jetty.util.component.Dumpable.dump.

public void
dump(Appendable
The appendable to dump to
out, String
The indent to apply after any new lines.
indent)

Implements org.eclipse.jetty.util.component.Dumpable.dump.

Dump this object (and children) into an Appendable using the provided indent after any new lines.

public int
getInitialStreamRecvWindow()

public int
getInitialStreamSendWindow()

public long
getSessionStallTime()

public long
getStreamsStallTime()

public void
onDataReceived(Session session, Stream stream, int length)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onDataReceived.

public void
onDataSending(Stream stream, int length)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onDataSending.

public void
onDataSent(Stream stream, int length)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onDataSent.

protected void
onSessionStalled(Session session)

protected void
onSessionUnstalled(Session session)

public void
onStreamCreated(Stream stream)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onStreamCreated.

public void
onStreamDestroyed(Stream stream)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onStreamDestroyed.

protected void
onStreamStalled(Stream stream)

protected void
onStreamUnstalled(Stream stream)

public void
onWindowUpdate(Session session, Stream stream, WindowUpdateFrame frame)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onWindowUpdate.

public void
reset()

protected void
sendWindowUpdate(Session session, Stream stream, List<WindowUpdateFrame> frames)

public void
updateInitialStreamWindow(Session session, int initialStreamWindow, boolean local)

Implements org.eclipse.jetty.http2.FlowControlStrategy.updateInitialStreamWindow.

protected int
updateRecvWindow(Session session, int value)

protected int
updateRecvWindow(Stream stream, int value)

protected int
updateSendWindow(Session session, int value)

protected int
updateSendWindow(Stream stream, int value)

protected void
updateWindow(Session session, Stream stream, WindowUpdateFrame frame)

public void
windowUpdate(Session session, Stream stream, WindowUpdateFrame frame)

Implements org.eclipse.jetty.http2.FlowControlStrategy.windowUpdate.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

initialStreamRecvWindowback to summary
private int initialStreamRecvWindow
initialStreamSendWindowback to summary
private int initialStreamSendWindow
LOGback to summary
private static final Logger LOG
sessionStallback to summary
private final AtomicLong sessionStall
sessionStallTimeback to summary
private final AtomicLong sessionStallTime
streamsStallsback to summary
private final Map<Stream, Long> streamsStalls
streamsStallTimeback to summary
private final AtomicLong streamsStallTime

Constructor Detail

AbstractFlowControlStrategyback to summary
public AbstractFlowControlStrategy(int initialStreamSendWindow)

Method Detail

dumpback to summary
public String dump()

Overrides default org.eclipse.jetty.util.component.Dumpable.dump.

Annotations
@Override
dumpback to summary
public void dump(Appendable out, String indent) throws IOException

Implements org.eclipse.jetty.util.component.Dumpable.dump.

Doc from org.eclipse.jetty.util.component.Dumpable.dump.

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Parameters
out:Appendable

The appendable to dump to

indent:String

The indent to apply after any new lines.

Annotations
@Override
Exceptions
IOException:
if unable to write to Appendable
getInitialStreamRecvWindowback to summary
public int getInitialStreamRecvWindow()
Annotations
@ManagedAttribute:The initial size of stream\'s flow control receive window
readonly:true
getInitialStreamSendWindowback to summary
public int getInitialStreamSendWindow()
Annotations
@ManagedAttribute:The initial size of stream\'s flow control send window
readonly:true
getSessionStallTimeback to summary
public long getSessionStallTime()
Annotations
@ManagedAttribute:The time, in milliseconds, that the session flow control has stalled
readonly:true
getStreamsStallTimeback to summary
public long getStreamsStallTime()
Annotations
@ManagedAttribute:The time, in milliseconds, that the streams flow control has stalled
readonly:true
onDataReceivedback to summary
public void onDataReceived(Session session, Stream stream, int length)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onDataReceived.

Annotations
@Override
onDataSendingback to summary
public void onDataSending(Stream stream, int length)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onDataSending.

Annotations
@Override
onDataSentback to summary
public void onDataSent(Stream stream, int length)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onDataSent.

Annotations
@Override
onSessionStalledback to summary
protected void onSessionStalled(Session session)
onSessionUnstalledback to summary
protected void onSessionUnstalled(Session session)
onStreamCreatedback to summary
public void onStreamCreated(Stream stream)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onStreamCreated.

Annotations
@Override
onStreamDestroyedback to summary
public void onStreamDestroyed(Stream stream)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onStreamDestroyed.

Annotations
@Override
onStreamStalledback to summary
protected void onStreamStalled(Stream stream)
onStreamUnstalledback to summary
protected void onStreamUnstalled(Stream stream)
onWindowUpdateback to summary
public void onWindowUpdate(Session session, Stream stream, WindowUpdateFrame frame)

Implements org.eclipse.jetty.http2.FlowControlStrategy.onWindowUpdate.

Annotations
@Override
resetback to summary
public void reset()
Annotations
@ManagedOperation:Resets the statistics
impact:ACTION
sendWindowUpdateback to summary
protected void sendWindowUpdate(Session session, Stream stream, List<WindowUpdateFrame> frames)
updateInitialStreamWindowback to summary
public void updateInitialStreamWindow(Session session, int initialStreamWindow, boolean local)

Implements org.eclipse.jetty.http2.FlowControlStrategy.updateInitialStreamWindow.

Annotations
@Override
updateRecvWindowback to summary
protected int updateRecvWindow(Session session, int value)
updateRecvWindowback to summary
protected int updateRecvWindow(Stream stream, int value)
updateSendWindowback to summary
protected int updateSendWindow(Session session, int value)
updateSendWindowback to summary
protected int updateSendWindow(Stream stream, int value)
updateWindowback to summary
protected void updateWindow(Session session, Stream stream, WindowUpdateFrame frame)
windowUpdateback to summary
public void windowUpdate(Session session, Stream stream, WindowUpdateFrame frame)

Implements org.eclipse.jetty.http2.FlowControlStrategy.windowUpdate.

Annotations
@Override