[Bug 348978] migrate jetty-http-spi

jetty-http-spi/pom.xml

@@ -0,0 +1,73 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+  <parent>
+    <groupId>org.eclipse.jetty</groupId>
+    <artifactId>jetty-project</artifactId>
+    <version>7.5.3-SNAPSHOT</version>
+  </parent>
+  <modelVersion>4.0.0</modelVersion>
+  <artifactId>jetty-http-spi</artifactId>
+  <name>Jetty :: Http Service Provider Interface</name>
+  <properties>
+    <bundle-symbolic-name>${project.groupId}.http.spi</bundle-symbolic-name>
+  </properties>
+  <dependencies>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.sun.net.httpserver</groupId>
+      <artifactId>http</artifactId>
+      <version>20070405</version>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.eclipse.jetty</groupId>
+      <artifactId>jetty-server</artifactId>
+      <version>${project.version}</version>
+      <scope>provided</scope>
+    </dependency>
+  </dependencies>
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.felix</groupId>
+        <artifactId>maven-bundle-plugin</artifactId>
+        <extensions>true</extensions>
+        <executions>
+          <execution>
+            <goals>
+              <goal>manifest</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-jar-plugin</artifactId>
+        <executions>
+          <execution>
+            <id>artifact-jar</id>
+            <goals>
+              <goal>jar</goal>
+            </goals>
+          </execution>
+        </executions>
+        <configuration>
+          <archive>
+            <manifestFile>${project.build.outputDirectory}/META-INF/MANIFEST.MF</manifestFile>
+          </archive>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>findbugs-maven-plugin</artifactId>
+        <configuration>
+          <onlyAnalyze>org.eclipse.jetty.http.spi.*</onlyAnalyze>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+</project>

jetty-http-spi/src/main/java/org/eclipse/jetty/http/spi/HttpSpiContextHandler.java

@@ -0,0 +1,121 @@
+package org.eclipse.jetty.http.spi;
+//========================================================================
+//Copyright (c) 2004-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. 
+//========================================================================
+
+import com.sun.net.httpserver.Authenticator;
+import com.sun.net.httpserver.Authenticator.Result;
+import com.sun.net.httpserver.HttpContext;
+import com.sun.net.httpserver.HttpHandler;
+import com.sun.net.httpserver.HttpPrincipal;
+import org.eclipse.jetty.server.HttpConnection;
+import org.eclipse.jetty.server.Request;
+import org.eclipse.jetty.server.handler.ContextHandler;
+
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.PrintWriter;
+
+/**
+ * Jetty handler that bridges requests to {@link HttpHandler}.
+ */
+public class HttpSpiContextHandler extends ContextHandler
+{
+
+    private HttpContext _httpContext;
+
+    private HttpHandler _httpHandler;
+
+
+    public HttpSpiContextHandler(HttpContext httpContext, HttpHandler httpHandler)
+    {
+        this._httpContext = httpContext;
+        this._httpHandler = httpHandler;
+    }
+
+    @Override
+    public void doScope(String target, Request baseRequest, HttpServletRequest req, HttpServletResponse resp) throws IOException, ServletException
+    {
+        if (!target.startsWith(getContextPath())) return;
+
+        JettyHttpExchange jettyHttpExchange = new JettyHttpExchange(_httpContext, req, resp);
+
+        // TODO: add filters processing
+
+        try
+        {
+            Authenticator auth = _httpContext.getAuthenticator();
+            if (auth != null)
+                handleAuthentication(resp, jettyHttpExchange, auth);
+            else
+                _httpHandler.handle(jettyHttpExchange);
+        }
+        catch(Exception ex)
+        {
+            PrintWriter writer = new PrintWriter(jettyHttpExchange.getResponseBody());
+            
+            resp.setStatus(500);
+            writer.println("<h2>HTTP ERROR: 500</h2>");
+            writer.println("<pre>INTERNAL_SERVER_ERROR</pre>");
+            writer.println("<p>RequestURI=" + req.getRequestURI() + "</p>");
+            
+            writer.println("<pre>");
+            ex.printStackTrace(writer);
+            writer.println("</pre>");
+            
+            writer.println("<p><i><small><a href=\"http://jetty.mortbay.org\">Powered by jetty://</a></small></i></p>");
+            
+            writer.close();
+        }
+        finally
+        {
+            Request base_request = (req instanceof Request) ? (Request)req:HttpConnection.getCurrentConnection().getRequest();
+            base_request.setHandled(true);
+        }
+        
+    }
+
+
+    private void handleAuthentication(HttpServletResponse resp, JettyHttpExchange jettyHttpExchange, Authenticator auth) throws IOException
+    {
+        Result result = auth.authenticate(jettyHttpExchange);
+        if (result instanceof Authenticator.Failure)
+        {
+            int rc = ((Authenticator.Failure)result).getResponseCode();
+            resp.sendError(rc);
+        }
+        else if (result instanceof Authenticator.Retry)
+        {
+            int rc = ((Authenticator.Retry)result).getResponseCode();
+            resp.sendError(rc);
+        }
+        else if (result instanceof Authenticator.Success)
+        {
+            HttpPrincipal principal = ((Authenticator.Success)result).getPrincipal();
+            jettyHttpExchange.setPrincipal(principal);
+            _httpHandler.handle(jettyHttpExchange);
+        }
+    }
+
+    public HttpHandler getHttpHandler()
+    {
+        return _httpHandler;
+    }
+
+    public void setHttpHandler(HttpHandler handler)
+    {
+        this._httpHandler = handler;
+    }
+
+}

