diff --git a/core/src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/core/src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java index fe8b995e839..4578b03cf62 100644 --- a/core/src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java +++ b/core/src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java @@ -78,10 +78,9 @@ static class NamedPipeProxy { InetSocketAddress start() throws IOException { ServerSocket listenSocket = new ServerSocket(); listenSocket.bind(new InetSocketAddress("localhost", 0)); + log.debug("Listening on {} and proxying to {}", listenSocket.getLocalSocketAddress(), file); executorService.submit(() -> { - log.debug("Listening on {} and proxying to {}", listenSocket.getLocalSocketAddress(), file); - try { while (!Thread.interrupted()) { try { @@ -132,6 +131,8 @@ InetSocketAddress start() throws IOException { } catch (IOException e) { log.warn("", e); } + + log.info("Thread was interrupted. I'm done."); } } catch (Exception e) { log.warn("", e); @@ -142,6 +143,7 @@ InetSocketAddress start() throws IOException { }); InetSocketAddress inetSocketAddress = (InetSocketAddress) listenSocket.getLocalSocketAddress(); + log.info("Pinging..."); log.info("Ping: " + IOUtils.toString(URI.create("http://localhost:" + inetSocketAddress.getPort() + "/v1.25/_ping"))); return inetSocketAddress;