Skip to main content
aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGreg Wilkins2012-05-09 11:30:27 +0000
committerGreg Wilkins2012-05-09 11:30:27 +0000
commita7154fcb059f5571a61ccb411d948bcc0304c115 (patch)
tree9960adbcee15d957f21269d92b7a911a9172cfa7
parent2b9ff87e0268f45013365a941221a1e944b8acf1 (diff)
downloadorg.eclipse.jetty.project-a7154fcb059f5571a61ccb411d948bcc0304c115.tar.gz
org.eclipse.jetty.project-a7154fcb059f5571a61ccb411d948bcc0304c115.tar.xz
org.eclipse.jetty.project-a7154fcb059f5571a61ccb411d948bcc0304c115.zip
jetty-9 work in progress
-rw-r--r--jetty-io/src/main/java/org/eclipse/jetty/io/SelectorManager.java1
-rw-r--r--jetty-server/src/main/java/org/eclipse/jetty/server/nio/NIOConnector.java26
-rw-r--r--jetty-server/src/main/java/org/eclipse/jetty/server/nio/SelectChannelConnector.java8
3 files changed, 5 insertions, 30 deletions
diff --git a/jetty-io/src/main/java/org/eclipse/jetty/io/SelectorManager.java b/jetty-io/src/main/java/org/eclipse/jetty/io/SelectorManager.java
index 4facdd3cdd..be1fe2a697 100644
--- a/jetty-io/src/main/java/org/eclipse/jetty/io/SelectorManager.java
+++ b/jetty-io/src/main/java/org/eclipse/jetty/io/SelectorManager.java
@@ -487,6 +487,7 @@ public abstract class SelectorManager extends AbstractLifeCycle implements Dumpa
}
else if (change instanceof ChangeTask)
{
+ LOG.warn("DO WE NEED THIS????");
((Runnable)change).run();
}
else if (change instanceof Runnable)
diff --git a/jetty-server/src/main/java/org/eclipse/jetty/server/nio/NIOConnector.java b/jetty-server/src/main/java/org/eclipse/jetty/server/nio/NIOConnector.java
deleted file mode 100644
index 16d27566fa..0000000000
--- a/jetty-server/src/main/java/org/eclipse/jetty/server/nio/NIOConnector.java
+++ /dev/null
@@ -1,26 +0,0 @@
-// ========================================================================
-// Copyright (c) 2006-2009 Mort Bay Consulting Pty. Ltd.
-// ------------------------------------------------------------------------
-// All rights reserved. This program and the accompanying materials
-// are made available under the terms of the Eclipse Public License v1.0
-// and Apache License v2.0 which accompanies this distribution.
-// The Eclipse Public License is available at
-// http://www.eclipse.org/legal/epl-v10.html
-// The Apache License v2.0 is available at
-// http://www.opensource.org/licenses/apache2.0.php
-// You may elect to redistribute this code under either of these licenses.
-// ========================================================================
-
-package org.eclipse.jetty.server.nio;
-
-/**
- * NIOConnector.
- * A marker interface that indicates that NIOBuffers can be handled (efficiently) by this Connector.
- *
- *
- *
- */
-public interface NIOConnector
-{
- boolean getUseDirectBuffers();
-}
diff --git a/jetty-server/src/main/java/org/eclipse/jetty/server/nio/SelectChannelConnector.java b/jetty-server/src/main/java/org/eclipse/jetty/server/nio/SelectChannelConnector.java
index c9f735e544..5e55a5d1e0 100644
--- a/jetty-server/src/main/java/org/eclipse/jetty/server/nio/SelectChannelConnector.java
+++ b/jetty-server/src/main/java/org/eclipse/jetty/server/nio/SelectChannelConnector.java
@@ -247,26 +247,26 @@ public class SelectChannelConnector extends AbstractHttpConnector
}
@Override
- protected void endPointClosed(SelectChannelEndPoint endpoint)
+ protected void endPointClosed(AsyncEndPoint endpoint)
{
SelectChannelConnector.this.endPointClosed(endpoint);
}
@Override
- protected void endPointOpened(SelectChannelEndPoint endpoint)
+ protected void endPointOpened(AsyncEndPoint endpoint)
{
// TODO handle max connections and low resources
connectionOpened(endpoint.getAsyncConnection());
}
@Override
- protected void endPointUpgraded(SelectChannelEndPoint endpoint, AsyncConnection oldConnection)
+ protected void endPointUpgraded(AsyncEndPoint endpoint, AsyncConnection oldConnection)
{
connectionUpgraded(oldConnection,endpoint.getAsyncConnection());
}
@Override
- public AsyncConnection newConnection(SocketChannel channel, SelectChannelEndPoint endpoint, Object attachment)
+ public AsyncConnection newConnection(SocketChannel channel, AsyncEndPoint endpoint, Object attachment)
{
return SelectChannelConnector.this.newConnection(channel,endpoint);
}

Back to the top