fix some unit tests

Signed-off-by: olivier lamy <[email protected]>

tests/test-http-client-transport/src/test/java/org/eclipse/jetty/http/client/AbstractTest.java

@@ -71,7 +71,7 @@ public static Object[] parameters() throws Exception
         return Transport.values();//new Transport[]{UNIX_SOCKET};// Transport.values();
     }
 
-    private Path sockFile;
+    protected Path sockFile;
 
     @Rule
     public final TestTracker tracker = new TestTracker();

tests/test-http-client-transport/src/test/java/org/eclipse/jetty/http/client/HttpClientLoadTest.java

@@ -51,6 +51,7 @@
 import org.eclipse.jetty.server.Server;
 import org.eclipse.jetty.server.ServerConnector;
 import org.eclipse.jetty.server.handler.AbstractHandler;
+import org.eclipse.jetty.unixsocket.client.HttpClientTransportOverUnixSockets;
 import org.eclipse.jetty.util.IO;
 import org.eclipse.jetty.util.LeakDetector;
 import org.eclipse.jetty.util.log.Log;
@@ -117,6 +118,10 @@ protected void leaked(LeakDetector.LeakInfo leakInfo)
                 });
                 return clientTransport;
             }
+            case UNIX_SOCKET:
+            {
+                return new HttpClientTransportOverUnixSockets( sockFile.toString() );
+            }
             default:
             {
                 return super.provideClientTransport(transport);

tests/test-http-client-transport/src/test/java/org/eclipse/jetty/http/client/HttpClientStreamTest.java

@@ -60,6 +60,7 @@
 import org.eclipse.jetty.client.util.OutputStreamContentProvider;
 import org.eclipse.jetty.http.HttpStatus;
 import org.eclipse.jetty.server.Request;
+import org.eclipse.jetty.server.Server;
 import org.eclipse.jetty.server.ServerConnector;
 import org.eclipse.jetty.server.handler.AbstractHandler;
 import org.eclipse.jetty.toolchain.test.MavenTestingUtils;
@@ -463,7 +464,8 @@ public void testInputStreamResponseListenerFailedBeforeResponse() throws Excepti
 
         InputStreamResponseListener listener = new InputStreamResponseListener();
         // Connect to the wrong port
-        client.newRequest(newURI())
+        client.newRequest("localhost",
+                          (connector instanceof ServerConnector?ServerConnector.class.cast( connector ).getLocalPort():1))
                 .scheme(getScheme())
                 .send(listener);
         Result result = listener.await(5, TimeUnit.SECONDS);
@@ -940,8 +942,8 @@ public void testUploadWithOutputStreamFailureToConnect() throws Exception
         final byte[] data = new byte[512];
         final CountDownLatch latch = new CountDownLatch(1);
         OutputStreamContentProvider content = new OutputStreamContentProvider();
-        client.newRequest("0.0.0.1:"
-                              + ((connector instanceof ServerConnector)?ServerConnector.class.cast( connector ).getLocalPort():"0"))
+        client.newRequest("http://0.0.0.1"
+                              + ((connector instanceof ServerConnector)?":"+ServerConnector.class.cast(connector).getLocalPort():""))
                 .scheme(getScheme())
                 .content(content)
                 .send(result ->
@@ -1028,8 +1030,8 @@ public void close() throws IOException
         InputStreamContentProvider content = new InputStreamContentProvider(stream);
 
         final CountDownLatch completeLatch = new CountDownLatch(1);
-        client.newRequest("0.0.0.1:"
-                              + ((connector instanceof ServerConnector)?ServerConnector.class.cast( connector ).getLocalPort():"0"))
+        client.newRequest("http://0.0.0.1"
+                              + ((connector instanceof ServerConnector)?":"+ServerConnector.class.cast(connector).getLocalPort():""))
                 .scheme(getScheme())
                 .content(content)
                 .send(result ->