@ManagedObject public abstract class AbstractFlowControlStrategy extends Object implements FlowControlStrategy, Dumpable
FlowControlStrategy.Factory
Modifier and Type | Field and Description |
---|---|
protected static Logger |
LOG |
DEFAULT_WINDOW_SIZE
Constructor and Description |
---|
AbstractFlowControlStrategy(int initialStreamSendWindow) |
Modifier and Type | Method and Description |
---|---|
String |
dump() |
void |
dump(Appendable out,
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onDataConsumed
protected static final Logger LOG
public AbstractFlowControlStrategy(int initialStreamSendWindow)
@ManagedAttribute(value="The initial size of stream\'s flow control send window", readonly=true) public int getInitialStreamSendWindow()
@ManagedAttribute(value="The initial size of stream\'s flow control receive window", readonly=true) public int getInitialStreamRecvWindow()
public void onStreamCreated(IStream stream)
onStreamCreated
in interface FlowControlStrategy
public void onStreamDestroyed(IStream stream)
onStreamDestroyed
in interface FlowControlStrategy
public void updateInitialStreamWindow(ISession session, int initialStreamWindow, boolean local)
updateInitialStreamWindow
in interface FlowControlStrategy
public void onWindowUpdate(ISession session, IStream stream, WindowUpdateFrame frame)
onWindowUpdate
in interface FlowControlStrategy
public void onDataReceived(ISession session, IStream stream, int length)
onDataReceived
in interface FlowControlStrategy
public void windowUpdate(ISession session, IStream stream, WindowUpdateFrame frame)
windowUpdate
in interface FlowControlStrategy
public void onDataSending(IStream stream, int length)
onDataSending
in interface FlowControlStrategy
public void onDataSent(IStream stream, int length)
onDataSent
in interface FlowControlStrategy
protected void onSessionStalled(ISession session)
protected void onStreamStalled(IStream stream)
protected void onSessionUnstalled(ISession session)
protected void onStreamUnstalled(IStream stream)
@ManagedAttribute(value="The time, in milliseconds, that the session flow control has stalled", readonly=true) public long getSessionStallTime()
@ManagedAttribute(value="The time, in milliseconds, that the streams flow control has stalled", readonly=true) public long getStreamsStallTime()
@ManagedOperation(value="Resets the statistics", impact="ACTION") public void reset()
public void dump(Appendable out, String indent) throws IOException
dump
in interface Dumpable
IOException
Copyright © 1995-2016 Webtide. All Rights Reserved.