Merge branch 'memory-test' into remove-comment

Author: Ruslan Dudchenko

ManagedCode.Storage.Tests/StorageBaseTests.cs

@@ -1,5 +1,5 @@
-using System;
-using System.Collections.Generic;
+using System.Collections.Generic;
+using System.Diagnostics;
 using System.IO;
 using System.Linq;
 using System.Text;
@@ -27,33 +27,34 @@ protected StorageBaseTests()
 
     #region MemoryPayload
 
-    //[Fact]
-    //public async Task WhenBigFilesUpload()
-    //{
-    //    var directory = Path.Combine(Environment.CurrentDirectory, "managed-code-bucket");
-
-    //    var bigFiles = new List<LocalFile>()
-    //    {
-    //        GetLocalFile($"{directory}/{nameof(WhenBigFilesUpload)}_1.txt", 100 * 1024 * 1024),
-    //        GetLocalFile($"{directory}/{nameof(WhenBigFilesUpload)}_2.txt", 100 * 1024 * 1024),
-    //        GetLocalFile($"{directory}/{nameof(WhenBigFilesUpload)}_3.txt", 100 * 1024 * 1024)
-    //    };
-
-    //    foreach (var localFile in bigFiles)
-    //    {
-    //        await Storage.UploadStreamAsync(localFile.FileName, localFile.FileStream);  
-    //    }
-
-    //    //foreach (var localFile in bigFiles)
-    //    //{
-    //    //    await Storage.DeleteAsync(localFile.FileName);
-    //    //}
-
-    //    //foreach (var localFile in bigFiles)
-    //    //{
-    //    //    localFile.Dispose();
-    //    //}
-    //}
+    [Fact]
+    public async Task UploadBigFilesAsync()
+    {
+        const int fileSize = 70 * 1024 * 1024;
+
+        var bigFiles = new List<LocalFile>()
+        {
+            GetLocalFile(fileSize),
+            GetLocalFile(fileSize),
+            GetLocalFile(fileSize)
+        };
+
+        foreach (var localFile in bigFiles)
+        {
+            await Storage.UploadStreamAsync(localFile.FileName, localFile.FileStream);
+            await localFile.DisposeAsync();
+        }
+
+        Process currentProcess = Process.GetCurrentProcess();
+        long totalBytesOfMemoryUsed = currentProcess.WorkingSet64;
+
+        totalBytesOfMemoryUsed.Should().BeLessThan(3 * fileSize);
+
+        foreach (var localFile in bigFiles)
+        {
+            await Storage.DeleteAsync(localFile.FileName);
+        }
+    }
 
     #endregion
 
@@ -627,14 +628,14 @@ private async Task<string> DownloadAsync(string fileName)
         return await sr.ReadToEndAsync();
     }
 
-    private LocalFile GetLocalFile(string fileName, int byteSize)
+    private LocalFile GetLocalFile(int byteSize)
     {
-        var localFile = new LocalFile(fileName);
+        var localFile = new LocalFile();
         var fs = localFile.FileStream;
 
         fs.Seek(byteSize, SeekOrigin.Begin);
         fs.WriteByte(0);
-        fs.Close();
+        fs.Dispose();
 
         return localFile;
     }