Jetty9 - Renamed class removing "Async".

This commit is contained in:
Simone Bordet 2012-08-30 11:14:00 +02:00
parent 7586e5c9e9
commit 6531cbb69c
4 changed files with 10 additions and 10 deletions

View File

@ -52,9 +52,9 @@ public class HTTPSPDYServerConnector extends SPDYServerConnector
super(server, sslContextFactory, null); super(server, sslContextFactory, null);
clearConnectionFactories(); clearConnectionFactories();
// The "spdy/3" protocol handles HTTP over SPDY // The "spdy/3" protocol handles HTTP over SPDY
putConnectionFactory("spdy/3", new ServerHTTPSPDYAsyncConnectionFactory(SPDY.V3, getByteBufferPool(), getExecutor(), getScheduler(), this, getPushStrategy(SPDY.V3, pushStrategies))); putConnectionFactory("spdy/3", new ServerHTTPSPDYConnectionFactory(SPDY.V3, getByteBufferPool(), getExecutor(), getScheduler(), this, getPushStrategy(SPDY.V3, pushStrategies)));
// The "spdy/2" protocol handles HTTP over SPDY // The "spdy/2" protocol handles HTTP over SPDY
putConnectionFactory("spdy/2", new ServerHTTPSPDYAsyncConnectionFactory(SPDY.V2, getByteBufferPool(), getExecutor(), getScheduler(), this, getPushStrategy(SPDY.V2, pushStrategies))); putConnectionFactory("spdy/2", new ServerHTTPSPDYConnectionFactory(SPDY.V2, getByteBufferPool(), getExecutor(), getScheduler(), this, getPushStrategy(SPDY.V2, pushStrategies)));
// The "http/1.1" protocol handles browsers that support NPN but not SPDY // The "http/1.1" protocol handles browsers that support NPN but not SPDY
putConnectionFactory("http/1.1", new HttpServerConnectionFactory(this)); putConnectionFactory("http/1.1", new HttpServerConnectionFactory(this));
// The default connection factory handles plain HTTP on non-SSL or non-NPN connections // The default connection factory handles plain HTTP on non-SSL or non-NPN connections

View File

