added logger to streams and packages

src/Downloader.Test/UnitTests/ChunkDownloaderOnMemoryTest.cs

@@ -12,6 +12,6 @@ public ChunkDownloaderOnMemoryTest()
             MinimumSizeOfChunking = 16,
             Timeout = 100,
         };
-        Storage = new ConcurrentStream();
+        Storage = new ConcurrentStream(null);
     }
 }

src/Downloader.Test/UnitTests/StorageTestOnMemory.cs

@@ -7,7 +7,7 @@ public class StorageTestOnMemory : StorageTest
 {
     protected override void CreateStorage(int initialSize)
     {
-        Storage = new ConcurrentStream();
+        Storage = new ConcurrentStream(null);
     }
 
     [Fact]

src/Downloader/ConcurrentPacketBuffer.cs

@@ -103,7 +103,7 @@ private void StopAddingIfLimitationExceeded(long packetSize)
     {
         if (BufferSize < packetSize * Count)
         {
-            _logger.LogDebug($"ConcurrentPacketBuffer: Stop writing packets to the queue on size {packetSize * Count}bytes until the memory is free");
+            _logger?.LogDebug($"ConcurrentPacketBuffer: Stop writing packets to the queue on size {packetSize * Count}bytes until the memory is free");
             StopAdding();
         }
     }
@@ -124,13 +124,13 @@ public async Task WaitToComplete()
 
     public void StopAdding()
     {
-        _logger.LogDebug("ConcurrentPacketBuffer: stop writing new items to the list by blocking writer threads");
+        _logger?.LogDebug("ConcurrentPacketBuffer: stop writing new items to the list by blocking writer threads");
         _addingBlocker.Pause();
     }
 
     public void ResumeAdding()
     {
-        _logger.LogDebug("ConcurrentPacketBuffer: resume writing new item to the list");
+        _logger?.LogDebug("ConcurrentPacketBuffer: resume writing new item to the list");
         _addingBlocker.Resume();
     }
 

src/Downloader/ConcurrentStream.cs

@@ -1,4 +1,5 @@
-using System;
+using Downloader.Extensions.Logging;
+using System;
 using System.IO;
 using System.Threading;
 using System.Threading.Tasks;
@@ -65,21 +66,21 @@ public long MaxMemoryBufferBytes
     }
 
     // parameterless constructor for deserialization
-    public ConcurrentStream() : this(0) { }
+    public ConcurrentStream(ILogger logger = null) : this(0, logger) { }
 
-    public ConcurrentStream(long maxMemoryBufferBytes = 0)
+    public ConcurrentStream(long maxMemoryBufferBytes = 0, ILogger logger = null) : base(logger)
     {
         _stream = new MemoryStream();
         Initial(maxMemoryBufferBytes);
     }
 
-    public ConcurrentStream(Stream stream, long maxMemoryBufferBytes = 0)
+    public ConcurrentStream(Stream stream, long maxMemoryBufferBytes = 0, ILogger logger = null) : base(logger)
     {
         _stream = stream;
         Initial(maxMemoryBufferBytes);
     }
 
-    public ConcurrentStream(string filename, long initSize, long maxMemoryBufferBytes = 0)
+    public ConcurrentStream(string filename, long initSize, long maxMemoryBufferBytes = 0, ILogger logger = null) : base(logger)
     {
         _path = filename;
         _stream = new FileStream(filename, FileMode.OpenOrCreate, FileAccess.ReadWrite, FileShare.Read);
@@ -90,9 +91,9 @@ public ConcurrentStream(string filename, long initSize, long maxMemoryBufferByte
         Initial(maxMemoryBufferBytes);
     }
 
-    private void Initial(long maxMemoryBufferBytes)
+    private void Initial(long maxMemoryBufferBytes, ILogger logger = null)
     {
-        _inputBuffer = new ConcurrentPacketBuffer<Packet>(maxMemoryBufferBytes);
+        _inputBuffer = new ConcurrentPacketBuffer<Packet>(maxMemoryBufferBytes, logger);
         _watcherCancelSource = new CancellationTokenSource();
 
         Task<Task> task = Task.Factory.StartNew(
@@ -145,6 +146,7 @@ private async Task Watcher()
         }
         catch (Exception ex) when (ex is TaskCanceledException || ex is OperationCanceledException)
         {
+            Logger?.LogError(ex, "ConcurrentStream: Call CancelState()");
             CancelState();
         }
         catch (Exception ex)

src/Downloader/DownloadPackage.cs

@@ -1,4 +1,5 @@
-using System;
+using Downloader.Extensions.Logging;
+using System;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
@@ -61,12 +62,12 @@ public void Validate()
         }
     }
 
-    public void BuildStorage(bool reserveFileSize, long maxMemoryBufferBytes = 0)
+    public void BuildStorage(bool reserveFileSize, long maxMemoryBufferBytes = 0, ILogger logger = null)
     {
         if (string.IsNullOrWhiteSpace(FileName))
-            Storage = new ConcurrentStream(maxMemoryBufferBytes);
+            Storage = new ConcurrentStream(maxMemoryBufferBytes, logger);
         else
-            Storage = new ConcurrentStream(FileName, reserveFileSize ? TotalFileSize : 0, maxMemoryBufferBytes);
+            Storage = new ConcurrentStream(FileName, reserveFileSize ? TotalFileSize : 0, maxMemoryBufferBytes, logger);
     }
 
     public void Dispose()

src/Downloader/TaskStateManagement.cs

@@ -1,12 +1,15 @@
-using System;
+using Downloader.Extensions.Logging;
+using System;
 using System.Collections.Concurrent;
+using System.Runtime.CompilerServices;
 using System.Threading.Tasks;
 
 namespace Downloader;
 
 public class TaskStateManagement
 {
     private readonly ConcurrentQueue<Exception> _exceptions = new ConcurrentQueue<Exception>();
+    protected readonly ILogger Logger;
 
     /// <summary>
     /// Gets the System.AggregateException that caused the ConcurrentStream
@@ -47,11 +50,17 @@ public class TaskStateManagement
     /// </summary>
     public TaskStatus Status { get; private set; } = TaskStatus.Created;
 
+    public TaskStateManagement(ILogger logger = null)
+    {
+        Logger = logger;
+    }
+
     internal void StartState() => Status = TaskStatus.Running;
     internal void CompleteState() => Status = TaskStatus.RanToCompletion;
     internal void CancelState() => Status = TaskStatus.Canceled;
-    internal void SetException(Exception exp)
+    internal void SetException(Exception exp, [CallerMemberName] string callerName = null)
     {
+        Logger?.LogCritical(exp, $"TaskStateManagement: SetException catch an exception on {callerName}");
         Status = TaskStatus.Faulted;
         _exceptions.Enqueue(exp);
         Exception = new AggregateException(_exceptions);