testcontainers#291 manual ping(2)

bsideup · Feb 21, 2017 · 17c55c6 · 17c55c6
1 parent 71f15d7
commit 17c55c6
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/.../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;