diff --git a/IntegrationEgaltech/Generator.cs b/IntegrationEgaltech/Generator.cs index dd66862..cb5ce4b 100644 --- a/IntegrationEgaltech/Generator.cs +++ b/IntegrationEgaltech/Generator.cs @@ -248,8 +248,8 @@ namespace ib.essetre.integration.egaltech vProc[j].nBar = -1 ; nActProc -- ; } - // altrimenti - else { + // se superato il numero di processi eseguibili in parallelo + else if ( vProc[j].Proc.ExitCode == 1) { // aggiungo il pezzo in coda if ( numBars + nShiftBar < numBars + nMaxThread) { vBar[numBars + nShiftBar] = vBar[vProc[j].nBar] ; @@ -260,6 +260,14 @@ namespace ib.essetre.integration.egaltech vProc[j].nBar = -1 ; nActProc -- ; } + // altrimenti (errore generico di esecuzione) + else { + // salvo il risultato + ProcessResults( vBar[vProc[j].nBar].sBtlPath, vBar[vProc[j].nBar].piInfo, parameters.UIMode) ; + bDone = true ; + vProc[j].nBar = -1 ; + nActProc -- ; + } } else vProc[j].Proc.Refresh() ; @@ -275,11 +283,21 @@ namespace ib.essetre.integration.egaltech ref bCancel); if ( bCancel ) { callback.Done( parameters) ; // fine - return; + return ; } } Thread.Sleep( 1) ; } + // Verifico che i processi non siano andati tutti in errore + bool bAllKO = true ; + for ( int j = 0 ; j < nMaxThread ; ++ j) { + if ( vProc[j].bEnable) + bAllKO = false ; + } + if ( bAllKO) { + MessageBox.Show( "Execution error (all processes are disabled)") ; + break ; + } Thread.Sleep( 10) ; } diff --git a/IntegrationEgaltech/Properties/AssemblyInfo.cs b/IntegrationEgaltech/Properties/AssemblyInfo.cs index 12c80d2..3e9a177 100644 --- a/IntegrationEgaltech/Properties/AssemblyInfo.cs +++ b/IntegrationEgaltech/Properties/AssemblyInfo.cs @@ -36,5 +36,5 @@ using System.Runtime.InteropServices; // È possibile specificare tutti i valori oppure impostare valori predefiniti per i numeri relativi alla revisione e alla build // usando l'asterisco '*' come illustrato di seguito: // [assembly: AssemblyVersion("1.0.*")] -[assembly: AssemblyVersion("2.2.2.1")] -[assembly: AssemblyFileVersion("2.2.2.1")] +[assembly: AssemblyVersion("2.2.2.2")] +[assembly: AssemblyFileVersion("2.2.2.2")]