Fix spec: rimanda su pagina 1 al cambio filtro su PODL KIT, fix vari RIOC

2026-06-12 18:34:57 +02:00
parent 5e7016629a
commit f738c0a690
12 changed files with 40 additions and 12 deletions
@@ -5,7 +5,7 @@
        <Nullable>enable</Nullable>
        <ImplicitUsings>enable</ImplicitUsings>
        <RootNamespace>MP.RIOC</RootNamespace>
-        <Version>8.16.2606.1217</Version>
+        <Version>8.16.2606.1218</Version>
        <AspNetCoreHostingModel>InProcess</AspNetCoreHostingModel>
    </PropertyGroup>

@@ -10,6 +10,10 @@ using System.Diagnostics;
 using System.Net;
 using System.Reflection;

+
+// Forza il ThreadPool a tenere pronti almeno 500 thread per i calcoli e 500 per l'I/O di rete
+ThreadPool.SetMinThreads(500, 500);
+
 var builder = WebApplication.CreateBuilder(args);

 // RECUPERO L'AMBIENTE REALE (Che ora IIS passa correttamente come 'Staging')
@@ -1,6 +1,6 @@
 <body>
    <i>Modulo MP-RIOC </i>
-    <h4>Versione: 8.16.2606.1217</h4>
+    <h4>Versione: 8.16.2606.1218</h4>
    <br /> Note di rilascio:
    <ul>
        <li>
@@ -1 +1 @@
-8.16.2606.1217
+8.16.2606.1218
@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <item>
-  <version>8.16.2606.1217</version>
+  <version>8.16.2606.1218</version>
  <url>https://nexus.steamware.net/repository/SWS/MP-RIOC/stable/LAST/MP.RIOC.zip</url>
  <changelog>https://nexus.steamware.net/repository/SWS/MP-RIOC/stable/LAST/ChangeLog.html</changelog>
  <mandatory>false</mandatory>
@@ -33,8 +33,23 @@ namespace MP.RIOC.Services
            {
                try
                {
-                    await ProcessDayLiveMetricsAsync();
-                    await ProcessHourLiveMetricsAsync();
+                    //await ProcessDayLiveMetricsAsync();
+                    //await ProcessHourLiveMetricsAsync();
+
+                    // 2. 🚀 COSTRINGIAMO IL FLUSH A GIRARE IN BACKGROUND
+                    // Task.Run prende l'intera esecuzione e la sposta su un thread separato.
+                    // In questo modo, anche se l'Upsert fa calcoli pesanti o blocca momentaneamente,
+                    // i thread principali di YARP rimangono liberi al 100% di rispondere a wrk in 2ms.
+                    await Task.Run(async () =>
+                    {
+                        // Cede immediatamente il controllo per evitare di monopolizzare il thread corrente
+                        await Task.Yield();
+
+                        // Esegue i tuoi due metodi (che manterranno i loro scope interni asincroni)
+                        await ProcessDayLiveMetricsAsync();
+                        await ProcessHourLiveMetricsAsync();
+                    }, stoppingToken);
+                    // poi attendo...
                    await Task.Delay(TimeSpan.FromSeconds(interval), stoppingToken);
                }
                catch (TaskCanceledException) { break; }
@@ -98,8 +98,16 @@ namespace MP.RIOC.Services

                // ESECUZIONE FORWARDING
                var error = await _forwarder.SendAsync(context, destBase, _httpClientInvoker, _forwarderConfig, HttpTransformer.Default, context.RequestAborted);
-                // commento transformer custom
-                //var error = await _forwarder.SendAsync(context, destBase, _httpClientInvoker, _forwarderConfig, _transformer, context.RequestAborted);
+                // Se YARP fallisce per un problema di connessione interrotta (come l'errore 995)
+                // e NON è un problema di sintassi della richiesta o di autorizzazione
+                if (error != ForwarderError.None &&
+                    error != ForwarderError.RequestBodyClient &&
+                    error != ForwarderError.NoAvailableDestinations)
+                {
+                    // Fai un secondo e ultimo tentativo immediato prima di dare errore al client
+                    Log.Warn($"Micro-reset di rete rilevato ({error}). Tento il secondo invio immediato...");
+                    error = await _forwarder.SendAsync(context, destBase, _httpClientInvoker, _forwarderConfig, HttpTransformer.Default, context.RequestAborted);
+                }

                sw.Stop();
                _stats.RecordDuration(sKey, sw.Elapsed);
@@ -169,6 +169,7 @@ namespace MP.SPEC.Components.ProdKit
        protected async Task toggleClosed()
        {
            hasOdl = !hasOdl;
+            currPage = 1;
            await EC_HasOdl.InvokeAsync(hasOdl);
        }

@@ -5,7 +5,7 @@
    <Nullable>enable</Nullable>
    <ImplicitUsings>enable</ImplicitUsings>
    <RootNamespace>MP.SPEC</RootNamespace>
-    <Version>8.16.2606.1216</Version>
+    <Version>8.16.2606.1218</Version>
    <UserSecretsId>1800a78a-6ff1-40f9-b490-87fb8bfc1394</UserSecretsId>
    <SatelliteResourceLanguages>en</SatelliteResourceLanguages>
  </PropertyGroup>
@@ -1,6 +1,6 @@
 <body>
    <i>Modulo MAPOSPEC </i>
-    <h4>Versione: 8.16.2606.1216</h4>
+    <h4>Versione: 8.16.2606.1218</h4>
    <br /> Note di rilascio:
    <ul>
        <li>
@@ -1 +1 @@
-8.16.2606.1216
+8.16.2606.1218
@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <item>
-  <version>8.16.2606.1216</version>
+  <version>8.16.2606.1218</version>
  <url>https://nexus.steamware.net/repository/SWS/MP-SPEC/stable/LAST/MP.SPEC.zip</url>
  <changelog>https://nexus.steamware.net/repository/SWS/MP-SPEC/stable/LAST/ChangeLog.html</changelog>
  <mandatory>false</mandatory>