PostOutResponseHandlerGestioneControlloTraffico.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.  */
  20. package org.openspcoop2.pdd.core.controllo_traffico.handler;

  22. import java.util.ArrayList;
  23. import java.util.List;

  25. import org.openspcoop2.core.controllo_traffico.beans.IDUnivocoGroupByPolicy;
  26. import org.openspcoop2.core.controllo_traffico.beans.MisurazioniTransazione;
  27. import org.openspcoop2.core.controllo_traffico.driver.IGestorePolicyAttive;
  28. import org.openspcoop2.core.controllo_traffico.driver.IPolicyGroupByActiveThreads;
  29. import org.openspcoop2.core.controllo_traffico.driver.PolicyNotFoundException;
  30. import org.openspcoop2.core.controllo_traffico.driver.PolicyShutdownException;
  31. import org.openspcoop2.pdd.config.OpenSPCoop2Properties;
  32. import org.openspcoop2.pdd.core.controllo_traffico.CostantiControlloTraffico;
  33. import org.openspcoop2.pdd.core.controllo_traffico.GeneratoreMessaggiErrore;
  34. import org.openspcoop2.pdd.core.controllo_traffico.GestoreControlloTraffico;
  35. import org.openspcoop2.pdd.core.controllo_traffico.policy.config.PolicyConfiguration;
  36. import org.openspcoop2.pdd.core.controllo_traffico.policy.driver.GestorePolicyAttive;
  37. import org.openspcoop2.pdd.logger.OpenSPCoop2Logger;
  38. import org.openspcoop2.pdd.logger.transazioni.InformazioniTransazione;
  39. import org.openspcoop2.pdd.logger.transazioni.TransazioniProcessTimes;
  40. import org.openspcoop2.protocol.sdk.Context;
  41. import org.openspcoop2.utils.date.DateManager;
  42. import org.slf4j.Logger;

  44. /**     
  45.  * PostOutResponseHandlerGestioneControlloTraffico
  46.  *
  47.  * @author Poli Andrea (poli@link.it)
  48.  * @author $Author$
  49.  * @version $Rev$, $Date$
  50.  */
  51. public class PostOutResponseHandlerGestioneControlloTraffico {

  53.     public void process(Boolean controlloTrafficoMaxRequestThreadRegistrato, Logger logger, String idTransazione,
  54.             MisurazioniTransazione misurazioniTransazione, InformazioniTransazione info,
  55.             TransazioniProcessTimes times){
  56.         
  57.         Context context = info.getContext();
  58.         
  59.         long timeStart = -1;
  60.         
  61.         if(controlloTrafficoMaxRequestThreadRegistrato!=null && controlloTrafficoMaxRequestThreadRegistrato){
  62.             // significa che sono entrato nel motore di anti-congestionamento
  63.             if(times!=null) {
  64.                 timeStart = DateManager.getTimeMillis();
  65.             }
  66.             try {
  67.                 
  68.                 Long maxThreads = null;
  69.                 Integer threshold = null;
  70.                 
  71.                 if(context!=null){
  72.                     Object maxThreadsObject = context.getObject(GeneratoreMessaggiErrore.PDD_CONTEXT_MAX_THREADS_THRESHOLD);
  73.                     if(maxThreadsObject instanceof Long){
  74.                         maxThreads = (Long) maxThreadsObject;
  75.                     }
  76.                     
  77.                     Object thresholdObject = context.getObject(GeneratoreMessaggiErrore.PDD_CONTEXT_CONTROLLO_TRAFFICO_THRESHOLD);
  78.                     if(thresholdObject!=null && maxThreadsObject instanceof Long){
  79.                         threshold = (Integer) thresholdObject;
  80.                     }
  81.                 }
  82.                 
  83.                 GestoreControlloTraffico.getInstance().removeThread(maxThreads,threshold,idTransazione);
  84.             } catch (Exception e) {
  85.                 logger.error("["+idTransazione+"] Errore durante la rimozione del thread all'interno della lista dei threads attivi",e);
  86.             }
  87.             if(times!=null) {
  88.                 long timeEnd =  DateManager.getTimeMillis();
  89.                 long timeProcess = timeEnd-timeStart;
  90.                 times.setControlloTrafficoRemoveThread(timeProcess);
  91.             }
  92.         }
  93.         try {
  94.             Logger logControlloTraffico = OpenSPCoop2Logger.getLoggerOpenSPCoopControlloTraffico(OpenSPCoop2Properties.getInstance().isControlloTrafficoDebug());
  95.             if(misurazioniTransazione!=null){
  96.             
  97.                 if(times!=null) {
  98.                     timeStart = DateManager.getTimeMillis();
  99.                 }
  100.                 
  101.                 Object objectId = null;
  102.                 if(context!=null) {
  103.                     objectId = context.removeObject(CostantiControlloTraffico.PDD_CONTEXT_LIST_UNIQUE_ID_POLICY);
  104.                 }
  105.                 if(context!=null &&
  106.                         objectId!=null && (objectId instanceof List<?>) ){
  107.                     @SuppressWarnings("unchecked")
  108.                     List<String> uniqueIdsPolicies = (List<String>) objectId;
  109.                     if(uniqueIdsPolicies!=null && !uniqueIdsPolicies.isEmpty()){
  110.                         Object object = context.removeObject(CostantiControlloTraffico.PDD_CONTEXT_LIST_GROUP_BY_CONDITION);
  111.                         Object objectIncrementCounterPolicyApplicabile = context.removeObject(CostantiControlloTraffico.PDD_CONTEXT_LIST_POLICY_APPLICABILE);
  112.                         Object objectIncrementCounterPolicyViolata = context.removeObject(CostantiControlloTraffico.PDD_CONTEXT_LIST_POLICY_VIOLATA);
  113.                         Object objectPolicyTypes = context.removeObject(CostantiControlloTraffico.PDD_CONTEXT_LIST_API_OR_GLOBAL_OR_DEFAULT);
  114.                         Object objectPolicyConfigurationPorta = context.removeObject(CostantiControlloTraffico.PDD_CONTEXT_POLICY_CONFIG_PORTA);
  115.                         Object objectPolicyConfigurationGlobale = context.removeObject(CostantiControlloTraffico.PDD_CONTEXT_POLICY_CONFIG_GLOBALE);
  116.                         if((object instanceof List<?>) &&
  117.                                 objectIncrementCounterPolicyApplicabile!=null && (objectIncrementCounterPolicyApplicabile instanceof List<?>) &&
  118.                                 objectIncrementCounterPolicyViolata!=null && (objectIncrementCounterPolicyViolata instanceof List<?>) &&
  119.                                 objectPolicyTypes!=null && (objectPolicyTypes instanceof List<?>) &&
  120.                                 objectPolicyConfigurationGlobale!=null && (objectPolicyConfigurationGlobale instanceof PolicyConfiguration) &&
  121.                                 objectPolicyConfigurationPorta!=null && (objectPolicyConfigurationPorta instanceof PolicyConfiguration)){
  122.                             @SuppressWarnings("unchecked")
  123.                             List<IDUnivocoGroupByPolicy> groupByPolicies = (List<IDUnivocoGroupByPolicy>) object; 
  124.                             @SuppressWarnings("unchecked")
  125.                             List<Boolean> incrementCounterPolicyApplicabile = (List<Boolean>) objectIncrementCounterPolicyApplicabile; 
  126.                             @SuppressWarnings("unchecked")
  127.                             List<Boolean> incrementCounterPolicyViolata = (List<Boolean>) objectIncrementCounterPolicyViolata; 
  128.                             @SuppressWarnings("unchecked")
  129.                             List<String> policyTypes = (List<String>) objectPolicyTypes; 
  130.                             PolicyConfiguration policyConfigurationGlobale = (PolicyConfiguration) objectPolicyConfigurationGlobale;
  131.                             PolicyConfiguration policyConfigurationPorta = (PolicyConfiguration) objectPolicyConfigurationPorta;
  132.                             if(groupByPolicies!=null && groupByPolicies.size()==uniqueIdsPolicies.size() &&
  133.                                     incrementCounterPolicyApplicabile!=null && incrementCounterPolicyApplicabile.size()==uniqueIdsPolicies.size() &&
  134.                                     incrementCounterPolicyViolata!=null && incrementCounterPolicyViolata.size()==uniqueIdsPolicies.size() &&
  135.                                     policyTypes!=null && policyTypes.size()==uniqueIdsPolicies.size() &&
  136.                                     policyConfigurationGlobale!=null &&
  137.                                     policyConfigurationPorta!=null) {
  138.                                                                 
  139.                                 if(times!=null) {
  140.                                     long timeEnd =  DateManager.getTimeMillis();
  141.                                     long timeProcess = timeEnd-timeStart;
  142.                                     times.setControlloTrafficoPreparePolicy(timeProcess);
  143.                                 
  144.                                     if(!uniqueIdsPolicies.isEmpty()) {
  145.                                         times.setControlloTrafficoPolicyTimes(new ArrayList<>());
  146.                                     }
  147.                                 }
  148.                                 
  149.                                 for (int i = 0; i < uniqueIdsPolicies.size(); i++) {
  150.                                     String uniqueIdMap = null;
  151.                                     try{
  152.                                         uniqueIdMap = uniqueIdsPolicies.get(i);
  153.                                         
  154.                                         StringBuilder sb = null;
  155.                                         if(times!=null) {
  156.                                             timeStart = DateManager.getTimeMillis();
  157.                                         }
  158.                                         
  159.                                         String policyAPI = policyTypes.get(i);
  160.                                         PolicyConfiguration policyConfiguration = null;
  161.                                         if(CostantiControlloTraffico.PDD_CONTEXT_LIST_API_OR_GLOBAL_OR_DEFAULT_VALUE_API.equals(policyAPI)) {
  162.                                             policyConfiguration = policyConfigurationPorta;
  163.                                         }
  164.                                         else if(CostantiControlloTraffico.PDD_CONTEXT_LIST_API_OR_GLOBAL_OR_DEFAULT_VALUE_GLOBAL.equals(policyAPI)) {
  165.                                             policyConfiguration = policyConfigurationGlobale;
  166.                                         }
  167.                                         else {
  168.                                             /**CostantiControlloTraffico.PDD_CONTEXT_LIST_API_OR_GLOBAL_OR_DEFAULT_VALUE_DEFAULT;*/
  169.                                             policyConfiguration = new PolicyConfiguration(true);
  170.                                         } 
  171.                                         IGestorePolicyAttive gestorePolicy = GestorePolicyAttive.getInstance(policyConfiguration.getType());
  172.                                         
  173.                                         IPolicyGroupByActiveThreads policyGroupByActiveThreads = gestorePolicy.getActiveThreadsPolicy(uniqueIdMap);
  174.                                         
  175.                                         if(times!=null) {
  176.                                             sb = new StringBuilder(uniqueIdMap);
  177.                                             sb.append("[");
  178.                                             long timeEnd =  DateManager.getTimeMillis();
  179.                                             long timeProcess = timeEnd-timeStart;
  180.                                             sb.append(timeProcess);
  181.                                             timeStart = DateManager.getTimeMillis();
  182.                                         }
  183.                                         
  184.                                         org.openspcoop2.utils.Map<Object> mapContext = null;
  185.                                         if(context!=null) {
  186.                                             mapContext = context;
  187.                                         }
  188.                                         
  189.                                         policyGroupByActiveThreads.
  190.                                             registerStopRequest(logControlloTraffico, idTransazione, groupByPolicies.get(i),mapContext, 
  191.                                                     misurazioniTransazione, 
  192.                                                     incrementCounterPolicyApplicabile.get(i),
  193.                                                     incrementCounterPolicyViolata.get(i));
  194.                                         
  195.                                         if(times!=null) {
  196.                                             sb.append(",");
  197.                                             long timeEnd =  DateManager.getTimeMillis();
  198.                                             long timeProcess = timeEnd-timeStart;
  199.                                             sb.append(timeProcess);
  200.                                             sb.append("]");
  201.                                             times.getControlloTrafficoPolicyTimes().add(sb.toString());
  202.                                         }
  203.                                         
  204.                                     }catch(PolicyNotFoundException notFound){
  205.                                         logControlloTraffico.debug("NotFoundException durante la registrazione di terminazione del thread (policy inspection: "+uniqueIdMap+")",notFound);
  206.                                     }catch(PolicyShutdownException shutdown){
  207.                                         logControlloTraffico.debug("PolicyShutdownException durante la registrazione di terminazione del thread (policy inspection: "+uniqueIdMap+")",shutdown);
  208.                                     }   
  209.                                     catch(Throwable error){
  210.                                         logControlloTraffico.error("Errore durante la registrazione di terminazione del thread (policy inspection: "+uniqueIdMap+"): "+error.getMessage(),error);
  211.                                     }   
  212.                                 }
  213.                             }                                   

  215.                         }
  216.                     }
  217.                 }
  218.                 
  219.             }
  220.         } catch (Exception e) {
  221.             logger.error("["+idTransazione+"] Errore durante la registrazione di terminazione del thread (policy inspection)",e);
  222.         }
  223.     }
  224.     
  225. }
Created with JaCoCo 0.8.8.202204050719