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

Jetty9 - SPDY cleanups.

This commit is contained in:
Simone Bordet 2012-08-03 19:16:57 +02:00
parent 103dcd7131
commit b1bb418fea
6 changed files with 20 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/EmptyAsyncEndPoint.java → jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/EmptyEndPoint.java
View File

@ -23,7 +23,7 @@ import org.eclipse.jetty.io.Connection;
import org.eclipse.jetty.io.EndPoint; import org.eclipse.jetty.io.EndPoint;
import org.eclipse.jetty.util.Callback; import org.eclipse.jetty.util.Callback;
public class EmptyAsyncEndPoint implements EndPoint public class EmptyEndPoint implements EndPoint
{ {
private boolean checkForIdle; private boolean checkForIdle;
private Connection connection; private Connection connection;

6
jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/NextProtoNegoClientAsyncConnection.java → jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/NextProtoNegoClientConnection.java
View File

@ -26,7 +26,7 @@ import org.eclipse.jetty.util.BufferUtil;
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 NextProtoNegoClientAsyncConnection extends AbstractConnection implements NextProtoNego.ClientProvider public class NextProtoNegoClientConnection extends AbstractConnection implements NextProtoNego.ClientProvider
{ {
private final Logger logger = Log.getLogger(getClass()); private final Logger logger = Log.getLogger(getClass());
private final SocketChannel channel; private final SocketChannel channel;
@ -34,7 +34,7 @@ public class NextProtoNegoClientAsyncConnection extends AbstractConnection imple
private final SPDYClient client; private final SPDYClient client;
private volatile boolean completed; private volatile boolean completed;
public NextProtoNegoClientAsyncConnection(SocketChannel channel, EndPoint endPoint, Object attachment, Executor executor, SPDYClient client) public NextProtoNegoClientConnection(SocketChannel channel, EndPoint endPoint, Object attachment, Executor executor, SPDYClient client)
{ {
super(endPoint, executor); super(endPoint, executor);
this.channel = channel; this.channel = channel;
@ -48,7 +48,7 @@ public class NextProtoNegoClientAsyncConnection extends AbstractConnection imple
super.onOpen(); super.onOpen();
fillInterested(); fillInterested();
} }
@Override @Override
public void onFillable() public void onFillable()
{ {

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

@ -347,7 +347,7 @@ public class SPDYClient
}; };
EndPoint sslEndPoint = sslConnection.getDecryptedEndPoint(); EndPoint sslEndPoint = sslConnection.getDecryptedEndPoint();
NextProtoNegoClientAsyncConnection connection = new NextProtoNegoClientAsyncConnection(channel, sslEndPoint, attachment, client.factory.threadPool, client); NextProtoNegoClientConnection connection = new NextProtoNegoClientConnection(channel, sslEndPoint, attachment, client.factory.threadPool, client);
sslEndPoint.setConnection(connection); sslEndPoint.setConnection(connection);
connectionOpened(connection); connectionOpened(connection);
@ -414,7 +414,7 @@ public class SPDYClient
Parser parser = new Parser(compressionFactory.newDecompressor()); Parser parser = new Parser(compressionFactory.newDecompressor());
Generator generator = new Generator(factory.bufferPool, compressionFactory.newCompressor()); Generator generator = new Generator(factory.bufferPool, compressionFactory.newCompressor());
SPDYAsyncConnection connection = new ClientSPDYAsyncConnection(endPoint, factory.bufferPool, parser, factory); SPDYConnection connection = new ClientSPDYConnection(endPoint, factory.bufferPool, parser, factory);
endPoint.setConnection(connection); endPoint.setConnection(connection);
FlowControlStrategy flowControlStrategy = client.newFlowControlStrategy(); FlowControlStrategy flowControlStrategy = client.newFlowControlStrategy();
@ -430,11 +430,11 @@ public class SPDYClient
return connection; return connection;
} }
private class ClientSPDYAsyncConnection extends SPDYAsyncConnection private class ClientSPDYConnection extends SPDYConnection
{ {
private final Factory factory; private final Factory factory;
public ClientSPDYAsyncConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Factory factory) public ClientSPDYConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Factory factory)
{ {
super(endPoint, bufferPool, parser, factory.threadPool); super(endPoint, bufferPool, parser, factory.threadPool);
this.factory = factory; this.factory = factory;

10
jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/SPDYAsyncConnection.java → jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/SPDYConnection.java
View File

@ -18,23 +18,23 @@ import java.nio.ByteBuffer;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;
import org.eclipse.jetty.io.AbstractConnection; import org.eclipse.jetty.io.AbstractConnection;
import org.eclipse.jetty.io.EndPoint;
import org.eclipse.jetty.io.ByteBufferPool; import org.eclipse.jetty.io.ByteBufferPool;
import org.eclipse.jetty.io.EndPoint;
import org.eclipse.jetty.io.RuntimeIOException; import org.eclipse.jetty.io.RuntimeIOException;
import org.eclipse.jetty.spdy.parser.Parser; import org.eclipse.jetty.spdy.parser.Parser;
import org.eclipse.jetty.util.Callback; import org.eclipse.jetty.util.Callback;
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 SPDYAsyncConnection extends AbstractConnection implements Controller<StandardSession.FrameBytes>, IdleListener public class SPDYConnection extends AbstractConnection implements Controller<StandardSession.FrameBytes>, IdleListener
{ {
private static final Logger logger = Log.getLogger(SPDYAsyncConnection.class); private static final Logger logger = Log.getLogger(SPDYConnection.class);
private final ByteBufferPool bufferPool; private final ByteBufferPool bufferPool;
private final Parser parser; private final Parser parser;
private volatile ISession session; private volatile ISession session;
private volatile boolean idle = false; private volatile boolean idle = false;
public SPDYAsyncConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Executor executor) public SPDYConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Executor executor)
{ {
super(endPoint, executor); super(endPoint, executor);
this.bufferPool = bufferPool; this.bufferPool = bufferPool;
@ -48,7 +48,7 @@ public class SPDYAsyncConnection extends AbstractConnection implements Controlle
super.onOpen(); super.onOpen();
fillInterested(); fillInterested();
} }
@Override @Override
public void onFillable() public void onFillable()
{ {

24
jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/SPDYServerConnector.java
View File

@ -21,8 +21,6 @@ import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.Queue; import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Executor;
import java.util.concurrent.RejectedExecutionException;
import javax.net.ssl.SSLEngine; import javax.net.ssl.SSLEngine;
import org.eclipse.jetty.io.Connection; import org.eclipse.jetty.io.Connection;
@ -42,7 +40,7 @@ public class SPDYServerConnector extends SelectChannelConnector
{ {
private final Queue<Session> sessions = new ConcurrentLinkedQueue<>(); private final Queue<Session> sessions = new ConcurrentLinkedQueue<>();
private final ServerSessionFrameListener listener; private final ServerSessionFrameListener listener;
private volatile int initialWindowSize = 65536; private volatile int initialWindowSize;
public SPDYServerConnector(Server server, ServerSessionFrameListener listener) public SPDYServerConnector(Server server, ServerSessionFrameListener listener)
{ {
@ -53,6 +51,7 @@ public class SPDYServerConnector extends SelectChannelConnector
{ {
super(server, sslContextFactory); super(server, sslContextFactory);
this.listener = listener; this.listener = listener;
setInitialWindowSize(65536);
putConnectionFactory("spdy/3", new ServerSPDYAsyncConnectionFactory(SPDY.V3, getByteBufferPool(), getExecutor(), getScheduler(), listener)); putConnectionFactory("spdy/3", new ServerSPDYAsyncConnectionFactory(SPDY.V3, getByteBufferPool(), getExecutor(), getScheduler(), listener));
putConnectionFactory("spdy/2", new ServerSPDYAsyncConnectionFactory(SPDY.V2, getByteBufferPool(), getExecutor(), getScheduler(), listener)); putConnectionFactory("spdy/2", new ServerSPDYAsyncConnectionFactory(SPDY.V2, getByteBufferPool(), getExecutor(), getScheduler(), listener));
setDefaultConnectionFactory(getConnectionFactory("spdy/2")); setDefaultConnectionFactory(getConnectionFactory("spdy/2"));
@ -173,25 +172,10 @@ public class SPDYServerConnector extends SelectChannelConnector
getSelectorManager().connectionUpgraded(endPoint, oldConnection); getSelectorManager().connectionUpgraded(endPoint, oldConnection);
} }
private class LazyExecutor implements Executor
{
@Override
public void execute(Runnable command)
{
Executor threadPool = getExecutor();
if (threadPool == null)
throw new RejectedExecutionException();
threadPool.execute(command);
}
}
@Override @Override
public void dump(Appendable out, String indent) throws IOException public void dump(Appendable out, String indent) throws IOException
{ {
super.dump(out,indent); super.dump(out, indent);
AggregateLifeCycle.dump(out, indent, new ArrayList<Session>(sessions)); AggregateLifeCycle.dump(out, indent, new ArrayList<>(sessions));
} }
} }

6
jetty-spdy/spdy-jetty/src/main/java/org/eclipse/jetty/spdy/ServerSPDYAsyncConnectionFactory.java
View File

@ -62,7 +62,7 @@ public class ServerSPDYAsyncConnectionFactory implements ConnectionFactory
SPDYServerConnector connector = (SPDYServerConnector)attachment; SPDYServerConnector connector = (SPDYServerConnector)attachment;
ServerSessionFrameListener listener = provideServerSessionFrameListener(endPoint, attachment); ServerSessionFrameListener listener = provideServerSessionFrameListener(endPoint, attachment);
SPDYAsyncConnection connection = new ServerSPDYAsyncConnection(endPoint, bufferPool, parser, listener, connector); SPDYConnection connection = new ServerSPDYConnection(endPoint, bufferPool, parser, listener, connector);
endPoint.setConnection(connection); endPoint.setConnection(connection);
FlowControlStrategy flowControlStrategy = connector.newFlowControlStrategy(version); FlowControlStrategy flowControlStrategy = connector.newFlowControlStrategy(version);
@ -83,13 +83,13 @@ public class ServerSPDYAsyncConnectionFactory implements ConnectionFactory
return listener; return listener;
} }
private static class ServerSPDYAsyncConnection extends SPDYAsyncConnection private static class ServerSPDYConnection extends SPDYConnection
{ {
private final ServerSessionFrameListener listener; private final ServerSessionFrameListener listener;
private final SPDYServerConnector connector; private final SPDYServerConnector connector;
private volatile boolean connected; private volatile boolean connected;
private ServerSPDYAsyncConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, ServerSessionFrameListener listener, SPDYServerConnector connector) private ServerSPDYConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, ServerSessionFrameListener listener, SPDYServerConnector connector)
{ {
super(endPoint, bufferPool, parser, connector.getExecutor()); super(endPoint, bufferPool, parser, connector.getExecutor());
this.listener = listener; this.listener = listener;