aggiunto ritardo crescente su invii

2024-05-17 15:42:33 +02:00
parent 7406753961
commit 7c2a570971
5 changed files with 13 additions and 9 deletions
@@ -239,6 +239,8 @@ namespace Eqn.Sender.Controllers
                }
                messageList.Add(newMessage);
            }
+            int iter = 0;
+            int bDelay = 40;
            List<BatchResponse> listBResp = new List<BatchResponse>();
            if (numParall > 1)
            {
@@ -248,7 +250,7 @@ namespace Eqn.Sender.Controllers
                    // eventuale delay se richiesto
                    if (doDelay)
                    {
-                        await Task.Delay(rnd.Next(5, 15));
+                        await Task.Delay(bDelay * iter + rnd.Next(5, 15));
                    }
                    Stopwatch lsw = new Stopwatch();
                    var currData = new BStatData();
@@ -262,8 +264,9 @@ namespace Eqn.Sender.Controllers
                    // eventuale delay se richiesto
                    if (doDelay)
                    {
-                        await Task.Delay(rnd.Next(5, 15));
+                        await Task.Delay(bDelay * iter + rnd.Next(5, 15));
                    }
+                    iter++;
                });
            }
            else
@@ -273,7 +276,7 @@ namespace Eqn.Sender.Controllers
                    // eventuale delay se richiesto
                    if (doDelay)
                    {
-                        await Task.Delay(rnd.Next(5, 15));
+                        await Task.Delay(bDelay * iter + rnd.Next(5, 15));
                    }
                    Stopwatch lsw = new Stopwatch();
                    var currData = new BStatData();
@@ -287,8 +290,9 @@ namespace Eqn.Sender.Controllers
                    // eventuale delay se richiesto
                    if (doDelay)
                    {
-                        await Task.Delay(rnd.Next(5, 15));
+                        await Task.Delay(bDelay * iter + rnd.Next(5, 15));
                    }
+                    iter++;
                }
            }
            sw.Stop();
@@ -315,7 +319,7 @@ namespace Eqn.Sender.Controllers
                _logger.LogWarning(logVal);
                // scrivo tutte le righe
                int idx = 1;
-                foreach (var item in elapsedTime)
+                foreach (var item in elapsedTime.OrderBy(x => x.DtCreated))
                {
                    _logger.LogWarning($"{idx:00} | Start: {item.DtCreated:HH:mm:ss.ffffff} | bSize:{item.Size} | {item.TimeSec:N3} sec");
                    idx++;
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
  <PropertyGroup>
    <TargetFramework>net6.0</TargetFramework>
-    <Version>1.0.2405.1618</Version>
+    <Version>1.0.2405.1715</Version>
    <Nullable>enable</Nullable>
    <ImplicitUsings>enable</ImplicitUsings>
    <UserSecretsId>352f62a7-3b7d-40cd-ab21-b55a5fefae44</UserSecretsId>
@@ -1,6 +1,6 @@
 <body>
    <i>EqnSender - Gestione invio messaggi piattaforma EQN</i>
-    <h4>Versione: 1.0.2405.1618</h4>
+    <h4>Versione: 1.0.2405.1715</h4>
    <br /> Note di rilascio:
    <ul>
        <li>
@@ -1 +1 @@
-1.0.2405.1618
+1.0.2405.1715
@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <item>
-  <version>1.0.2405.1618</version>
+  <version>1.0.2405.1715</version>
  <url>http://nexus.steamware.net/repository/SWS/EqnSender/stable/0/EqnSender.zip</url>
  <changelog>http://nexus.steamware.net/repository/SWS/EqnSender/stable/0/ChangeLog.html</changelog>
  <mandatory>false</mandatory>