Storage Client Library - 4.2.1

Lib/Common/Blob/CloudBlockBlob.Common.cs

@@ -515,7 +515,11 @@ private void ParseQueryAndVerify(StorageUri address, StorageCredentials credenti
                 this.SnapshotTime = parsedSnapshot;
             }
 
-            this.ServiceClient = new CloudBlobClient(NavigationHelper.GetServiceClientBaseAddress(this.StorageUri, null /* usePathStyleUris */), credentials ?? parsedCredentials);
+            if (this.ServiceClient == null)
+            {
+                this.ServiceClient = new CloudBlobClient(NavigationHelper.GetServiceClientBaseAddress(this.StorageUri, null /* usePathStyleUris */), credentials ?? parsedCredentials);
+            }
+
             this.Name = NavigationHelper.GetBlobName(this.Uri, this.ServiceClient.UsePathStyleUris);
         }
     }

Lib/Common/Blob/CloudPageBlob.Common.cs

@@ -512,7 +512,11 @@ private void ParseQueryAndVerify(StorageUri address, StorageCredentials credenti
                 this.SnapshotTime = parsedSnapshot;
             }
 
-            this.ServiceClient = new CloudBlobClient(NavigationHelper.GetServiceClientBaseAddress(this.StorageUri, null /* usePathStyleUris */), credentials ?? parsedCredentials);
+            if (this.ServiceClient == null)
+            {
+                this.ServiceClient = new CloudBlobClient(NavigationHelper.GetServiceClientBaseAddress(this.StorageUri, null /* usePathStyleUris */), credentials ?? parsedCredentials);
+            }
+
             this.Name = NavigationHelper.GetBlobName(this.Uri, this.ServiceClient.UsePathStyleUris);
         }
     }

Lib/Common/File/CloudFile.Common.cs

@@ -262,7 +262,11 @@ public CloudFileDirectory Parent
         private void ParseQueryAndVerify(StorageUri address, StorageCredentials credentials)
         {
             this.attributes.StorageUri = address;
-            this.ServiceClient = new CloudFileClient(NavigationHelper.GetServiceClientBaseAddress(this.StorageUri, null /* usePathStyleUris */), credentials);
+            if (this.ServiceClient == null)
+            {
+                this.ServiceClient = new CloudFileClient(NavigationHelper.GetServiceClientBaseAddress(this.StorageUri, null /* usePathStyleUris */), credentials);
+            }
+
             this.Name = NavigationHelper.GetFileName(this.Uri, this.ServiceClient.UsePathStyleUris);
         }
     }

Lib/Common/Shared/Protocol/Constants.cs

@@ -760,7 +760,7 @@ static HeaderConstants()
             /// <summary>
             /// Specifies the value to use for UserAgent header.
             /// </summary>
-            public const string UserAgentProductVersion = "4.2.0";
+            public const string UserAgentProductVersion = "4.2.1";
 
             /// <summary>
             /// Master Windows Azure Storage header prefix.

Lib/Common/StorageException.cs

