Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Enabled flow control configuration in SPDYClient.

This commit is contained in:
Simone Bordet 2012-05-26 22:49:43 +02:00
parent 0ea58ab1d5
commit 58dd9c3bf1
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/SPDYClient.java
View File

@ -64,6 +64,7 @@ public class SPDYClient
private final Factory factory;
private SocketAddress bindAddress;
private long maxIdleTime = -1;
private boolean flowControlEnabled = true;
protected SPDYClient(short version, Factory factory)
{
@ -118,6 +119,16 @@ public class SPDYClient
this.maxIdleTime = maxIdleTime;
}
public boolean isFlowControlEnabled()
{
return flowControlEnabled;
}
public void setFlowControlEnabled(boolean flowControlEnabled)
{
this.flowControlEnabled = flowControlEnabled;
}
protected String selectProtocol(List<String> serverProtocols)
{
if (serverProtocols == null)
@ -419,7 +430,8 @@ public class SPDYClient
public AsyncConnection newAsyncConnection(SocketChannel channel, AsyncEndPoint endPoint, Object attachment)
{
SessionPromise sessionPromise = (SessionPromise)attachment;
Factory factory = sessionPromise.client.factory;
SPDYClient client = sessionPromise.client;
Factory factory = client.factory;
CompressionFactory compressionFactory = new StandardCompressionFactory();
Parser parser = new Parser(compressionFactory.newDecompressor());
@ -428,7 +440,8 @@ public class SPDYClient
SPDYAsyncConnection connection = new ClientSPDYAsyncConnection(endPoint, factory.bufferPool, parser, factory);
endPoint.setConnection(connection);
StandardSession session = new StandardSession(sessionPromise.client.version, factory.bufferPool, factory.threadPool, factory.scheduler, connection, connection, 1, sessionPromise.listener, generator);
StandardSession session = new StandardSession(client.version, factory.bufferPool, factory.threadPool, factory.scheduler, connection, connection, 1, sessionPromise.listener, generator);
session.setFlowControlEnabled(client.isFlowControlEnabled());
parser.addListener(session);
sessionPromise.completed(session);
connection.setSession(session);