From 0636a22a7ddd365105e4b7e31abeed58f205a93b Mon Sep 17 00:00:00 2001 From: Lucio Lelii Date: Thu, 12 Jul 2018 13:43:44 +0000 Subject: [PATCH] git-svn-id: https://svn.d4science-ii.research-infrastructures.eu/gcube/branches/data-access/storagehub-webapp/1.0@169761 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../gcube/data/access/storagehub/MultipleOutputStream.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java b/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java index de60e49..e902eb3 100644 --- a/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java +++ b/src/main/java/org/gcube/data/access/storagehub/MultipleOutputStream.java @@ -44,17 +44,15 @@ public class MultipleOutputStream { while ((read =bis.read(buf))!=-1){ for (int i=0; i< pipedInStreams.length; i++) { if (!pipedInStreams[i].isClosed()) { - logger.debug("writing into piped stream {} ",i); pipedOutStreams[i].write(buf, 0, read); } } writeTot+= read; - if (allOutStreamClosed()) { - logger.debug("all streams created are closed"); + if (allOutStreamClosed()) break; - } else logger.debug("NOT all streams created are closed"); + } for (int i=0; i< pipedOutStreams.length; i++) {