Adds retry policy in exception error paths

LuccaSA · Oct 12, 2021 · c73a6d3 · c73a6d3
1 parent 21158b4
commit c73a6d3
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/TCC.Lib/TarCompressCrypt.cs b/TCC.Lib/TarCompressCrypt.cs
@@ -125,13 +125,17 @@ private async Task<OperationCompressionBlock> UploadBlockInternal(IRemoteStorage
 
                     sw.Stop();
 
-                    if (result.IsSuccess)
+                    if (!hasError)
                     {
                         double speed = file.Length / sw.Elapsed.TotalSeconds;
                         _logger.LogInformation($"{progress} Uploaded \"{file.Name}\" in {sw.Elapsed.HumanizedTimeSpan()} at {speed.HumanizedBandwidth()} ");
                     }
                     else
                     {
+                        if (ctx == null && option.RetryPeriodInSeconds.HasValue)
+                        {
+                            ctx = new RetryContext(option.RetryPeriodInSeconds.Value);
+                        }
                         _logger.LogError($"{progress} Uploaded {file.Name} with errors. {result.ErrorMessage}");
                     }
                 }
@@ -261,6 +265,10 @@ private async Task<OperationCompressionBlock> CompressionBlockInternal(CompressO
                     if (result.HasError)
                     {
                         hasError = true;
+                        if (ctx == null && option.RetryPeriodInSeconds.HasValue)
+                        {
+                            ctx = new RetryContext(option.RetryPeriodInSeconds.Value);
+                        }
                     }
                     var report = $"{progress} [{block.BackupMode}] : {block.BlockName}";
                     if (block.BackupMode == BackupMode.Diff)