Class AbstractFlowControlStrategy

java.lang.Object

org.eclipse.jetty.http2.AbstractFlowControlStrategy

All Implemented Interfaces:

FlowControlStrategy, Dumpable

Direct Known Subclasses:

BufferingFlowControlStrategy, SimpleFlowControlStrategy

@ManagedObject
public abstract class AbstractFlowControlStrategy
extends Object
implements FlowControlStrategy, Dumpable

Nested Class Summary

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer, Dumpable.DumpAppendable

Nested classes/interfaces inherited from interface FlowControlStrategy

FlowControlStrategy.Factory

Field Summary

Fields inherited from interface Dumpable

LEGEND

Fields inherited from interface FlowControlStrategy

DEFAULT_WINDOW_SIZE

Constructor Summary

Constructors

Constructor	Description
AbstractFlowControlStrategy(int initialStreamSendWindow)

Method Summary

Modifier and Type	Method	Description
String	dump()
void	dump(Appendable out, String indent)	Dump this object (and children) into an Appendable using the provided indent after any new lines.
int	getInitialStreamRecvWindow()
int	getInitialStreamSendWindow()
long	getSessionStallTime()
long	getStreamsStallTime()
void	onDataReceived(Session session, Stream stream, int length)
void	onDataSending(Stream stream, int length)
void	onDataSent(Stream stream, int length)
protected void	onSessionStalled(Session session)
protected void	onSessionUnstalled(Session session)
void	onStreamCreated(Stream stream)
void	onStreamDestroyed(Stream stream)
protected void	onStreamStalled(Stream stream)
protected void	onStreamUnstalled(Stream stream)
void	onWindowUpdate(Session session, Stream stream, WindowUpdateFrame frame)
void	reset()
protected void	sendWindowUpdate(Session session, Stream stream, List<WindowUpdateFrame> frames)
void	updateInitialStreamWindow(Session session, int initialStreamWindow, boolean local)
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)
void	windowUpdate(Session session, Stream stream, WindowUpdateFrame frame)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Dumpable

dumpSelf

Methods inherited from interface FlowControlStrategy

onDataConsumed

Constructor Details

AbstractFlowControlStrategy

public AbstractFlowControlStrategy(int initialStreamSendWindow)

Method Details

getInitialStreamSendWindow

@ManagedAttribute(value="The initial size of stream's flow control send window",
                  readonly=true)
public int getInitialStreamSendWindow()

getInitialStreamRecvWindow

@ManagedAttribute(value="The initial size of stream's flow control receive window",
                  readonly=true)
public int getInitialStreamRecvWindow()

onStreamCreated

public void onStreamCreated(Stream stream)

Specified by:

onStreamCreated in interface FlowControlStrategy

onStreamDestroyed

public void onStreamDestroyed(Stream stream)

Specified by:

onStreamDestroyed in interface FlowControlStrategy

updateInitialStreamWindow

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

Specified by:

updateInitialStreamWindow in interface FlowControlStrategy

onWindowUpdate

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

Specified by:

onWindowUpdate in interface FlowControlStrategy

onDataReceived

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

Specified by:

onDataReceived in interface FlowControlStrategy

windowUpdate

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

Specified by:

windowUpdate in interface FlowControlStrategy

onDataSending

public void onDataSending(Stream stream,
 int length)

Specified by:

onDataSending in interface FlowControlStrategy

onDataSent

public void onDataSent(Stream stream,
 int length)

Specified by:

onDataSent in interface FlowControlStrategy

updateWindow

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

updateRecvWindow

protected int updateRecvWindow(Session session,
 int value)

updateSendWindow

protected int updateSendWindow(Session session,
 int value)

updateRecvWindow

protected int updateRecvWindow(Stream stream,
 int value)

updateSendWindow

protected int updateSendWindow(Stream stream,
 int value)

sendWindowUpdate

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

onSessionStalled

protected void onSessionStalled(Session session)

onStreamStalled

protected void onStreamStalled(Stream stream)

onSessionUnstalled

protected void onSessionUnstalled(Session session)

onStreamUnstalled

protected void onStreamUnstalled(Stream stream)

getSessionStallTime

@ManagedAttribute(value="The time, in milliseconds, that the session flow control has stalled",
                  readonly=true)
public long getSessionStallTime()

getStreamsStallTime

@ManagedAttribute(value="The time, in milliseconds, that the streams flow control has stalled",
                  readonly=true)
public long getStreamsStallTime()

reset

@ManagedOperation(value="Resets the statistics",
                  impact="ACTION")
public void reset()

dump

public String dump()

Specified by:

dump in interface Dumpable

dump

public void dump(Appendable out,
 String indent)
          throws IOException

Description copied from interface: Dumpable

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.

Specified by:

dump in interface Dumpable

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

IOException - if unable to write to Appendable