Repository: commons-compress Updated Branches: refs/heads/COMPRESS-207 e1a895a0f -> 17501ed87
COMPRESS-207 don't allow progress listeners to kill (de)compression Project: http://git-wip-us.apache.org/repos/asf/commons-compress/repo Commit: http://git-wip-us.apache.org/repos/asf/commons-compress/commit/17501ed8 Tree: http://git-wip-us.apache.org/repos/asf/commons-compress/tree/17501ed8 Diff: http://git-wip-us.apache.org/repos/asf/commons-compress/diff/17501ed8 Branch: refs/heads/COMPRESS-207 Commit: 17501ed873db3c6aaf49b7dea1a81cb4dc8e3d46 Parents: e1a895a Author: Stefan Bodewig <bode...@apache.org> Authored: Wed Mar 30 10:52:56 2016 +0200 Committer: Stefan Bodewig <bode...@apache.org> Committed: Wed Mar 30 10:52:56 2016 +0200 ---------------------------------------------------------------------- .../commons/compress/compressors/CompressorInputStream.java | 6 +++++- .../commons/compress/compressors/CompressorOutputStream.java | 6 +++++- 2 files changed, 10 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/commons-compress/blob/17501ed8/src/main/java/org/apache/commons/compress/compressors/CompressorInputStream.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/commons/compress/compressors/CompressorInputStream.java b/src/main/java/org/apache/commons/compress/compressors/CompressorInputStream.java index 4d0e46a..9c2b850 100644 --- a/src/main/java/org/apache/commons/compress/compressors/CompressorInputStream.java +++ b/src/main/java/org/apache/commons/compress/compressors/CompressorInputStream.java @@ -114,7 +114,11 @@ public abstract class CompressorInputStream extends InputStream { CompressionProgressEvent e = new CompressionProgressEvent(this, blockNumber, streamNumber, compressedBytesRead, getBytesRead()); for (CompressionProgressListener l : listeners) { - l.notify(e); + try { + l.notify(e); + } catch (Exception ex) { + // TODO what to do with it? + } } } } http://git-wip-us.apache.org/repos/asf/commons-compress/blob/17501ed8/src/main/java/org/apache/commons/compress/compressors/CompressorOutputStream.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/commons/compress/compressors/CompressorOutputStream.java b/src/main/java/org/apache/commons/compress/compressors/CompressorOutputStream.java index 9dd18a1..28440e0 100644 --- a/src/main/java/org/apache/commons/compress/compressors/CompressorOutputStream.java +++ b/src/main/java/org/apache/commons/compress/compressors/CompressorOutputStream.java @@ -60,7 +60,11 @@ public abstract class CompressorOutputStream extends OutputStream { CompressionProgressEvent e = new CompressionProgressEvent(this, blockNumber, streamNumber, compressedBytesWritten, getBytesWritten()); for (CompressionProgressListener l : listeners) { - l.notify(e); + try { + l.notify(e); + } catch (Exception ex) { + // TODO what to do with it? + } } }