@@ -252,7 +252,7 @@ private static StorageException CoreTranslate(Exception ex, RequestResult reqRes
             else if (ex is TimeoutException)
             {
                 reqResult.HttpStatusMessage = null;
-                reqResult.HttpStatusCode = (int)HttpStatusCode.Unused;
+                reqResult.HttpStatusCode = (int)HttpStatusCode.RequestTimeout;
                 reqResult.ExtendedErrorInformation = null;
                 return new StorageException(reqResult, ex.Message, ex);
             }
@@ -309,7 +309,7 @@ internal static StorageException TranslateDataServiceException(Exception ex, Req
             else if (ex is TimeoutException)
             {
                 reqResult.HttpStatusMessage = null;
-                reqResult.HttpStatusCode = (int)HttpStatusCode.Unused;
+                reqResult.HttpStatusCode = (int)HttpStatusCode.RequestTimeout;
                 reqResult.ExtendedErrorInformation = null;
                 return new StorageException(reqResult, ex.Message, ex);
             }
@@ -351,6 +351,13 @@ private static void PopulateRequestResult(RequestResult reqResult, HttpWebRespon
                 string tempDate = HttpWebUtility.TryGetHeader(response, "Date", null);
                 reqResult.RequestDate = string.IsNullOrEmpty(tempDate) ? DateTime.Now.ToString("R", CultureInfo.InvariantCulture) : tempDate;
                 reqResult.Etag = response.Headers[HttpResponseHeader.ETag];
+#endif
+            }
+
+            if (response.ContentLength > 0) 
+            {
+#if !WINDOWS_RT
+                reqResult.IngressBytes += response.ContentLength;
 #endif
             }
         }

Lib/WindowsDesktop/Properties/AssemblyInfo.cs

@@ -34,8 +34,8 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("4.2.0.0")]
-[assembly: AssemblyFileVersion("4.2.0.0")]
+[assembly: AssemblyVersion("4.2.1.0")]
+[assembly: AssemblyFileVersion("4.2.1.0")]
 
 #if SIGN
 [assembly: InternalsVisibleTo(

Lib/WindowsDesktop/WindowsAzure.Storage.nuspec

@@ -2,7 +2,7 @@
 <package xmlns="http://schemas.microsoft.com/packaging/2011/08/nuspec.xsd">
   <metadata>
     <id>WindowsAzure.Storage</id>
-    <version>4.2.0</version>
+    <version>4.2.1</version>
     <title>Windows Azure Storage</title>
     <authors>Microsoft</authors>
     <owners>Microsoft</owners>

Lib/WindowsPhone/Properties/AssemblyInfo.cs

@@ -32,8 +32,8 @@
 //
 // You can specify all the values or you can default the Revision and Build Numbers 
 // by using the '*' as shown below:
-[assembly: AssemblyVersion("4.2.0.0")]
-[assembly: AssemblyFileVersion("4.2.0.0")]
+[assembly: AssemblyVersion("4.2.1.0")]
+[assembly: AssemblyFileVersion("4.2.1.0")]
 [assembly: NeutralResourcesLanguageAttribute("en-US")]
 
 #if SIGN

Lib/WindowsRuntime/Properties/AssemblyInfo.cs

@@ -25,8 +25,8 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("4.2.0.0")]
-[assembly: AssemblyFileVersion("4.2.0.0")]
+[assembly: AssemblyVersion("4.2.1.0")]
+[assembly: AssemblyFileVersion("4.2.1.0")]
 [assembly: ComVisible(false)]
 
 #if SIGN

README.md

@@ -1,4 +1,4 @@
-# Microsoft Azure Storage SDK for .NET (4.2.0)
+# Microsoft Azure Storage SDK for .NET (4.2.1)
 
 The Microsoft Azure Storage SDK for .NET allows you to build Azure applications 
 that take advantage of scalable cloud computing resources.

Test/ClassLibraryCommon/Blob/BlobManglerUnitTests.cs

@@ -114,6 +114,19 @@ public void BlobIngressEgressCounters()
                 });
 
                 Assert.AreEqual(blob.Properties.Length, 98765 + 1024 + 1);
+
+                // Error Case
+                CloudBlockBlob nullBlob = container.GetBlockBlobReference("null");
+                OperationContext errorContext = new OperationContext();
+                try
+                {
+                    nullBlob.DownloadToStream(Stream.Null, null, new BlobRequestOptions() { RetryPolicy = new RetryPolicies.NoRetry() }, errorContext);
+                    Assert.Fail("Null blob, null stream, no download possible.");
+                }
+                catch (StorageException)
+                {
+                    Assert.IsTrue(errorContext.LastResult.IngressBytes > 0);
+                }
             }
             finally
             {

Test/ClassLibraryCommon/Blob/CloudBlobContainerTest.cs

@@ -2060,7 +2060,9 @@ public void CloudBlobContainerSetMetadataTask()
         [TestCategory(TenantTypeCategory.DevStore), TestCategory(TenantTypeCategory.DevFabric), TestCategory(TenantTypeCategory.Cloud)]
         public void CloudBlobContainerListBlobs()
         {
-            CloudBlobContainer container = GetRandomContainerReference();
+            CloudBlobClient client = GenerateCloudBlobClient();
+            client.DefaultRequestOptions.LocationMode = RetryPolicies.LocationMode.PrimaryThenSecondary;
+            CloudBlobContainer container = client.GetContainerReference(GetRandomContainerName());
             try
             {
                 container.Create();
@@ -2072,6 +2074,7 @@ public void CloudBlobContainerListBlobs()
                 {
                     Assert.IsInstanceOfType(blobItem, typeof(CloudPageBlob));
                     Assert.IsTrue(blobNames.Remove(((CloudPageBlob)blobItem).Name));
+                    Assert.AreEqual(RetryPolicies.LocationMode.PrimaryThenSecondary, ((CloudPageBlob)blobItem).ServiceClient.DefaultRequestOptions.LocationMode);
                 }
             }
             finally

Test/ClassLibraryCommon/Blob/CloudBlockBlobTest.cs

@@ -3751,5 +3751,29 @@ private void DoTextUploadDownloadTask(string text, bool checkDifferentEncoding)
             }
         }
 #endif
