close request output stream

Author: dpproduction

microsoft-azure-storage/src/com/microsoft/azure/storage/core/ExecutionEngine.java

@@ -17,6 +17,7 @@
 
 import java.io.IOException;
 import java.io.InputStream;
+import java.io.OutputStream;
 import java.net.HttpURLConnection;
 import java.util.Date;
 import java.util.Map.Entry;
@@ -72,6 +73,7 @@ public static <CLIENT_TYPE, PARENT_TYPE, RESULT_TYPE> RESULT_TYPE executeWithRet
         int currentRetryCount = 0;
         StorageException translatedException = null;
         HttpURLConnection request = null;
+        OutputStream requestOutputStream = null;
         final long startTime = new Date().getTime();
 
         while (true) {
@@ -87,8 +89,9 @@ public static <CLIENT_TYPE, PARENT_TYPE, RESULT_TYPE> RESULT_TYPE executeWithRet
                 try {
                     if (task.getSendStream() != null) {
                         Logger.info(opContext, LogConstants.UPLOAD);
+                        requestOutputStream = request.getOutputStream();
                         final StreamMd5AndLength descriptor = Utility.writeToOutputStream(task.getSendStream(),
-                                request.getOutputStream(), task.getLength(), false /* rewindStream */,
+                                requestOutputStream, task.getLength(), false /* rewindStream */,
                                 false /* calculate MD5 */, opContext, task.getRequestOptions());
 
                         task.validateStreamWrite(descriptor);
@@ -131,6 +134,14 @@ public static <CLIENT_TYPE, PARENT_TYPE, RESULT_TYPE> RESULT_TYPE executeWithRet
 
                         ExecutionEngine.fireErrorReceivingResponseEvent(opContext, request, task.getResult());
                     }
+                    if(requestOutputStream != null){
+                        if (requestOutputStream != null) {
+                            try {
+                                requestOutputStream.close();
+                            } catch (IOException logOrIgnore) {
+                            }
+                        }
+                    }
                 }
 
                 // 8. Pre-process response to check if there was an exception. Do Response parsing (headers etc).