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

Moved NIO connectors to nio package.

This commit is contained in:
Simone Bordet 2012-01-27 12:15:51 +01:00
parent 672c89827b
commit 4d0096978d
3 changed files with 24 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/org/eclipse/jetty/spdy/SPDYClient.java → src/main/java/org/eclipse/jetty/spdy/nio/SPDYClient.java
View File

@ -2,26 +2,34 @@
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package org.eclipse.jetty.spdy;
package org.eclipse.jetty.spdy.nio;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.nio.channels.SelectionKey;
import java.nio.channels.SocketChannel;
import java.util.concurrent.*;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import org.eclipse.jetty.io.AsyncEndPoint;
import org.eclipse.jetty.io.ConnectedEndPoint;
import org.eclipse.jetty.io.Connection;
import org.eclipse.jetty.io.nio.AsyncConnection;
import org.eclipse.jetty.io.nio.SelectChannelEndPoint;
import org.eclipse.jetty.io.nio.SelectorManager;
import org.eclipse.jetty.spdy.CompressionFactory;
import org.eclipse.jetty.spdy.CompressionFactory.Compressor;
import org.eclipse.jetty.spdy.CompressionFactory.Decompressor;
import org.eclipse.jetty.spdy.ISession;
import org.eclipse.jetty.spdy.StandardCompressionFactory;
import org.eclipse.jetty.spdy.StandardSession;
import org.eclipse.jetty.spdy.api.Session;
import org.eclipse.jetty.spdy.api.Session.FrameListener;
import org.eclipse.jetty.spdy.generator.Generator;
import org.eclipse.jetty.spdy.nio.AsyncSPDYConnection;
import org.eclipse.jetty.spdy.parser.Parser;
import org.eclipse.jetty.util.component.AggregateLifeCycle;
import org.eclipse.jetty.util.thread.QueuedThreadPool;

8
src/main/java/org/eclipse/jetty/spdy/SPDYServerConnector.java → src/main/java/org/eclipse/jetty/spdy/nio/SPDYServerConnector.java
View File

@ -1,13 +1,17 @@
package org.eclipse.jetty.spdy;
package org.eclipse.jetty.spdy.nio;
import java.nio.channels.SocketChannel;
import org.eclipse.jetty.io.AsyncEndPoint;
import org.eclipse.jetty.io.nio.AsyncConnection;
import org.eclipse.jetty.server.nio.SelectChannelConnector;
import org.eclipse.jetty.spdy.CompressionFactory;
import org.eclipse.jetty.spdy.ISession;
import org.eclipse.jetty.spdy.StandardCompressionFactory;
import org.eclipse.jetty.spdy.StandardSession;
import org.eclipse.jetty.spdy.api.Session;
import org.eclipse.jetty.spdy.api.server.ServerSessionFrameListener;
import org.eclipse.jetty.spdy.generator.Generator;
import org.eclipse.jetty.spdy.nio.AsyncSPDYConnection;
import org.eclipse.jetty.spdy.parser.Parser;
public class SPDYServerConnector extends SelectChannelConnector

8
src/test/java/org/eclipse/jetty/spdy/SPDYTest.java
View File

@ -1,10 +1,14 @@
package org.eclipse.jetty.spdy;
import java.net.InetSocketAddress;
import org.eclipse.jetty.server.Connector;
import org.eclipse.jetty.server.Server;
import org.eclipse.jetty.spdy.api.Session;
import org.eclipse.jetty.spdy.api.server.ServerSessionFrameListener;
import org.eclipse.jetty.spdy.nio.SPDYClient;
import org.eclipse.jetty.spdy.nio.SPDYServerConnector;
import org.eclipse.jetty.util.thread.QueuedThreadPool;
import org.junit.After;
public class SPDYTest
@ -25,7 +29,9 @@ public class SPDYTest
{
if (clientFactory == null)
{
clientFactory = new SPDYClient.Factory();
QueuedThreadPool threadPool = new QueuedThreadPool();
threadPool.setName(threadPool.getName() + "-client");
clientFactory = new SPDYClient.Factory(threadPool);
clientFactory.start();
}
return clientFactory.newSPDYClient().connect(socketAddress, frameListener).get();