@ -38,16 +38,16 @@ import org.eclipse.jetty.spdy.api.server.ServerSessionFrameListener;
import org.eclipse.jetty.util.log.Log; import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger; import org.eclipse.jetty.util.log.Logger;
public class ServerHTTPSPDYAsyncConnectionFactory extends ServerSPDYConnectionFactory public class ServerHTTPSPDYConnectionFactory extends ServerSPDYConnectionFactory
{ {
private static final String CHANNEL_ATTRIBUTE = "org.eclipse.jetty.spdy.http.HTTPChannelOverSPDY"; private static final String CHANNEL_ATTRIBUTE = "org.eclipse.jetty.spdy.http.HTTPChannelOverSPDY";
private static final Logger logger = Log.getLogger(ServerHTTPSPDYAsyncConnectionFactory.class); private static final Logger logger = Log.getLogger(ServerHTTPSPDYConnectionFactory.class);
private final Connector connector; private final Connector connector;
private final PushStrategy pushStrategy; private final PushStrategy pushStrategy;
private final HttpConfiguration configuration; private final HttpConfiguration configuration;
public ServerHTTPSPDYAsyncConnectionFactory(short version, ByteBufferPool bufferPool, Executor threadPool, ScheduledExecutorService scheduler, Connector connector, PushStrategy pushStrategy) public ServerHTTPSPDYConnectionFactory(short version, ByteBufferPool bufferPool, Executor threadPool, ScheduledExecutorService scheduler, Connector connector, PushStrategy pushStrategy)
{ {
super(version, bufferPool, threadPool, scheduler); super(version, bufferPool, threadPool, scheduler);
this.connector = connector; this.connector = connector;

View File

@ -93,7 +93,7 @@ public abstract class AbstractHTTPSPDYTest
{ {
// For these tests, we need the connector to speak HTTP over SPDY even in non-SSL // For these tests, we need the connector to speak HTTP over SPDY even in non-SSL
SPDYServerConnector connector = new HTTPSPDYServerConnector(server); SPDYServerConnector connector = new HTTPSPDYServerConnector(server);
ConnectionFactory defaultFactory = new ServerHTTPSPDYAsyncConnectionFactory(version, connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, new PushStrategy.None()); ConnectionFactory defaultFactory = new ServerHTTPSPDYConnectionFactory(version, connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, new PushStrategy.None());
connector.setDefaultConnectionFactory(defaultFactory); connector.setDefaultConnectionFactory(defaultFactory);
return connector; return connector;
} }

View File

@ -57,7 +57,7 @@ public class ReferrerPushStrategyTest extends AbstractHTTPSPDYTest
protected SPDYServerConnector newHTTPSPDYServerConnector(short version) protected SPDYServerConnector newHTTPSPDYServerConnector(short version)
{ {
SPDYServerConnector connector = super.newHTTPSPDYServerConnector(version); SPDYServerConnector connector = super.newHTTPSPDYServerConnector(version);
ConnectionFactory defaultFactory = new ServerHTTPSPDYAsyncConnectionFactory(version, connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, new ReferrerPushStrategy()); ConnectionFactory defaultFactory = new ServerHTTPSPDYConnectionFactory(version, connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, new ReferrerPushStrategy());
connector.setDefaultConnectionFactory(defaultFactory); connector.setDefaultConnectionFactory(defaultFactory);
return connector; return connector;
} }
@ -70,7 +70,7 @@ public class ReferrerPushStrategyTest extends AbstractHTTPSPDYTest
ReferrerPushStrategy pushStrategy = new ReferrerPushStrategy(); ReferrerPushStrategy pushStrategy = new ReferrerPushStrategy();
int referrerPushPeriod = 1000; int referrerPushPeriod = 1000;
pushStrategy.setReferrerPushPeriod(referrerPushPeriod); pushStrategy.setReferrerPushPeriod(referrerPushPeriod);
ConnectionFactory defaultFactory = new ServerHTTPSPDYAsyncConnectionFactory(version, connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, pushStrategy); ConnectionFactory defaultFactory = new ServerHTTPSPDYConnectionFactory(version, connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, pushStrategy);
connector.setDefaultConnectionFactory(defaultFactory); connector.setDefaultConnectionFactory(defaultFactory);
Headers mainRequestHeaders = createHeadersWithoutReferrer(mainResource); Headers mainRequestHeaders = createHeadersWithoutReferrer(mainResource);
@ -92,7 +92,7 @@ public class ReferrerPushStrategyTest extends AbstractHTTPSPDYTest
ReferrerPushStrategy pushStrategy = new ReferrerPushStrategy(); ReferrerPushStrategy pushStrategy = new ReferrerPushStrategy();
int referrerPushPeriod = 1000; int referrerPushPeriod = 1000;
pushStrategy.setReferrerPushPeriod(referrerPushPeriod); pushStrategy.setReferrerPushPeriod(referrerPushPeriod);
ConnectionFactory defaultFactory = new ServerHTTPSPDYAsyncConnectionFactory(version, ConnectionFactory defaultFactory = new ServerHTTPSPDYConnectionFactory(version,
connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, pushStrategy); connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, pushStrategy);
connector.setDefaultConnectionFactory(defaultFactory); connector.setDefaultConnectionFactory(defaultFactory);
@ -114,7 +114,7 @@ public class ReferrerPushStrategyTest extends AbstractHTTPSPDYTest
ReferrerPushStrategy pushStrategy = new ReferrerPushStrategy(); ReferrerPushStrategy pushStrategy = new ReferrerPushStrategy();
pushStrategy.setMaxAssociatedResources(1); pushStrategy.setMaxAssociatedResources(1);
ConnectionFactory defaultFactory = new ServerHTTPSPDYAsyncConnectionFactory(version, ConnectionFactory defaultFactory = new ServerHTTPSPDYConnectionFactory(version,
connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, pushStrategy); connector.getByteBufferPool(), connector.getExecutor(), connector.getScheduler(), connector, pushStrategy);
connector.setDefaultConnectionFactory(defaultFactory); connector.setDefaultConnectionFactory(defaultFactory);