fix #6 add lock to Ensure...

pofider · Jan 26, 2016 · ee1398a · ee1398a
1 parent 38d312a
commit ee1398a
Showing 1 changed file with 14 additions and 9 deletions.
diff --git a/AzureBlobFileSystem/AzureBlobStorageProvider.cs b/AzureBlobFileSystem/AzureBlobStorageProvider.cs
@@ -14,6 +14,7 @@ namespace AzureBlobFileSystem
     public class AzureBlobStorageProvider  : IStorageProvider
     {
         private readonly CloudStorageAccount _storageAccount;
+        private Object _lock = new Object();
         public CloudBlobClient BlobClient { get; private set; }
         public IList<CloudBlobContainer> Containers { get; private set; }
         public Func<string, CloudBlobContainer> ContainerFactory;
@@ -30,18 +31,22 @@ private CloudBlobContainer EnsurePathIsRelativeAndEnsureContainer(ref string pat
         {
             var containerName = path.Split('/').First();
 
-            var container = Containers.SingleOrDefault(c => c.Name == containerName);
-
-            if (container == null)
+            CloudBlobContainer container;
+            lock (_lock)
             {
-                container = BlobClient.GetContainerReference(containerName);
-                
-                if (!container.Exists())
+                container = Containers.SingleOrDefault(c => c.Name == containerName);
+
+                if (container == null)
                 {
-                    container = ContainerFactory(containerName);
-                }
+                    container = BlobClient.GetContainerReference(containerName);
 
-                Containers.Add(container);
+                    if (!container.Exists())
+                    {
+                        container = ContainerFactory(containerName);
+                    }
+
+                    Containers.Add(container);
+                }
             }
 
             if (path.StartsWith("/") || path.StartsWith("http://") || path.StartsWith("https://"))