GestorePdDInitThread.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.  */


  22. package org.openspcoop2.web.ctrlstat.gestori;

  24. import java.sql.Connection;
  25. import java.util.HashMap;
  26. import java.util.List;
  27. import java.util.Map;

  29. import org.openspcoop2.core.registry.constants.PddTipologia;
  30. import org.openspcoop2.pdd.config.OpenSPCoop2ConfigurationException;
  31. import org.openspcoop2.utils.Utilities;
  32. import org.openspcoop2.web.ctrlstat.config.ConsoleProperties;
  33. import org.openspcoop2.web.ctrlstat.core.ControlStationLogger;
  34. import org.openspcoop2.web.ctrlstat.core.DBManager;
  35. import org.openspcoop2.web.ctrlstat.dao.PdDControlStation;
  36. import org.openspcoop2.web.ctrlstat.driver.DriverControlStationNotFound;
  37. import org.openspcoop2.web.ctrlstat.servlet.pdd.PddCore;
  38. import org.slf4j.Logger;

  40. /**
  41.  * GestorePdDInitThread
  42.  * 
  43.  * @author Andrea Poli (apoli@link.it)
  44.  * @author Stefano Corallo (corallo@link.it)
  45.  * @author Sandra Giangrandi (sandra@link.it)
  46.  * @author $Author$
  47.  * @version $Rev$, $Date$
  48.  * 
  49.  */
  50. public class GestorePdDInitThread extends Thread {

  52.     private ConsoleProperties consoleProperties;
  53.     
  54.     /** Logger utilizzato per debug. */
  55.     private static Logger log = null;
  56.     /** run */
  57.     // public static boolean stop = false;
  58.     private static Map<String, IGestore> gestoriPdd = new HashMap<String, IGestore>();

  60.     private boolean singlePdD = false;
  61.     private boolean enginePDD = false;
  62.     
  63.     /** Costruttore 
  64.      * @throws OpenSPCoop2ConfigurationException */
  65.     public GestorePdDInitThread() throws OpenSPCoop2ConfigurationException {
  66.         
  67.         GestorePdDInitThread.log = ControlStationLogger.getGestorePddLogger();

  69.         this.consoleProperties = ConsoleProperties.getInstance();
  70.         
  71.         // start();
  72.     }

  74.     /**
  75.      * Metodo che fa partire il Thread.
  76.      * 
  77.      */
  78.     @Override
  79.     public void run() {

  81.         try {
  82.             this.initGestore();

  84.             if (this.singlePdD) {
  85.                 log.warn("GestorePdDInitThread non avviato: govwayConsole avviata in singlePdD mode.");
  86.                 return;
  87.             }

  89.         } catch (GestoreNonAttivoException e) {
  90.             log.warn("Inizializzazione GestorePdDInitThread non effettuata : " + e.getMessage());
  91.             return;
  92.         } catch (Exception e) {
  93.             log.error("Inizializzazione Gestore PdD Init Thread Fallita : " + e.getMessage(), e);
  94.             return;
  95.         }
  96.         
  97.         try {

  99.             // Controllo se dbmanager inizializzato
  100.             // Il DBManager viene inizializzato nell'InitListener
  101.             if (!DBManager.isInitialized()) {
  102.                 GestorePdDInitThread.log.info("Inizializzazione di " + this.getClass().getSimpleName() + " non riuscito perche' DBManager non INIZIALIZZATO");
  103.                 GestorePdDInitThread.log.info("Gestore Pdd non avviato!");
  104.                 return;
  105.             }

  107.             DBManager dbm = DBManager.getInstance();
  108.             Connection con = dbm.getConnection();

  110.             PddCore core = new PddCore();
  111.             if(core.isSinglePdD()==false){
  112.                 List<String> pddList = core.getAllIdPorteDominio(null);
  113.                 if(pddList!=null && pddList.size()>0)
  114.                     GestorePdDInitThread.log.info("Trovate "+pddList.size()+" pdd su cui avviare il thread di gestione");
  115.                 else
  116.                     GestorePdDInitThread.log.info("Non sono state trovate pdd da gestire");
  117.                 if(pddList!=null) {
  118.                     for (int i = 0; i < pddList.size(); i++) {
  119.                         PdDControlStation pdd = null;
  120.                         try{
  121.                             pdd = core.getPdDControlStation(pddList.get(i));
  122.                         }catch(DriverControlStationNotFound dNot){
  123.                             GestorePdDInitThread.log.error("Errore durante la lettura dei dati della pdd ["+pddList.get(i)+"]: "+dNot.getMessage());
  124.                         }
  125.                         if(pdd!=null) {
  126.                             addGestore(pdd);
  127.                         }
  128.                     }
  129.                 }
  130.             }

  132.             // Chiudo la connessione al DB
  133.             dbm.releaseConnection(con);
  134.         } catch (org.openspcoop2.web.ctrlstat.core.ControlStationCoreException csce) {
  135.             GestorePdDInitThread.log.error("ControlStationCoreException: " + csce.getMessage());
  136.         } catch (org.openspcoop2.web.ctrlstat.driver.DriverControlStationException dcse) {
  137.             GestorePdDInitThread.log.error("DriverControlStationException: " + dcse.getMessage());
  138.         } catch (Exception dcse) {
  139.             GestorePdDInitThread.log.error("DriverControlStationException: " + dcse.getMessage());
  140.         }
  141.     }

  143.     /**
  144.      * Aggiunge una porta di dominio alla lista di porte di dominio e avvia il
  145.      * thread di gestione della PdD
  146.      * 
  147.      * @param nomeCoda
  148.      * @throws OpenSPCoop2ConfigurationException 
  149.      */
  150.     public static void startPdD(String nomeCoda) throws OpenSPCoop2ConfigurationException {
  151.         GestorePdDThread pdd = new GestorePdDThread(nomeCoda);
  152.         GestorePdDInitThread.gestoriPdd.put(nomeCoda,pdd);
  153.         new Thread(pdd).start();
  154.     }

  156.     public void stopGestore() {
  157.         // Stoppo tutti i thread gestori delle pdd
  158.         if(gestoriPdd!=null && !gestoriPdd.isEmpty()) {
  159.             for (String pdd : gestoriPdd.keySet()) {
  160.                 deleteGestore(pdd);
  161.             }
  162.         }

  164.     }

  166.     
  167.     public void initGestore() throws Exception {

  169.         this.enginePDD = this.consoleProperties.isGestioneCentralizzataSincronizzazionePdd();
  170.         this.singlePdD = this.consoleProperties.isSinglePdD();

  172.         if (this.enginePDD == false) {
  173.             //this.log.info("Motore di sincronizzazione verso le Porte di Dominio non attivo.");
  174.             throw new GestoreNonAttivoException("Motore di sincronizzazione verso le Porte di Dominio non attivo.");
  175.         }

  177.     }
  178.     
  179.     
  180.     public static void addGestore(PdDControlStation pdd) throws Exception {
  181.         if(gestoriPdd.containsKey(pdd.getNome())==false){
  182.             try{
  183.                 String tipoPdd = pdd.getTipo();
  184.                 if (tipoPdd != null && PddTipologia.OPERATIVO.toString().equals(tipoPdd)) {
  185.                     GestorePdDInitThread.log.info("Avvio thread di gestione per la porta di dominio ["+pdd.getNome()+"] ...");
  186.                     String nomeCoda = pdd.getNome();
  187.                     GestorePdDInitThread.startPdD(nomeCoda);
  188.                     GestorePdDInitThread.log.info("Avviato thread di gestione per la porta di dominio ["+pdd.getNome()+"]");
  189.                 }else{
  190.                     GestorePdDInitThread.log.info("Thread di gestione per la porta di dominio ["+pdd.getNome()+"] non avviato poiche' la porta di dominio non possiede tipo "+PddTipologia.OPERATIVO.toString()+" (tipo:"+pdd.getTipo()+")");
  191.                 }
  192.             }catch(Exception e){
  193.                 GestorePdDInitThread.log.error("Thread di gestione per la porta di dominio ["+pdd.getNome()+"] non avviato: "+e.getMessage());
  194.             }
  195.         }
  196.         else{
  197.             GestorePdDInitThread.log.debug("Thread di gestione per la porta di dominio ["+pdd.getNome()+"] gia' in esecuzione");
  198.         }
  199.     }
  200.     
  201.     public static void deleteGestore(String pdd)  {
  202.         if(gestoriPdd.containsKey(pdd)==false){
  203.             GestorePdDInitThread.log.debug("Thread di gestione per la porta di dominio ["+pdd+"] non risulta in esecuzione");
  204.         }
  205.         else{
  206.             GestorePdDInitThread.log.debug("Fermo il thread di gestione per la porta di dominio ["+pdd+"] ...");
  207.             GestorePdDThread gestore = (GestorePdDThread) gestoriPdd.get(pdd);
  208.             gestore.stopGestore();
  209.             int timeout = 60;
  210.             for (int i = 0; i < timeout; i++) {
  211.                 if(gestore.isRunning()){
  212.                     Utilities.sleep(1000);
  213.                 }
  214.                 else{
  215.                     break;
  216.                 }
  217.             }
  218.             GestorePdDInitThread.log.debug("Thread di gestione per la porta di dominio ["+pdd+"] terminato");
  219.             gestoriPdd.remove(pdd);
  220.         }
  221.     }
  222. }
Created with JaCoCo 0.8.8.202204050719