svn commit: r1597949 - /chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/main/java/org/apache/chemistry/opencmis/server/shared/ThresholdOutputStream.java

[fmui]

Author: fmui
Date: Wed May 28 08:56:37 2014
New Revision: 1597949

URL: http://svn.apache.org/r1597949
Log:
Added more logging to ThresholdOutputStream

Modified:
    
chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/main/java/org/apache/chemistry/opencmis/server/shared/ThresholdOutputStream.java

Modified: 
chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/main/java/org/apache/chemistry/opencmis/server/shared/ThresholdOutputStream.java
URL: 
http://svn.apache.org/viewvc/chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/main/java/org/apache/chemistry/opencmis/server/shared/ThresholdOutputStream.java?rev=1597949&r1=1597948&r2=1597949&view=diff
==============================================================================
--- 
chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/main/java/org/apache/chemistry/opencmis/server/shared/ThresholdOutputStream.java
 (original)
+++ 
chemistry/opencmis/trunk/chemistry-opencmis-server/chemistry-opencmis-server-bindings/src/main/java/org/apache/chemistry/opencmis/server/shared/ThresholdOutputStream.java
 Wed May 28 08:56:37 2014
@@ -170,6 +170,11 @@ public class ThresholdOutputStream exten
 
                 iv = cipher.getIV();
             } catch (Exception e) {
+
+                if (LOG.isErrorEnabled()) {
+                    LOG.error("Cannot initialize encryption cipher: {}", 
e.toString(), e);
+                }
+
                 throw new IOException("Cannot initialize encryption cipher!", 
e);
             }
 
@@ -206,6 +211,15 @@ public class ThresholdOutputStream exten
             size += len;
         } catch (IOException ioe) {
             destroy();
+
+            if (LOG.isErrorEnabled()) {
+                if (tempFile != null) {
+                    LOG.error("Writing to temp file {} failed: {}", 
tempFile.getAbsolutePath(), ioe.toString(), ioe);
+                } else {
+                    LOG.error("Writing to temp buffer failed: {}", 
ioe.toString(), ioe);
+                }
+            }
+
             throw ioe;
         }
     }
@@ -226,6 +240,15 @@ public class ThresholdOutputStream exten
             size++;
         } catch (IOException ioe) {
             destroy();
+
+            if (LOG.isErrorEnabled()) {
+                if (tempFile != null) {
+                    LOG.error("Writing to temp file {} failed: {}", 
tempFile.getAbsolutePath(), ioe.toString(), ioe);
+                } else {
+                    LOG.error("Writing to temp buffer failed: {}", 
ioe.toString(), ioe);
+                }
+            }
+
             throw ioe;
         }
     }
@@ -245,6 +268,11 @@ public class ThresholdOutputStream exten
                 tmpStream.flush();
             } catch (IOException ioe) {
                 destroy();
+
+                if (LOG.isErrorEnabled()) {
+                    LOG.error("Flushing the temp file {} failed: {}", 
tempFile.getAbsolutePath(), ioe.toString(), ioe);
+                }
+
                 throw ioe;
             }
         }
@@ -275,7 +303,9 @@ public class ThresholdOutputStream exten
         if (tempFile != null) {
             boolean isDeleted = tempFile.delete();
             if (!isDeleted) {
-                LOG.warn("Temp file " + tempFile.getAbsolutePath() + " could 
not be deleted!");
+                if (LOG.isErrorEnabled()) {
+                    LOG.error("Temp file {} could not be deleted!", 
tempFile.getAbsolutePath());
+                }
             }
         }
 
@@ -485,6 +515,11 @@ public class ThresholdOutputStream exten
                     cipher.init(Cipher.DECRYPT_MODE, key, new 
IvParameterSpec(iv));
                 } catch (Exception e) {
                     delete();
+
+                    if (LOG.isErrorEnabled()) {
+                        LOG.error("Cannot initialize decryption cipher: {}", 
e.toString(), e);
+                    }
+
                     throw new IOException("Cannot initialize decryption 
cipher!", e);
                 }
             } else {