Renamed ISession.control() to ISession.frames().

This commit is contained in:
Simone Bordet 2015-03-20 15:02:07 +01:00
parent 4107444beb
commit 2a21f8cb2f
7 changed files with 11 additions and 11 deletions

View File

@ -114,11 +114,11 @@ public class HTTP2ClientConnectionFactory implements ClientConnectionFactory
if (windowDelta > 0) if (windowDelta > 0)
{ {
session.updateRecvWindow(windowDelta); session.updateRecvWindow(windowDelta);
session.control(null, this, prefaceFrame, settingsFrame, new WindowUpdateFrame(0, windowDelta)); session.frames(null, this, prefaceFrame, settingsFrame, new WindowUpdateFrame(0, windowDelta));
} }
else else
{ {
session.control(null, this, prefaceFrame, settingsFrame); session.frames(null, this, prefaceFrame, settingsFrame);
} }
} }

View File

@ -138,7 +138,7 @@ public class BufferingFlowControlStrategy extends AbstractFlowControlStrategy
} }
if (windowFrame != null) if (windowFrame != null)
session.control(stream, Callback.Adapter.INSTANCE, windowFrame, windowFrames); session.frames(stream, Callback.Adapter.INSTANCE, windowFrame, windowFrames);
} }
@Override @Override

View File

@ -537,11 +537,11 @@ public abstract class HTTP2Session implements ISession, Parser.Listener
private void control(IStream stream, Callback callback, Frame frame) private void control(IStream stream, Callback callback, Frame frame)
{ {
control(stream, callback, frame, Frame.EMPTY_ARRAY); frames(stream, callback, frame, Frame.EMPTY_ARRAY);
} }
@Override @Override
public void control(IStream stream, Callback callback, Frame frame, Frame... frames) public void frames(IStream stream, Callback callback, Frame frame, Frame... frames)
{ {
// We want to generate as late as possible to allow re-prioritization; // We want to generate as late as possible to allow re-prioritization;
// generation will happen while processing the entries. // generation will happen while processing the entries.

View File

@ -76,7 +76,7 @@ public class HTTP2Stream extends IdleTimeout implements IStream
public void headers(HeadersFrame frame, Callback callback) public void headers(HeadersFrame frame, Callback callback)
{ {
notIdle(); notIdle();
session.control(this, callback, frame, Frame.EMPTY_ARRAY); session.frames(this, callback, frame, Frame.EMPTY_ARRAY);
} }
@Override @Override
@ -100,7 +100,7 @@ public class HTTP2Stream extends IdleTimeout implements IStream
return; return;
notIdle(); notIdle();
localReset = true; localReset = true;
session.control(this, callback, frame, Frame.EMPTY_ARRAY); session.frames(this, callback, frame, Frame.EMPTY_ARRAY);
} }
@Override @Override

View File

@ -53,11 +53,11 @@ public interface ISession extends Session
* @param frame the first frame to enqueue * @param frame the first frame to enqueue
* @param frames additional frames to enqueue * @param frames additional frames to enqueue
*/ */
public void control(IStream stream, Callback callback, Frame frame, Frame... frames); public void frames(IStream stream, Callback callback, Frame frame, Frame... frames);
/** /**
* <p>Enqueues the given PUSH_PROMISE frame to be written to the connection.</p> * <p>Enqueues the given PUSH_PROMISE frame to be written to the connection.</p>
* <p>Differently from {@link #control(IStream, Callback, Frame, Frame...)}, this method * <p>Differently from {@link #frames(IStream, Callback, Frame, Frame...)}, this method
* generates atomically the stream id for the pushed stream.</p> * generates atomically the stream id for the pushed stream.</p>
* *
* @param stream the stream associated to the pushed stream * @param stream the stream associated to the pushed stream

View File

@ -67,6 +67,6 @@ public class SimpleFlowControlStrategy extends AbstractFlowControlStrategy
} }
} }
session.control(stream, Callback.Adapter.INSTANCE, sessionFrame, streamFrame); session.frames(stream, Callback.Adapter.INSTANCE, sessionFrame, streamFrame);
} }
} }

View File

@ -62,7 +62,7 @@ public class HTTP2ServerSession extends HTTP2Session implements ServerParser.Lis
settings = Collections.emptyMap(); settings = Collections.emptyMap();
SettingsFrame frame = new SettingsFrame(settings, false); SettingsFrame frame = new SettingsFrame(settings, false);
// TODO: consider sending a WINDOW_UPDATE to enlarge the session send window of the client. // TODO: consider sending a WINDOW_UPDATE to enlarge the session send window of the client.
control(null, Callback.Adapter.INSTANCE, frame, Frame.EMPTY_ARRAY); frames(null, Callback.Adapter.INSTANCE, frame, Frame.EMPTY_ARRAY);
} }
@Override @Override