Package org.eclipse.jetty.http2

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 org.eclipse.jetty.util.component.Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface org.eclipse.jetty.http2.FlowControlStrategy

FlowControlStrategy.Factory

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	LOG

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Fields inherited from interface org.eclipse.jetty.http2.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(ISession session, IStream stream, int length)
void	onDataSending(IStream stream, int length)
void	onDataSent(IStream stream, int length)
protected void	onSessionStalled(ISession session)
protected void	onSessionUnstalled(ISession session)
void	onStreamCreated(IStream stream)
void	onStreamDestroyed(IStream stream)
protected void	onStreamStalled(IStream stream)
protected void	onStreamUnstalled(IStream stream)
void	onWindowUpdate(ISession session, IStream stream, WindowUpdateFrame frame)
void	reset()
void	updateInitialStreamWindow(ISession session, int initialStreamWindow, boolean local)
void	windowUpdate(ISession session, IStream stream, WindowUpdateFrame frame)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dumpSelf

Methods inherited from interface org.eclipse.jetty.http2.FlowControlStrategy

onDataConsumed

Field Details

LOG

protected static final org.slf4j.Logger LOG

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(IStream stream)

Specified by:

onStreamCreated in interface FlowControlStrategy

onStreamDestroyed

public void onStreamDestroyed(IStream stream)

Specified by:

onStreamDestroyed in interface FlowControlStrategy

updateInitialStreamWindow

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

Specified by:

updateInitialStreamWindow in interface FlowControlStrategy

onWindowUpdate

public void onWindowUpdate(ISession session,
 IStream stream,
 WindowUpdateFrame frame)

Specified by:

onWindowUpdate in interface FlowControlStrategy

onDataReceived

public void onDataReceived(ISession session,
 IStream stream,
 int length)

Specified by:

onDataReceived in interface FlowControlStrategy

windowUpdate

public void windowUpdate(ISession session,
 IStream stream,
 WindowUpdateFrame frame)

Specified by:

windowUpdate in interface FlowControlStrategy

onDataSending

public void onDataSending(IStream stream,
 int length)

Specified by:

onDataSending in interface FlowControlStrategy

onDataSent

public void onDataSent(IStream stream,
 int length)

Specified by:

onDataSent in interface FlowControlStrategy

onSessionStalled

protected void onSessionStalled(ISession session)

onStreamStalled

protected void onStreamStalled(IStream stream)

onSessionUnstalled

protected void onSessionUnstalled(ISession session)

onStreamUnstalled

protected void onStreamUnstalled(IStream 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