StatisticsCollection.java

  1. /*
  2.  * GovWay - A customizable API Gateway 
  3.  * https://govway.org
  4.  * 
  5.  * Copyright (c) 2005-2025 Link.it srl (https://link.it). 
  6.  * 
  7.  * This program is free software: you can redistribute it and/or modify
  8.  * it under the terms of the GNU General Public License version 3, as published by
  9.  * the Free Software Foundation.
  10.  *
  11.  * This program is distributed in the hope that it will be useful,
  12.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14.  * GNU General Public License for more details.
  15.  *
  16.  * You should have received a copy of the GNU General Public License
  17.  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18.  *
  19.  */

  21. package org.openspcoop2.pdd.core.handlers.statistics;

  23. import java.util.List;

  25. import org.openspcoop2.core.constants.TipoPdD;
  26. import org.openspcoop2.protocol.sdk.IProtocolFactory;
  27. import org.openspcoop2.protocol.sdk.builder.EsitoTransazione;
  28. import org.openspcoop2.protocol.utils.EsitiProperties;
  29. import org.openspcoop2.utils.LoggerWrapperFactory;
  30. import org.openspcoop2.utils.SemaphoreLock;
  31. import org.openspcoop2.utils.UtilsRuntimeException;
  32. import org.openspcoop2.utils.date.DateManager;
  33. import org.slf4j.Logger;

  35. /**
  36.  * StatisticsCollection
  37.  *
  38.  * @author Poli Andrea (apoli@link.it)
  39.  * @author $Author$
  40.  * @version $Rev$, $Date$
  41.  */
  42. public class StatisticsCollection {

  44.     private StatisticsCollection() {}
  45.     
  46.     private static final StatisticsCollection statisticsCollection =  new StatisticsCollection();
  47.     public static StatisticsCollection getStatisticsCollection(){
  48.         return StatisticsCollection.statisticsCollection;
  49.     }

  51.     private static final long SOGLIA_DIMENSIONE = Long.MAX_VALUE-100000;
  52.     private static final int SOGLIA_TEMPORALE = 1000*60*30; // statistiche relative all'ultima mezz'ora.
  53.     
  54.     private static Logger log = LoggerWrapperFactory.getLogger(StatisticsCollection.class);
  55.     private static boolean isEsitoOk(EsitoTransazione esito, IProtocolFactory<?> protocollo){
  56.         try{
  57.             if(esito==null) {
  58.                 return false;
  59.             }
  60.             List<Integer> esitiOk = EsitiProperties.getInstance(log,protocollo).getEsitiCodeOk();
  61.             for (Integer esitoOk : esitiOk) {
  62.                 if(esitoOk!=null && esito.getCode()!=null) {
  63.                     if(esitoOk.intValue() == esito.getCode().intValue()){
  64.                         return true;
  65.                     }
  66.                 }
  67.             }
  68.             return false;
  69.         }catch(Exception e){
  70.             // non sono previsti errori
  71.             throw new UtilsRuntimeException(e.getMessage(),e);
  72.         }
  73.     }
  74.     
  75.     
  76.     
  77.     /* ***** UPDATE STATO ******* */
  78.     private static org.openspcoop2.utils.Semaphore semaphore = new org.openspcoop2.utils.Semaphore("StatisticsCollection");
  79.     public static void update(Statistic stat){
  80.         SemaphoreLock lock = semaphore.acquireThrowRuntime("update");
  81.         try {
  82.             updateEngine(stat);
  83.         }finally {
  84.             semaphore.release(lock, "update");
  85.         }
  86.     }
  87.     private static void updateEngine(Statistic stat){

  89.         if(!TipoPdD.APPLICATIVA.equals(stat.getTipoPdD()) &&
  90.                 !TipoPdD.DELEGATA.equals(stat.getTipoPdD()) ){
  91.             return;
  92.         }
  93.         
  94.         // Check soglia temporale
  95.         if(StatisticsCollection.getStatisticsCollection().dataUltimoRefresh>0){
  96.             if((DateManager.getTimeMillis()-StatisticsCollection.getStatisticsCollection().dataUltimoRefresh)>StatisticsCollection.SOGLIA_TEMPORALE){
  97.                 StatisticsCollection.reset();
  98.             }
  99.         }
  100.         else{
  101.             // Inserisco data arrivo richiesta 
  102.             StatisticsCollection.getStatisticsCollection().dataUltimoRefresh = stat.getTimeMillisIngressoRichiesta();
  103.             if(StatisticsCollection.getStatisticsCollection().dataUltimoRefresh<=0){
  104.                 StatisticsCollection.getStatisticsCollection().dataUltimoRefresh = DateManager.getTimeMillis();
  105.             }
  106.         }
  107.         
  108.         // Cechk soglia sulla dimensione
  109.         /**if(needResetForOverSizeLong()){
  110.             reset();
  111.         }*/
  112.         
  113.         // Contatori
  114.         StatisticsCollection.incrementCount(stat.getEsito(), stat.getProtocollo(), StatisticsCollection.statisticsCollection.statNumeroTransazioni);
  115.         if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  116.             StatisticsCollection.incrementCount(stat.getEsito(), stat.getProtocollo(), StatisticsCollection.statisticsCollection.statNumeroTransazioniPA);
  117.         }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  118.             StatisticsCollection.incrementCount(stat.getEsito(), stat.getProtocollo(), StatisticsCollection.statisticsCollection.statNumeroTransazioniPD);
  119.         }
  120.         
  121.         // Latenze
  122.         if(isEsitoOk(stat.getEsito(),stat.getProtocollo())){
  123.             
  124.             long latenzaTotale = -1;
  125.             if(stat.getTimeMillisUscitaRisposta()>0 && stat.getTimeMillisIngressoRichiesta()>0)
  126.                 latenzaTotale = stat.getTimeMillisUscitaRisposta() - stat.getTimeMillisIngressoRichiesta();
  127.             if(latenzaTotale>0){
  128.                 StatisticsCollection.computeLatenza(latenzaTotale, StatisticsCollection.statisticsCollection.statLatenzaAttraversamento);
  129.                 if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  130.                     StatisticsCollection.computeLatenza(latenzaTotale, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoPA);
  131.                 }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  132.                     StatisticsCollection.computeLatenza(latenzaTotale, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoPD);
  133.                 }   
  134.             }
  135.             
  136.             long latenzaRichiesta = -1;
  137.             if(stat.getTimeMillisUscitaRichiesta()>0 && stat.getTimeMillisIngressoRichiesta()>0)
  138.                 latenzaRichiesta = stat.getTimeMillisUscitaRichiesta() - stat.getTimeMillisIngressoRichiesta();
  139.             if(latenzaRichiesta>0){
  140.                 StatisticsCollection.computeLatenza(latenzaRichiesta, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoRequest);
  141.                 if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  142.                     StatisticsCollection.computeLatenza(latenzaRichiesta, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoPARequest);
  143.                 }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  144.                     StatisticsCollection.computeLatenza(latenzaRichiesta, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoPDRequest);
  145.                 }   
  146.             }
  147.             
  148.             long latenzaRisposta = -1;
  149.             if(stat.getTimeMillisUscitaRisposta()>0 && stat.getTimeMillisIngressoRisposta()>0)
  150.                 latenzaRisposta = stat.getTimeMillisUscitaRisposta() - stat.getTimeMillisIngressoRisposta();
  151.             if(latenzaRisposta>0){
  152.                 StatisticsCollection.computeLatenza(latenzaRisposta, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoResponse);
  153.                 if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  154.                     StatisticsCollection.computeLatenza(latenzaRisposta, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoPAResponse);
  155.                 }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  156.                     StatisticsCollection.computeLatenza(latenzaRisposta, StatisticsCollection.statisticsCollection.statLatenzaAttraversamentoPDResponse);
  157.                 }   
  158.             }
  159.                 
  160.         }
  161.         
  162.         
  163.         // Dimensioni
  164.         
  165.         long inRequestSize = stat.getDimensioneIngressoRichiesta();
  166.         if(inRequestSize>0){
  167.             StatisticsCollection.computeDimensione(inRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggio);
  168.             StatisticsCollection.computeDimensione(inRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioInRequest);
  169.             if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  170.                 StatisticsCollection.computeDimensione(inRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPA);
  171.                 StatisticsCollection.computeDimensione(inRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPAInRequest);
  172.             }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  173.                 StatisticsCollection.computeDimensione(inRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPD);
  174.                 StatisticsCollection.computeDimensione(inRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPDInRequest);
  175.             }
  176.         }
  177.         
  178.         long outRequestSize = stat.getDimensioneUscitaRichiesta();
  179.         if(outRequestSize>0){
  180.             StatisticsCollection.computeDimensione(outRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggio);
  181.             StatisticsCollection.computeDimensione(outRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioOutRequest);
  182.             if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  183.                 StatisticsCollection.computeDimensione(outRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPA);
  184.                 StatisticsCollection.computeDimensione(outRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPAOutRequest);
  185.             }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  186.                 StatisticsCollection.computeDimensione(outRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPD);
  187.                 StatisticsCollection.computeDimensione(outRequestSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPDOutRequest);
  188.             }
  189.         }
  190.         
  191.         long inResponseSize = stat.getDimensioneIngressoRisposta();
  192.         if(inResponseSize>0){
  193.             StatisticsCollection.computeDimensione(inResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggio);
  194.             StatisticsCollection.computeDimensione(inResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioInResponse);
  195.             if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  196.                 StatisticsCollection.computeDimensione(inResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPA);
  197.                 StatisticsCollection.computeDimensione(inResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPAInResponse);
  198.             }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  199.                 StatisticsCollection.computeDimensione(inResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPD);
  200.                 StatisticsCollection.computeDimensione(inResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPDInResponse);
  201.             }
  202.         }
  203.         
  204.         long outResponseSize = stat.getDimensioneUscitaRisposta();
  205.         if(outResponseSize>0){
  206.             StatisticsCollection.computeDimensione(outResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggio);
  207.             StatisticsCollection.computeDimensione(outResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioOutResponse);
  208.             if(TipoPdD.APPLICATIVA.equals(stat.getTipoPdD())){
  209.                 StatisticsCollection.computeDimensione(outResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPA);
  210.                 StatisticsCollection.computeDimensione(outResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPAOutResponse);
  211.             }else if(TipoPdD.DELEGATA.equals(stat.getTipoPdD())){
  212.                 StatisticsCollection.computeDimensione(outResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPD);
  213.                 StatisticsCollection.computeDimensione(outResponseSize, StatisticsCollection.statisticsCollection.statDimensioneMessaggioPDOutResponse);
  214.             }
  215.         }
  216.     }
  217.     
  218.     
  219.     @SuppressWarnings("unused")
  220.     private static boolean needResetForOverSizeLong(){
  221.         
  222.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamento.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  223.             return true;
  224.         }
  225.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoRequest.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  226.             return true;
  227.         }
  228.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoResponse.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  229.             return true;
  230.         }
  231.         
  232.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPD.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  233.             return true;
  234.         }
  235.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPDRequest.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  236.             return true;
  237.         }
  238.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPDResponse.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  239.             return true;
  240.         }
  241.         
  242.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPA.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  243.             return true;
  244.         }
  245.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPARequest.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  246.             return true;
  247.         }
  248.         if(StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPAResponse.tmp_latenzaMediaAttraversamento_sumLatenze>StatisticsCollection.SOGLIA_DIMENSIONE){
  249.             return true;
  250.         }

  252.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggio.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  253.             return true;
  254.         }
  255.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioInRequest.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  256.             return true;
  257.         }
  258.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioOutRequest.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  259.             return true;
  260.         }
  261.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioInResponse.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  262.             return true;
  263.         }
  264.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioOutResponse.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  265.             return true;
  266.         }
  267.         
  268.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPD.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  269.             return true;
  270.         }
  271.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDInRequest.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  272.             return true;
  273.         }
  274.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDOutRequest.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  275.             return true;
  276.         }
  277.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDInResponse.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  278.             return true;
  279.         }
  280.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDOutResponse.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  281.             return true;
  282.         }

  284.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPA.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  285.             return true;
  286.         }
  287.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAInRequest.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  288.             return true;
  289.         }
  290.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAOutRequest.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  291.             return true;
  292.         }
  293.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAInResponse.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  294.             return true;
  295.         }
  296.         if(StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAOutResponse.tmp_dimensioneMediaMessaggio_sumDimensioni>StatisticsCollection.SOGLIA_DIMENSIONE){
  297.             return true;
  298.         }
  299.         
  300.         return false;
  301.         
  302.     }
  303.     
  304.     
  305.     public static void reset(){
  306.         
  307.         StatisticsCollection.getStatisticsCollection().dataUltimoRefresh = -1;
  308.         
  309.         StatisticsCollection.getStatisticsCollection().statNumeroTransazioni = new StatisticCount();
  310.         StatisticsCollection.getStatisticsCollection().statNumeroTransazioniPD = new StatisticCount();
  311.         StatisticsCollection.getStatisticsCollection().statNumeroTransazioniPA = new StatisticCount();
  312.         
  313.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamento = new StatisticTime();
  314.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoRequest = new StatisticTime();
  315.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoResponse = new StatisticTime();
  316.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPD = new StatisticTime();
  317.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPDRequest = new StatisticTime();
  318.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPDResponse = new StatisticTime();
  319.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPA = new StatisticTime();
  320.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPARequest = new StatisticTime();
  321.         StatisticsCollection.getStatisticsCollection().statLatenzaAttraversamentoPAResponse = new StatisticTime();
  322.         
  323.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggio = new StatisticSize();
  324.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioInRequest = new StatisticSize();
  325.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioOutRequest = new StatisticSize();
  326.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioInResponse = new StatisticSize();
  327.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioOutResponse = new StatisticSize();
  328.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioResponse = new StatisticSize();
  329.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPD = new StatisticSize();
  330.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDInRequest = new StatisticSize();
  331.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDOutRequest = new StatisticSize();
  332.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDInResponse = new StatisticSize();
  333.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPDOutResponse = new StatisticSize();
  334.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPA = new StatisticSize();
  335.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAInRequest = new StatisticSize();
  336.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAOutRequest = new StatisticSize();
  337.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAInResponse = new StatisticSize();
  338.         StatisticsCollection.getStatisticsCollection().statDimensioneMessaggioPAOutResponse = new StatisticSize();
  339.     }
  340.         
  341.     private static void incrementCount(EsitoTransazione esito,IProtocolFactory<?> protocollo, StatisticCount statCount){
  342.         statCount.numeroTransazioni++;
  343.         if(isEsitoOk(esito,protocollo)){
  344.             statCount.numeroTransazioni_esitoOK++;
  345.         }else{
  346.             statCount.numeroTransazioni_esitoErrore++;
  347.         }
  348.     }
  349.     
  350.     private static void computeLatenza(long latenza,StatisticTime statTime){
  351.         
  352.         // Minima
  353.         if(statTime.latenzaMinimaAttraversamento<=0 || latenza<statTime.latenzaMinimaAttraversamento)
  354.             statTime.latenzaMinimaAttraversamento = latenza;
  355.         
  356.         // Massima
  357.         if(latenza>statTime.latenzaMassimaAttraversamento)
  358.             statTime.latenzaMassimaAttraversamento = latenza;
  359.         
  360.         // Media
  361.         statTime.tmp_latenzaMediaAttraversamento_sumLatenze+=latenza;
  362.         statTime.tmp_latenzaMediaAttraversamento_countTransazioni++;
  363.         statTime.latenzaMediaAttraversamento = statTime.tmp_latenzaMediaAttraversamento_sumLatenze/statTime.tmp_latenzaMediaAttraversamento_countTransazioni;
  364.         // Effettuo refresh nel controllo iniziale, almeno tutti i dati sono consistenti rispetto all'intervallo temporale
  365. /**     if(statTime.tmp_latenzaMediaAttraversamento_sumLatenze>SOGLIA_DIMENSIONE){
  366. //          // azzero temporanei
  367. //          statTime.tmp_latenzaMediaAttraversamento_sumLatenze=statTime.tmp_latenzaMediaAttraversamento_sumLatenze;
  368. //          statTime.tmp_latenzaMediaAttraversamento_countTransazioni=1;
  369. //      }*/
  370.     }
  371.     
  372.     
  373.     
  374.     private static void computeDimensione(long dimensione,StatisticSize statSize){
  375.         
  376.         // Minima
  377.         if(statSize.dimensioneMinimaMessaggio<=0 || dimensione<statSize.dimensioneMinimaMessaggio)
  378.             statSize.dimensioneMinimaMessaggio = dimensione;
  379.         
  380.         // Massima
  381.         if(dimensione>statSize.dimensioneMassimaMessaggio)
  382.             statSize.dimensioneMassimaMessaggio = dimensione;
  383.         
  384.         // Media
  385.         statSize.tmp_dimensioneMediaMessaggio_sumDimensioni+=dimensione;
  386.         statSize.tmp_dimensioneMediaMessaggio_countTransazioni++;
  387.         statSize.dimensioneMediaMessaggio = statSize.tmp_dimensioneMediaMessaggio_sumDimensioni/statSize.tmp_dimensioneMediaMessaggio_countTransazioni;
  388.         // Effettuo refresh nel controllo iniziale, almeno tutti i dati sono consistenti rispetto all'intervallo temporale
  389. /**     if(statSize.tmp_dimensioneMediaMessaggio_sumDimensioni>SOGLIA_DIMENSIONE){
  390. //          // azzero temporanei
  391. //          statSize.tmp_dimensioneMediaMessaggio_sumDimensioni=statSize.dimensioneMediaMessaggio;
  392. //          statSize.tmp_dimensioneMediaMessaggio_countTransazioni=1;
  393. //      }*/
  394.     }
  395.     
  396.     
  397.     
  398.     /* BEAN */
  399.     
  400.     long dataUltimoRefresh = -1;
  401.     
  402.     StatisticCount statNumeroTransazioni = new StatisticCount();
  403.     StatisticCount statNumeroTransazioniPD = new StatisticCount();
  404.     StatisticCount statNumeroTransazioniPA = new StatisticCount();
  405.     
  406.     StatisticTime statLatenzaAttraversamento = new StatisticTime();
  407.     StatisticTime statLatenzaAttraversamentoRequest = new StatisticTime();
  408.     StatisticTime statLatenzaAttraversamentoResponse = new StatisticTime();
  409.     StatisticTime statLatenzaAttraversamentoPD = new StatisticTime();
  410.     StatisticTime statLatenzaAttraversamentoPDRequest = new StatisticTime();
  411.     StatisticTime statLatenzaAttraversamentoPDResponse = new StatisticTime();
  412.     StatisticTime statLatenzaAttraversamentoPA = new StatisticTime();
  413.     StatisticTime statLatenzaAttraversamentoPARequest = new StatisticTime();
  414.     StatisticTime statLatenzaAttraversamentoPAResponse = new StatisticTime();
  415.     
  416.     StatisticSize statDimensioneMessaggio = new StatisticSize();
  417.     StatisticSize statDimensioneMessaggioInRequest = new StatisticSize();
  418.     StatisticSize statDimensioneMessaggioOutRequest = new StatisticSize();
  419.     StatisticSize statDimensioneMessaggioInResponse = new StatisticSize();
  420.     StatisticSize statDimensioneMessaggioOutResponse = new StatisticSize();
  421.     StatisticSize statDimensioneMessaggioResponse = new StatisticSize();
  422.     StatisticSize statDimensioneMessaggioPD = new StatisticSize();
  423.     StatisticSize statDimensioneMessaggioPDInRequest = new StatisticSize();
  424.     StatisticSize statDimensioneMessaggioPDOutRequest = new StatisticSize();
  425.     StatisticSize statDimensioneMessaggioPDInResponse = new StatisticSize();
  426.     StatisticSize statDimensioneMessaggioPDOutResponse = new StatisticSize();
  427.     StatisticSize statDimensioneMessaggioPA = new StatisticSize();
  428.     StatisticSize statDimensioneMessaggioPAInRequest = new StatisticSize();
  429.     StatisticSize statDimensioneMessaggioPAOutRequest = new StatisticSize();
  430.     StatisticSize statDimensioneMessaggioPAInResponse = new StatisticSize();
  431.     StatisticSize statDimensioneMessaggioPAOutResponse = new StatisticSize();
  432.     
  433.     
  434.     public StatisticSize getStatDimensioneMessaggio() {
  435.         return this.statDimensioneMessaggio;
  436.     }

  438.     public StatisticSize getStatDimensioneMessaggioInRequest() {
  439.         return this.statDimensioneMessaggioInRequest;
  440.     }

  442.     public StatisticSize getStatDimensioneMessaggioOutRequest() {
  443.         return this.statDimensioneMessaggioOutRequest;
  444.     }

  446.     public StatisticSize getStatDimensioneMessaggioInResponse() {
  447.         return this.statDimensioneMessaggioInResponse;
  448.     }

  450.     public StatisticSize getStatDimensioneMessaggioOutResponse() {
  451.         return this.statDimensioneMessaggioOutResponse;
  452.     }

  454.     public StatisticSize getStatDimensioneMessaggioResponse() {
  455.         return this.statDimensioneMessaggioResponse;
  456.     }

  458.     public StatisticSize getStatDimensioneMessaggioPD() {
  459.         return this.statDimensioneMessaggioPD;
  460.     }

  462.     public StatisticSize getStatDimensioneMessaggioPDInRequest() {
  463.         return this.statDimensioneMessaggioPDInRequest;
  464.     }

  466.     public StatisticSize getStatDimensioneMessaggioPDOutRequest() {
  467.         return this.statDimensioneMessaggioPDOutRequest;
  468.     }

  470.     public StatisticSize getStatDimensioneMessaggioPDInResponse() {
  471.         return this.statDimensioneMessaggioPDInResponse;
  472.     }

  474.     public StatisticSize getStatDimensioneMessaggioPDOutResponse() {
  475.         return this.statDimensioneMessaggioPDOutResponse;
  476.     }

  478.     public StatisticSize getStatDimensioneMessaggioPA() {
  479.         return this.statDimensioneMessaggioPA;
  480.     }

  482.     public StatisticSize getStatDimensioneMessaggioPAInRequest() {
  483.         return this.statDimensioneMessaggioPAInRequest;
  484.     }

  486.     public StatisticSize getStatDimensioneMessaggioPAOutRequest() {
  487.         return this.statDimensioneMessaggioPAOutRequest;
  488.     }

  490.     public StatisticSize getStatDimensioneMessaggioPAInResponse() {
  491.         return this.statDimensioneMessaggioPAInResponse;
  492.     }

  494.     public StatisticSize getStatDimensioneMessaggioPAOutResponse() {
  495.         return this.statDimensioneMessaggioPAOutResponse;
  496.     }

  498.     public StatisticCount getStatNumeroTransazioni() {
  499.         return this.statNumeroTransazioni;
  500.     }

  502.     public StatisticCount getStatNumeroTransazioniPD() {
  503.         return this.statNumeroTransazioniPD;
  504.     }

  506.     public StatisticCount getStatNumeroTransazioniPA() {
  507.         return this.statNumeroTransazioniPA;
  508.     }

  510.     public StatisticTime getStatLatenzaAttraversamento() {
  511.         return this.statLatenzaAttraversamento;
  512.     }

  514.     public StatisticTime getStatLatenzaAttraversamentoRequest() {
  515.         return this.statLatenzaAttraversamentoRequest;
  516.     }

  518.     public StatisticTime getStatLatenzaAttraversamentoResponse() {
  519.         return this.statLatenzaAttraversamentoResponse;
  520.     }

  522.     public StatisticTime getStatLatenzaAttraversamentoPD() {
  523.         return this.statLatenzaAttraversamentoPD;
  524.     }

  526.     public StatisticTime getStatLatenzaAttraversamentoPDRequest() {
  527.         return this.statLatenzaAttraversamentoPDRequest;
  528.     }

  530.     public StatisticTime getStatLatenzaAttraversamentoPDResponse() {
  531.         return this.statLatenzaAttraversamentoPDResponse;
  532.     }

  534.     public StatisticTime getStatLatenzaAttraversamentoPA() {
  535.         return this.statLatenzaAttraversamentoPA;
  536.     }

  538.     public StatisticTime getStatLatenzaAttraversamentoPARequest() {
  539.         return this.statLatenzaAttraversamentoPARequest;
  540.     }

  542.     public StatisticTime getStatLatenzaAttraversamentoPAResponse() {
  543.         return this.statLatenzaAttraversamentoPAResponse;
  544.     }

  546.     public long getDataUltimoRefresh() {
  547.         return this.dataUltimoRefresh;
  548.     }
  549.     
  550. }
Created with JaCoCo 0.8.8.202204050719