jetty-http-spi/src/main/java/org/eclipse/jetty/http/spi/JettyHttpContext.java

@@ -0,0 +1,106 @@
+package org.eclipse.jetty.http.spi;
+
+//========================================================================
+//Copyright (c) 2004-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. 
+//========================================================================
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import com.sun.net.httpserver.Authenticator;
+import com.sun.net.httpserver.Filter;
+import com.sun.net.httpserver.HttpHandler;
+import com.sun.net.httpserver.HttpServer;
+
+/**
+ * Jetty implementation of {@link com.sun.net.httpserver.HttpContext}
+ */
+public class JettyHttpContext extends com.sun.net.httpserver.HttpContext
+{
+
+    private HttpSpiContextHandler _jettyContextHandler;
+
+    private HttpServer _server;
+    
+    private Map<String,Object> _attributes = new HashMap<String,Object>();
+    
+    private List<Filter> _filters = new ArrayList<Filter>();
+    
+    private Authenticator _authenticator;
+
+
+    protected JettyHttpContext(HttpServer server, String path,
+            HttpHandler handler)
+    {
+        this._server = server;
+        _jettyContextHandler = new HttpSpiContextHandler(this, handler);
+        _jettyContextHandler.setContextPath(path);
+    }
+
+    protected HttpSpiContextHandler getJettyContextHandler()
+    {
+        return _jettyContextHandler;
+    }
+
+    @Override
+    public HttpHandler getHandler()
+    {
+        return _jettyContextHandler.getHttpHandler();
+    }
+
+    @Override
+    public void setHandler(HttpHandler h)
+    {
+        _jettyContextHandler.setHttpHandler(h);
+    }
+
+    @Override
+    public String getPath()
+    {
+        return _jettyContextHandler.getContextPath();
+    }
+
+    @Override
+    public HttpServer getServer()
+    {
+        return _server;
+    }
+
+    @Override
+    public Map<String, Object> getAttributes()
+    {
+        return _attributes;
+    }
+
+    @Override
+    public List<Filter> getFilters()
+    {
+        return _filters;
+    }
+
+    @Override
+    public Authenticator setAuthenticator(Authenticator auth)
+    {
+    	Authenticator previous = _authenticator;
+    	_authenticator = auth;
+        return previous;
+    }
+
+    @Override
+    public Authenticator getAuthenticator()
+    {
+        return _authenticator;
+    }
+
+}

jetty-http-spi/src/main/java/org/eclipse/jetty/http/spi/JettyHttpExchange.java

