testcontainers#291 debug

bsideup · Feb 22, 2017 · 7d4f56b · 7d4f56b
1 parent 456d420
commit 7d4f56b
Showing 1 changed file with 19 additions and 24 deletions.
diff --git a/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java
@@ -104,6 +104,7 @@ InetSocketAddress start() throws IOException {
                                                     break;
                                                 }
                                                 fileOut.write(buffer, 0, n);
+                                                fileOut.flush();
                                                 System.out.println("Sent " + n + " bytes to a file. Value: " + new String(buffer, 0, n));
                                             }
                                             log.info("Done redirecting input");
@@ -114,35 +115,29 @@ InetSocketAddress start() throws IOException {
                                         }
                                     });
 
-                                    Thread threadB = new Thread(() -> {
-                                        log.info("Redirecting output");
-                                        try (
-                                                OutputStream socketOut = incomingSocket.getOutputStream();
-                                                FileInputStream fileIn = new FileInputStream(randomAccessFile.getFD());
-                                        ) {
-                                            final byte[] buffer = new byte[1024 * 4];
-                                            int n;
-                                            while (true) {
-                                                if (IOUtils.EOF == (n = fileIn.read(buffer))) {
-                                                    break;
-                                                }
-                                                System.out.println("Read " + n + " bytes from a file. Value: " + new String(buffer, 0, n));
-                                                socketOut.write(buffer, 0, n);
-                                                socketOut.flush();
+                                    log.info("Redirecting output");
+                                    try (
+                                            OutputStream socketOut = incomingSocket.getOutputStream();
+                                            FileInputStream fileIn = new FileInputStream(randomAccessFile.getFD());
+                                    ) {
+                                        final byte[] buffer = new byte[1024 * 4];
+                                        int n;
+                                        while (true) {
+                                            if (IOUtils.EOF == (n = fileIn.read(buffer))) {
+                                                break;
                                             }
-                                            log.info("Done redirecting output");
-                                            IOUtils.closeQuietly(incomingSocket);
-                                            IOUtils.closeQuietly(randomAccessFile);
-                                        } catch (Exception e) {
-                                            log.warn("output", e);
+                                            System.out.println("Read " + n + " bytes from a file. Value: " + new String(buffer, 0, n));
+                                            socketOut.write(buffer, 0, n);
                                         }
-                                    });
+                                        log.info("Done redirecting output");
+                                        IOUtils.closeQuietly(incomingSocket);
+                                        IOUtils.closeQuietly(randomAccessFile);
+                                    } catch (Exception e) {
+                                        log.warn("output", e);
+                                    }
 
                                     threadA.start();
-                                    threadB.start();
-
                                     threadA.join();
-                                    threadB.join();
                                     log.info("all futures completed");
                                 } catch (Exception e) {
                                     log.warn("", e);