413531 - Introduce pluggable transports for HttpClient.

Merge of the branch 'http_client_transport' is now complete,
and the implementation is sound for the HTTP transport.
A basic implementation for the SPDY transport exists, but needs
improvements.

jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java

@@ -914,22 +914,6 @@ public class HttpClient extends ContainerLifeCycle
         dump(out, indent, getBeans(), destinations.values());
     }
 
-    protected Connection tunnel(Connection connection)
-    {
-        // TODO
-/*
-        HttpConnection httpConnection = (HttpConnection)connection;
-        HttpDestination destination = httpConnection.getHttpDestination();
-        SslConnection sslConnection = createSslConnection(destination, httpConnection.getEndPoint());
-        Connection result = (Connection)sslConnection.getDecryptedEndPoint().getConnection();
-        selectorManager.connectionClosed(httpConnection);
-        selectorManager.connectionOpened(sslConnection);
-        LOG.debug("Tunnelled {} over {}", connection, result);
-        return result;
-*/
-        return connection;
-    }
-
     private class ContentDecoderFactorySet implements Set<ContentDecoder.Factory>
     {
         private final Set<ContentDecoder.Factory> set = new HashSet<>();

jetty-client/src/main/java/org/eclipse/jetty/client/HttpClientTransport.java

@@ -30,4 +30,6 @@ public interface HttpClientTransport
     HttpDestination newHttpDestination(HttpClient httpClient, String scheme, String host, int port);
 
     void connect(HttpDestination destination, SocketAddress address, Promise<Connection> promise);
+
+    Connection tunnel(Connection connection);
 }

jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java

@@ -330,7 +330,7 @@ public abstract class HttpDestination implements Destination, Closeable, Dumpabl
                         if (response.getStatus() == 200)
                         {
                             // Wrap the connection with TLS
-                            Connection tunnel = client.tunnel(connection);
+                            Connection tunnel = client.getTransport().tunnel(connection);
                             delegate.succeeded(tunnel);
                         }
                         else

jetty-client/src/main/java/org/eclipse/jetty/client/http/HttpClientTransportOverHTTP.java

@@ -107,6 +107,19 @@ public class HttpClientTransportOverHTTP extends ContainerLifeCycle implements H
         }
     }
 
+    @Override
+    public org.eclipse.jetty.client.api.Connection tunnel(org.eclipse.jetty.client.api.Connection connection)
+    {
+        HttpConnectionOverHTTP httpConnection = (HttpConnectionOverHTTP)connection;
+        HttpDestination destination = httpConnection.getHttpDestination();
+        SslConnection sslConnection = createSslConnection(destination, httpConnection.getEndPoint());
+        HttpConnectionOverHTTP result = (HttpConnectionOverHTTP)sslConnection.getDecryptedEndPoint().getConnection();
+        selectorManager.connectionClosed(httpConnection);
+        selectorManager.connectionOpened(sslConnection);
+        LOG.debug("Tunnelled {} over {}", connection, result);
+        return result;
+    }
+
     protected void configure(HttpClient client, SocketChannel channel) throws SocketException
     {
         channel.socket().setTcpNoDelay(client.isTCPNoDelay());

jetty-spdy/spdy-http-client-transport/src/main/java/org/eclipse/jetty/spdy/client/http/HttpClientTransportOverSPDY.java

@@ -87,4 +87,10 @@ public class HttpClientTransportOverSPDY implements HttpClientTransport
                 }
         );
     }
+
+    @Override
+    public Connection tunnel(Connection connection)
+    {
+        throw new UnsupportedOperationException();
+    }
 }