@@ -0,0 +1,227 @@
+package org.eclipse.jetty.http.spi;
+
+//========================================================================
+//Copyright (c) 2004-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. 
+//========================================================================
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.InetSocketAddress;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.util.Enumeration;
+import java.util.List;
+import java.util.Map;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import com.sun.net.httpserver.Headers;
+import com.sun.net.httpserver.HttpContext;
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpPrincipal;
+
+/**
+ * Jetty implementation of {@link com.sun.net.httpserver.HttpExchange}
+ */
+public class JettyHttpExchange extends HttpExchange
+{
+
+    private HttpContext _httpContext;
+
+    private HttpServletRequest _req;
+
+    private HttpServletResponse _resp;
+
+    private Headers _responseHeaders = new Headers();
+
+    private int _responseCode = 0;
+
+    private InputStream _is;
+
+    private OutputStream _os;
+
+	private HttpPrincipal _httpPrincipal;
+
+
+    public JettyHttpExchange(HttpContext jaxWsContext , HttpServletRequest req,
+            HttpServletResponse resp)
+    {
+        this._httpContext = jaxWsContext;
+        this._req = req;
+        this._resp = resp;
+        try
+        {
+            this._is = req.getInputStream();
+            this._os = resp.getOutputStream();
+        }
+        catch (IOException ex)
+        {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    @Override
+    public Headers getRequestHeaders()
+    {
+        Headers headers = new Headers();
+        Enumeration<?> en = _req.getHeaderNames();
+        while (en.hasMoreElements())
+        {
+            String name = (String) en.nextElement();
+            Enumeration<?> en2 = _req.getHeaders(name);
+            while (en2.hasMoreElements())
+            {
+                String value = (String) en2.nextElement();
+                headers.add(name, value);
+            }
+        }
+        return headers;
+    }
+
+    @Override
+    public Headers getResponseHeaders()
+    {
+        return _responseHeaders;
+    }
+
+    @Override
+    public URI getRequestURI()
+    {
+        try
+        {
+        	String uriAsString = _req.getRequestURI();
+        	if (_req.getQueryString() != null)
+        		uriAsString += "?" + _req.getQueryString();
+        	
+            return new URI(uriAsString);
+        }
+        catch (URISyntaxException ex)
+        {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    @Override
+    public String getRequestMethod()
+    {
+        return _req.getMethod();
+    }
+
+    @Override
+    public HttpContext getHttpContext()
+    {
+        return _httpContext;
+    }
+
+    @Override
+    public void close()
+    {
+        try
+        {
+            _resp.getOutputStream().close();
+        }
+        catch (IOException ex)
+        {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    @Override
+    public InputStream getRequestBody()
+    {
+        return _is;
+    }
+
+    @Override
+    public OutputStream getResponseBody()
+    {
+        return _os;
+    }
+
+    @Override
+    public void sendResponseHeaders(int rCode, long responseLength)
+            throws IOException
+    {
+        this._responseCode = rCode;
+
+        for (Map.Entry<String, List<String>> stringListEntry : _responseHeaders.entrySet())
+        {
+            String name = stringListEntry.getKey();
+            List<String> values = stringListEntry.getValue();
+
+            for (String value : values)
+            {
+                _resp.setHeader(name, value);
+            }
+        }
+        if (responseLength > 0)
+            _resp.setHeader("content-length", "" + responseLength);
+        _resp.setStatus(rCode);
+    }
+
+    @Override
+    public InetSocketAddress getRemoteAddress()
+    {
+        return new InetSocketAddress(_req.getRemoteAddr(), _req.getRemotePort());
+    }
+
+    @Override
+    public int getResponseCode()
+    {
+        return _responseCode;
+    }
+
+    @Override
+    public InetSocketAddress getLocalAddress()
+    {
+        return new InetSocketAddress(_req.getLocalAddr(), _req.getLocalPort());
+    }
+
+    @Override
+    public String getProtocol()
+    {
+        return _req.getProtocol();
+    }
+
+    @Override
+    public Object getAttribute(String name)
+    {
+        return _req.getAttribute(name);
+    }
+
+    @Override
+    public void setAttribute(String name, Object value)
+    {
+        _req.setAttribute(name, value);
+    }
+
+    @Override
+    public void setStreams(InputStream i, OutputStream o)
+    {
+        _is = i;
+        _os = o;
+    }
+
+    @Override
+    public HttpPrincipal getPrincipal()
+    {
+    	return _httpPrincipal;
+    }
+    
+    public void setPrincipal(HttpPrincipal principal)
+    {
+    	this._httpPrincipal = principal;
+    }
+
+}

jetty-http-spi/src/main/java/org/eclipse/jetty/http/spi/JettyHttpServer.java

@@ -0,0 +1,262 @@
+package org.eclipse.jetty.http.spi;
+
+//========================================================================
+//Copyright (c) 2004-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. 
+//========================================================================
+
+import com.sun.net.httpserver.HttpContext;
+import com.sun.net.httpserver.HttpHandler;
+import org.eclipse.jetty.server.Connector;
+import org.eclipse.jetty.server.Handler;
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.server.handler.ContextHandler;
+import org.eclipse.jetty.server.handler.HandlerCollection;
+import org.eclipse.jetty.server.handler.ContextHandlerCollection;
+import org.eclipse.jetty.server.nio.SelectChannelConnector;
+import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
+
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+/**
+ * Jetty implementation of {@link com.sun.net.httpserver.HttpServer}.
+ */
+public class JettyHttpServer extends com.sun.net.httpserver.HttpServer
+{
+    private static final Logger LOG = Log.getLogger(JettyHttpServer.class);
+
+
+    private Server _server;
+    
+    private boolean _serverShared;
+
+    private InetSocketAddress _addr;
+
+    private ThreadPoolExecutor _executor;
+
+    private Map<String, JettyHttpContext> _contexts = new HashMap<String, JettyHttpContext>();
+    
+    private Map<String, Connector> _connectors = new HashMap<String, Connector>();
+
+    
+    public JettyHttpServer(Server server, boolean shared)
+    {
+        this._server = server;
+        this._serverShared = shared;
+    }
+
+    @Override
+    public void bind(InetSocketAddress addr, int backlog) throws IOException
+    {
+    	// check if there is already a connector listening
+        Connector[] connectors = _server.getConnectors();
+        if (connectors != null)
+        {
+            for (Connector connector : connectors)
+            {
+                if (connector.getPort() == addr.getPort()) {
+                    if (LOG.isDebugEnabled()) LOG.debug("server already bound to port " + addr.getPort() + ", no need to rebind");
+                    return;
+                }
+            }
+        }
+        
+        if (_serverShared)
+        	throw new IOException("jetty server is not bound to port " + addr.getPort());
+        
+        this._addr = addr;
+
+        if (LOG.isDebugEnabled()) LOG.debug("binding server to port " + addr.getPort());
+        SelectChannelConnector connector = new SelectChannelConnector();
+        connector.setAcceptors(1);
+        connector.setPort(addr.getPort());
+        connector.setHost(addr.getHostName());
+        _server.addConnector(connector);
+        
+        _connectors.put(addr.getHostName() + addr.getPort(), connector);
+    }
+
+    @Override
+    public InetSocketAddress getAddress()
+    {
+        return _addr;
+    }
+
+    @Override
+    public void start()
+    {
+    	if (_serverShared) return;
+    	
+        try
+        {
+            _server.start();
+        }
+        catch (Exception ex)
+        {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    @Override
+    public void setExecutor(Executor executor)
+    {
+        if (executor == null)
+            throw new IllegalArgumentException("missing required 'executor' argument");
+
+    	if (!(executor instanceof ThreadPoolExecutor))
+    		throw new IllegalArgumentException("only java.util.concurrent.ThreadPoolExecutor instances are allowed, got: " + executor.getClass().getName());
+    	
+    	if (LOG.isDebugEnabled()) LOG.debug("using ThreadPoolExecutor for server thread pool");
+    	this._executor = (ThreadPoolExecutor) executor;
+    	_server.setThreadPool(new ThreadPoolExecutorAdapter(_executor));
+    }
+
+    @Override
+    public Executor getExecutor()
+    {
+        return _executor;
+    }
+
+    @Override
+    public void stop(int delay)
+    {
+    	cleanUpContexts();
+    	cleanUpConnectors();
+    	
+    	if (_serverShared) return;
+
+    	try
+        {
+            _server.stop();
+        }
+        catch (Exception ex)
+        {
+            throw new RuntimeException(ex);
+        }
+    }
+
+	private void cleanUpContexts()
+	{
+        for (Map.Entry<String, JettyHttpContext> stringJettyHttpContextEntry : _contexts.entrySet())
+        {
+            JettyHttpContext context = stringJettyHttpContextEntry.getValue();
+            _server.removeBean(context.getJettyContextHandler());
+        }
+		_contexts.clear();
+	}
+
+    private void cleanUpConnectors()
+    {
+        for (Map.Entry<String, Connector> stringConnectorEntry : _connectors.entrySet())
+        {
+            Connector connector = stringConnectorEntry.getValue();
+            try
+            {
+                connector.stop();
+            } catch (Exception ex) {
+                LOG.warn(ex);
+            }
+            _server.removeConnector(connector);
+        }
+		_connectors.clear();
+	}
+
+	@Override
+    public HttpContext createContext(String path, HttpHandler httpHandler)
+    {
+    	checkIfContextIsFree(path);
+
+        JettyHttpContext context = new JettyHttpContext(this, path, httpHandler);
+        HttpSpiContextHandler jettyContextHandler = context.getJettyContextHandler();
+
+        ContextHandlerCollection chc = findContextHandlerCollection(_server.getHandlers());
+        if (chc == null)
+        	throw new RuntimeException("could not find ContextHandlerCollection, you must configure one");
+
+        chc.addHandler(jettyContextHandler);
+        _contexts.put(path, context);
+
+        return context;
+    }
+
+    private ContextHandlerCollection findContextHandlerCollection(Handler[] handlers)
+    {
+        if (handlers == null)
+            return null;
+
+        for (Handler handler : handlers)
+        {
+            if (handler instanceof ContextHandlerCollection)
+            {
+                return (ContextHandlerCollection) handler;
+            }
+
+            if (handler instanceof HandlerCollection)
+            {
+                HandlerCollection hc = (HandlerCollection) handler;
+                ContextHandlerCollection chc = findContextHandlerCollection(hc.getHandlers());
+                if (chc != null)
+                    return chc;
+            }
+        }
+        return null;
+    }
+
+    private void checkIfContextIsFree(String path)
+    {
+    	Handler serverHandler = _server.getHandler();
+		if (serverHandler instanceof ContextHandler)
+		{
+			ContextHandler ctx = (ContextHandler) serverHandler;
+			if (ctx.getContextPath().equals(path))
+	        	throw new RuntimeException("another context already bound to path " + path);
+		}
+    	
+    	Handler[] handlers = _server.getHandlers();
+    	if (handlers == null) return;
+
+        for (Handler handler : handlers)
+        {
+            if (handler instanceof ContextHandler) {
+                ContextHandler ctx = (ContextHandler) handler;
+                if (ctx.getContextPath().equals(path))
+                    throw new RuntimeException("another context already bound to path " + path);
+            }
+        }
+	}
+
+	@Override
+    public HttpContext createContext(String path)
+    {
+        return createContext(path, null);
+    }
+
+    @Override
+    public void removeContext(String path) throws IllegalArgumentException
+    {
+        JettyHttpContext context = _contexts.remove(path);
+        if (context == null) return;
+        _server.removeBean(context.getJettyContextHandler());
+    }
+
+    @Override
+    public void removeContext(HttpContext context)
+    {
+        removeContext(context.getPath());
+    }
+
+}

jetty-http-spi/src/main/java/org/eclipse/jetty/http/spi/JettyHttpServerProvider.java

@@ -0,0 +1,72 @@
+package org.eclipse.jetty.http.spi;
+
+//========================================================================
+//Copyright (c) 2004-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. 
+//========================================================================
+
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+
+import org.eclipse.jetty.server.Handler;
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.server.handler.DefaultHandler;
+import org.eclipse.jetty.server.handler.HandlerCollection;
+import org.eclipse.jetty.server.handler.ContextHandlerCollection;
+
+import com.sun.net.httpserver.HttpServer;
+import com.sun.net.httpserver.HttpsServer;
+import com.sun.net.httpserver.spi.HttpServerProvider;
+
+/**
+ * Jetty implementation of <a href="http://java.sun.com/javase/6/docs/jre/api/net/httpserver/spec/index.html">Java HTTP Server SPI</a>
+ */
+public class JettyHttpServerProvider extends HttpServerProvider
+{
+
+    private static Server _server;
+
+    public static void setServer(Server server)
+    {
+    	_server = server;
+    }
+
+    @Override
+    public HttpServer createHttpServer(InetSocketAddress addr, int backlog)
+            throws IOException
+    {
+        Server server = _server;
+    	boolean shared = true;
+
+        if (server == null)
+        {
+        	server = new Server();
+        	
+        	HandlerCollection handlerCollection = new HandlerCollection();
+        	handlerCollection.setHandlers(new Handler[] {new ContextHandlerCollection(), new DefaultHandler()});
+			server.setHandler(handlerCollection);
+
+            shared = false;
+        }
+
+        JettyHttpServer jettyHttpServer = new JettyHttpServer(server, shared);
+        jettyHttpServer.bind(addr, backlog);
+        return jettyHttpServer;
+    }
+
+    @Override
+    public HttpsServer createHttpsServer(InetSocketAddress addr, int backlog) throws IOException
+    {
+        throw new UnsupportedOperationException();
+    }
+
+}

jetty-http-spi/src/main/java/org/eclipse/jetty/http/spi/ThreadPoolExecutorAdapter.java

@@ -0,0 +1,119 @@
+package org.eclipse.jetty.http.spi;
+
+//========================================================================
+//Copyright (c) 2004-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. 
+//========================================================================
+
+import java.util.concurrent.RejectedExecutionException;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+import org.eclipse.jetty.util.component.AbstractLifeCycle;
+import org.eclipse.jetty.util.log.Log;
import org.eclipse.jetty.util.log.Logger;
+
+import org.eclipse.jetty.util.thread.ThreadPool;
+
+/**
+ * Jetty {@link ThreadPool} that bridges requests to a {@link ThreadPoolExecutor}.
+ */
+public class ThreadPoolExecutorAdapter extends AbstractLifeCycle implements ThreadPool
+{
+    private static final Logger LOG = Log.getLogger(ThreadPoolExecutorAdapter.class);
+
+	
+	private ThreadPoolExecutor executor;
+	
+	public ThreadPoolExecutorAdapter(ThreadPoolExecutor executor)
+	{
+		this.executor = executor;
+	}
+
+	public boolean dispatch(Runnable job)
+	{
+		try
+        {       
+			executor.execute(job);
+            return true;
+        }
+        catch(RejectedExecutionException e)
+        {
+            LOG.warn(e);
+            return false;
+        }
+	}
+
+	public int getIdleThreads()
+	{
+		return executor.getPoolSize()-executor.getActiveCount();
+	}
+
+	public int getThreads()
+	{
+		return executor.getPoolSize();
+	}
+
+	public boolean isLowOnThreads()
+	{
+		return executor.getActiveCount()>=executor.getMaximumPoolSize();
+	}
+
+	public void join() throws InterruptedException
+	{
+		executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
+	}
+
+	
+	
+	public boolean isFailed()
+	{
+		return false;
+	}
+
+	public boolean isRunning()
+	{
+		return !executor.isTerminated() && !executor.isTerminating();
+	}
+
+	public boolean isStarted()
+	{
+		return !executor.isTerminated() && !executor.isTerminating();
+	}
+
+	public boolean isStarting()
+	{
+		return false;
+	}
+
+	public boolean isStopped()
+	{
+		return executor.isTerminated();
+	}
+
+	public boolean isStopping()
+	{
+		return executor.isTerminating();
+	}
+
+	protected void doStart() throws Exception
+	{
+		if (executor.isTerminated() || executor.isTerminating() || executor.isShutdown())
+            throw new IllegalStateException("Cannot restart");
+	}
+
+	protected void doStop() throws Exception
+	{
+		executor.shutdown();
+        if (!executor.awaitTermination(60, TimeUnit.SECONDS))
+        	executor.shutdownNow();
+	}
+
+}

jetty-http-spi/src/main/resources/META-INF/services/com.sun.net.httpserver.spi.HttpServerProvider

@@ -0,0 +1 @@
+org.eclipse.jetty.http.spi.JettyHttpServerProvider

pom.xml

@@ -349,6 +349,7 @@
     <module>jetty-nested</module>
     <module>jetty-overlay-deployer</module>
     <module>jetty-nosql</module>
+    <module>jetty-http-spi</module>
     <module>jetty-distribution</module>
     <module>test-continuation</module>
     <module>test-continuation-jetty6</module>