testcontainers#291 debug

bsideup · Feb 22, 2017 · fbe2f12 · fbe2f12
1 parent 8acb68d
commit fbe2f12
Showing 1 changed file with 23 additions and 23 deletions.
diff --git a/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java
@@ -92,54 +92,54 @@ InetSocketAddress start() throws IOException {
                                     log.info("Created RandomAccessFile from " + NAMED_PIPE_FILE_NAME);
 
                                     Thread threadB = new Thread(() -> {
-                                        log.info("Redirecting output");
+                                        log.info("Redirecting input");
                                         try (
-                                                OutputStream socketOut = incomingSocket.getOutputStream();
-                                                FileInputStream fileIn = new FileInputStream(randomAccessFile.getFD());
+                                                InputStream socketIn = incomingSocket.getInputStream();
+                                                FileOutputStream fileOut = new FileOutputStream(randomAccessFile.getFD());
                                         ) {
                                             final byte[] buffer = new byte[1024 * 4];
                                             int n;
                                             while (true) {
+                                                if (IOUtils.EOF == (n = socketIn.read(buffer))) {
+                                                    break;
+                                                }
                                                 synchronized (randomAccessFile) {
-                                                    if (IOUtils.EOF == (n = fileIn.read(buffer))) {
-                                                        break;
-                                                    }
+                                                    fileOut.write(buffer, 0, n);
                                                 }
-                                                System.out.println("Read " + n + " bytes from a file. Value: " + new String(buffer, 0, n));
-                                                socketOut.write(buffer, 0, n);
-                                                socketOut.flush();
+                                                System.out.println("Sent " + n + " bytes to a file. Value: " + new String(buffer, 0, n));
                                             }
-                                            log.info("Done redirecting output");
+                                            log.info("Done redirecting input");
                                             IOUtils.closeQuietly(incomingSocket);
                                             IOUtils.closeQuietly(randomAccessFile);
                                         } catch (Exception e) {
-                                            log.warn("output", e);
+                                            log.warn("input", e);
                                         }
                                     });
 
-                                    threadB.start();
-
-                                    log.info("Redirecting input");
+                                    log.info("Redirecting output");
                                     try (
-                                            InputStream socketIn = incomingSocket.getInputStream();
-                                            FileOutputStream fileOut = new FileOutputStream(randomAccessFile.getFD());
+                                            OutputStream socketOut = incomingSocket.getOutputStream();
+                                            FileInputStream fileIn = new FileInputStream(randomAccessFile.getFD());
                                     ) {
+                                        threadB.start();
+
                                         final byte[] buffer = new byte[1024 * 4];
                                         int n;
                                         while (true) {
-                                            if (IOUtils.EOF == (n = socketIn.read(buffer))) {
-                                                break;
-                                            }
                                             synchronized (randomAccessFile) {
-                                                fileOut.write(buffer, 0, n);
+                                                if (IOUtils.EOF == (n = fileIn.read(buffer))) {
+                                                    break;
+                                                }
                                             }
-                                            System.out.println("Sent " + n + " bytes to a file. Value: " + new String(buffer, 0, n));
+                                            System.out.println("Read " + n + " bytes from a file. Value: " + new String(buffer, 0, n));
+                                            socketOut.write(buffer, 0, n);
+                                            socketOut.flush();
                                         }
-                                        log.info("Done redirecting input");
+                                        log.info("Done redirecting output");
                                         IOUtils.closeQuietly(incomingSocket);
                                         IOUtils.closeQuietly(randomAccessFile);
                                     } catch (Exception e) {
-                                        log.warn("input", e);
+                                        log.warn("output", e);
                                     }
 
                                     threadB.join();