Package org.eclipse.jetty.http2
Class AbstractFlowControlStrategy
- java.lang.Object
-
- org.eclipse.jetty.http2.AbstractFlowControlStrategy
-
- All Implemented Interfaces:
FlowControlStrategy
,org.eclipse.jetty.util.component.Dumpable
- Direct Known Subclasses:
BufferingFlowControlStrategy
,SimpleFlowControlStrategy
@ManagedObject public abstract class AbstractFlowControlStrategy extends java.lang.Object implements FlowControlStrategy, org.eclipse.jetty.util.component.Dumpable
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable
org.eclipse.jetty.util.component.Dumpable.DumpableContainer
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.http2.FlowControlStrategy
FlowControlStrategy.Factory
-
-
Field Summary
Fields Modifier and Type Field Description private int
initialStreamRecvWindow
private int
initialStreamSendWindow
protected static org.eclipse.jetty.util.log.Logger
LOG
private java.util.concurrent.atomic.AtomicLong
sessionStall
private java.util.concurrent.atomic.AtomicLong
sessionStallTime
private java.util.Map<IStream,java.lang.Long>
streamsStalls
private java.util.concurrent.atomic.AtomicLong
streamsStallTime
-
Fields inherited from interface org.eclipse.jetty.http2.FlowControlStrategy
DEFAULT_WINDOW_SIZE
-
-
Constructor Summary
Constructors Constructor Description AbstractFlowControlStrategy(int initialStreamSendWindow)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
dump()
void
dump(java.lang.Appendable out, java.lang.String indent)
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.http2.FlowControlStrategy
onDataConsumed
-
-
-
-
Field Detail
-
LOG
protected static final org.eclipse.jetty.util.log.Logger LOG
-
sessionStall
private final java.util.concurrent.atomic.AtomicLong sessionStall
-
sessionStallTime
private final java.util.concurrent.atomic.AtomicLong sessionStallTime
-
streamsStalls
private final java.util.Map<IStream,java.lang.Long> streamsStalls
-
streamsStallTime
private final java.util.concurrent.atomic.AtomicLong streamsStallTime
-
initialStreamSendWindow
private int initialStreamSendWindow
-
initialStreamRecvWindow
private int initialStreamRecvWindow
-
-
Method Detail
-
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 interfaceFlowControlStrategy
-
onStreamDestroyed
public void onStreamDestroyed(IStream stream)
- Specified by:
onStreamDestroyed
in interfaceFlowControlStrategy
-
updateInitialStreamWindow
public void updateInitialStreamWindow(ISession session, int initialStreamWindow, boolean local)
- Specified by:
updateInitialStreamWindow
in interfaceFlowControlStrategy
-
onWindowUpdate
public void onWindowUpdate(ISession session, IStream stream, WindowUpdateFrame frame)
- Specified by:
onWindowUpdate
in interfaceFlowControlStrategy
-
onDataReceived
public void onDataReceived(ISession session, IStream stream, int length)
- Specified by:
onDataReceived
in interfaceFlowControlStrategy
-
windowUpdate
public void windowUpdate(ISession session, IStream stream, WindowUpdateFrame frame)
- Specified by:
windowUpdate
in interfaceFlowControlStrategy
-
onDataSending
public void onDataSending(IStream stream, int length)
- Specified by:
onDataSending
in interfaceFlowControlStrategy
-
onDataSent
public void onDataSent(IStream stream, int length)
- Specified by:
onDataSent
in interfaceFlowControlStrategy
-
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 java.lang.String dump()
- Specified by:
dump
in interfaceorg.eclipse.jetty.util.component.Dumpable
-
dump
public void dump(java.lang.Appendable out, java.lang.String indent) throws java.io.IOException
- Specified by:
dump
in interfaceorg.eclipse.jetty.util.component.Dumpable
- Throws:
java.io.IOException
-
-