testcontainers#291 debug

bsideup · Feb 21, 2017 · 0d218d3 · 0d218d3
1 parent 04ec098
commit 0d218d3
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java b/.../src/main/java/org/testcontainers/dockerclient/NamedPipeSocketClientProviderStrategy.java
@@ -88,12 +88,16 @@ InetSocketAddress start() throws IOException {
 
                             executorService.submit(() -> {
                                 try (RandomAccessFile randomAccessFile = new RandomAccessFile(file, "rw")) {
+                                    log.info("Created RandomAccessFile from " + file);
                                     Future<Long> inputFuture = executorService.submit(() -> {
                                         try (
                                                 InputStream in = incomingSocket.getInputStream();
                                                 FileOutputStream out = new FileOutputStream(randomAccessFile.getFD())
                                         ) {
                                             return IOUtils.copyLarge(in, out);
+                                        } catch (Exception e) {
+                                            log.warn("", e);
+                                            return null;
                                         }
                                     });
 
@@ -103,11 +107,16 @@ InetSocketAddress start() throws IOException {
                                                 OutputStream out = incomingSocket.getOutputStream()
                                         ) {
                                             return IOUtils.copyLarge(in, out);
+                                        } catch (Exception e) {
+                                            log.warn("", e);
+                                            return null;
                                         }
                                     });
 
                                     inputFuture.get();
                                     outputFuture.get();
+                                } catch (Exception e) {
+                                    log.warn("", e);
                                 } finally {
                                     incomingSocket.close();
                                 }
@@ -118,6 +127,8 @@ InetSocketAddress start() throws IOException {
                             log.warn("", e);
                         }
                     }
+                } catch (Exception e) {
+                    log.warn("", e);
                 } finally {
                     listenSocket.close();
                 }