+
+        [TestMethod]
+        [Description("Test server failure retry case.")]
+        [TestCategory(ComponentCategory.Blob)]
+        [TestCategory(TestTypeCategory.UnitTest)]
+        [TestCategory(SmokeTestCategory.NonSmoke)]
+        [TestCategory(TenantTypeCategory.DevFabric), TestCategory(TenantTypeCategory.Cloud)]
+        public void CloudBlockBlobFailoverRetry()
+        {
+            OperationContext opContext = new OperationContext();
+            CloudBlobClient badPrimaryClient = new CloudBlobClient(new StorageUri(new Uri("http://1.2.3.4/x//"), new Uri(TargetTenantConfig.BlobServiceSecondaryEndpoint)), TestBase.StorageCredentials);
+            CloudBlockBlob secondaryBlob = badPrimaryClient.GetContainerReference(GetRandomContainerName()).GetBlockBlobReference("testblob");
+            badPrimaryClient.DefaultRequestOptions.RetryPolicy = new RetryPolicies.LinearRetry(TimeSpan.Zero, 1);
+            badPrimaryClient.DefaultRequestOptions.LocationMode = RetryPolicies.LocationMode.PrimaryThenSecondary;
+            try
+            {
+                secondaryBlob.DownloadText(operationContext: opContext);
+            }
+            catch (StorageException)
+            {
+                Assert.IsTrue(opContext.RequestResults.Count > 1);
+                Assert.AreEqual(StorageLocation.Secondary, opContext.LastResult.TargetLocation);
+            }
+        }
     }
 }

Test/WindowsDesktop/Properties/AssemblyInfo.cs

@@ -32,5 +32,5 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("4.2.0.0")]
-[assembly: AssemblyFileVersion("4.2.0.0")]
+[assembly: AssemblyVersion("4.2.1.0")]
+[assembly: AssemblyFileVersion("4.2.1.0")]

Test/WindowsPhone/Properties/AssemblyInfo.cs

@@ -32,6 +32,6 @@
 //
 // You can specify all the values or you can default the Revision and Build Numbers 
 // by using the '*' as shown below:
-[assembly: AssemblyVersion("4.2.0.0")]
-[assembly: AssemblyFileVersion("4.2.0.0")]
+[assembly: AssemblyVersion("4.2.1.0")]
+[assembly: AssemblyFileVersion("4.2.1.0")]
 [assembly: NeutralResourcesLanguageAttribute("en-US")]

Test/WindowsPhone81/Properties/AssemblyInfo.cs

@@ -32,6 +32,6 @@
 //
 // You can specify all the values or you can default the Revision and Build Numbers 
 // by using the '*' as shown below:
-[assembly: AssemblyVersion("4.2.0.0")]
-[assembly: AssemblyFileVersion("4.2.0.0")]
+[assembly: AssemblyVersion("4.2.1.0")]
+[assembly: AssemblyFileVersion("4.2.1.0")]
 [assembly: NeutralResourcesLanguageAttribute("en-US")]

Test/WindowsRuntime/Blob/ExceptionHResultTest.cs

@@ -102,7 +102,7 @@ public async Task CloudBlobUploadTimeoutAsync()
             }
             catch (Exception e)
             {
-                Assert.AreEqual(WindowsAzureErrorCode.TimeoutException, e.HResult);
+                Assert.AreEqual(WindowsAzureErrorCode.HttpRequestTimeout, e.HResult);
             }
             finally
             {

Test/WindowsRuntime/File/FileExceptionHResultTest.cs

@@ -101,7 +101,7 @@ public async Task CloudFileUploadTimeoutAsync()
             }
             catch (Exception e)
             {
-                Assert.AreEqual(WindowsAzureErrorCode.TimeoutException, e.InnerException.InnerException.HResult);
+                Assert.AreEqual(WindowsAzureErrorCode.HttpRequestTimeout, e.InnerException.InnerException.HResult);
             }
             finally
             {

Test/WindowsRuntime/Properties/AssemblyInfo.cs

@@ -24,5 +24,5 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("4.2.0.0")]
-[assembly: AssemblyFileVersion("4.2.0.0")]
+[assembly: AssemblyVersion("4.2.1.0")]
+[assembly: AssemblyFileVersion("4.2.1.0")]

changelog.txt

@@ -1,3 +1,9 @@
+Changes in 4.2.1 : 
+
+ - All: Fixed a bug where a TimeoutException was not properly retried.
+ - All: Fixed a bug where the IngressBytes of a RequestResult was not properly set in the exception case.
+ - All: Fixed a bug where default request options were overwritten on the resulting objects returned from a ListBlobs call.
+
 Changes in 4.2.0 :
 
   - All: Added the NameValidator class which contains helpers that check to see if resource names are valid.