TimerFSRecoveryThread.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.monitor.engine.fs_recovery;

  22. import org.openspcoop2.core.commons.dao.DAOFactory;
  23. import org.openspcoop2.core.commons.dao.DAOFactoryProperties;
  24. import org.openspcoop2.monitor.engine.exceptions.EngineException;
  25. import org.openspcoop2.monitor.engine.config.MonitorProperties;
  26. import org.openspcoop2.monitor.engine.constants.CostantiConfigurazione;

  28. import java.sql.Connection;
  29. import java.sql.DriverManager;
  30. import java.util.ArrayList;
  31. import java.util.List;
  32. import java.util.Properties;

  34. import javax.sql.DataSource;

  36. import org.openspcoop2.core.config.OpenspcoopAppender;
  37. import org.openspcoop2.core.config.Property;
  38. import org.openspcoop2.core.config.utils.OpenSPCoopAppenderUtilities;
  39. import org.openspcoop2.generic_project.utils.ServiceManagerProperties;
  40. import org.openspcoop2.protocol.engine.BasicProtocolFactory;
  41. import org.openspcoop2.protocol.engine.ProtocolFactoryManager;
  42. import org.openspcoop2.protocol.engine.constants.Costanti;
  43. import org.openspcoop2.protocol.sdk.ConfigurazionePdD;
  44. import org.openspcoop2.protocol.sdk.diagnostica.IDiagnosticProducer;
  45. import org.openspcoop2.protocol.sdk.dump.IDumpProducer;
  46. import org.openspcoop2.protocol.sdk.tracciamento.ITracciaProducer;
  47. import org.openspcoop2.utils.Utilities;
  48. import org.openspcoop2.utils.resources.GestoreJNDI;
  49. import org.openspcoop2.utils.resources.Loader;

  51. /**
  52.  * TimerFSRecoveryThread
  53.  *
  54.  * @author Poli Andrea (apoli@link.it)
  55.  * @author $Author$
  56.  * @version $Rev$, $Date$
  57.  */
  58. public class TimerFSRecoveryThread extends Thread{

  60.     /**
  61.      * Timeout che definisce la cadenza di avvio di questo timer. 
  62.      */
  63.     private long timeout = 10; // ogni 10 secondi avvio il Thread
  64.     

  66.     /** Configurazione */
  67.     private FSRecoveryConfig fsRepositoryConfig;
  68.     
  69.     /** DataSource */
  70.     private DataSource ds;
  71.     private String dsJndiName;
  72.     
  73.     /** Connection */
  74.     private Connection connection;
  75.     private String connectionUrl = null;
  76.     private String connectionDriver = null;
  77.     private String connectionUsername = null;
  78.     private String connectionPassword = null;
  79.     
  80.     /** DAOFactory */
  81.     private DAOFactory daoFactory;
  82.     private ServiceManagerProperties daoFactoryServiceManagerPropertiesTransazioni = null;
  83.     private org.openspcoop2.core.transazioni.dao.IServiceManager transazioniSM = null;
  84.     private org.openspcoop2.core.eventi.dao.IServiceManager pluginsEventiSM = null;
  85.     
  86.     /** OpenSPCoopAppender */
  87.     private ITracciaProducer tracciamentoAppender;
  88.     private IDiagnosticProducer diagnosticoAppender;
  89.     private IDumpProducer dumpAppender;
  90.     private boolean transazioniRegistrazioneDumpHeadersCompactEnabled;
  91.     
  92.     // VARIABILE PER STOP
  93.     private boolean stop = false;
  94.     
  95.     public boolean isStop() {
  96.         return this.stop;
  97.     }

  99.     public void setStop(boolean stop) {
  100.         this.stop = stop;
  101.     }
  102.     
  103.     
  104.     /** Costruttore Datasource */
  105.     public TimerFSRecoveryThread(DataSource ds, 
  106.             ITracciaProducer tracciamentoAppender,
  107.             IDiagnosticProducer diagnosticoAppender, 
  108.             IDumpProducer dumpAppender, boolean transazioniRegistrazioneDumpHeadersCompactEnabled,
  109.             FSRecoveryConfig fsRepositoryConfig) throws EngineException{
  110.         this(fsRepositoryConfig);
  111.         this.ds = ds;
  112.         this.tracciamentoAppender = tracciamentoAppender;
  113.         this.diagnosticoAppender = diagnosticoAppender;
  114.         this.dumpAppender = dumpAppender;
  115.         this.transazioniRegistrazioneDumpHeadersCompactEnabled = transazioniRegistrazioneDumpHeadersCompactEnabled;
  116.     }
  117.     public TimerFSRecoveryThread(String ds,Properties dsContext, FSRecoveryConfig fsRepositoryConfig) throws EngineException{
  118.         this(fsRepositoryConfig);
  119.         GestoreJNDI jndi = new GestoreJNDI(dsContext);
  120.         try{
  121.             this.dsJndiName = ds;
  122.             this.ds = (DataSource) jndi.lookup(ds);
  123.         }catch(Exception e){
  124.             throw new EngineException(e.getMessage(),e);
  125.         }
  126.     }
  127.     
  128.     /** Costruttore Connection */
  129.     public TimerFSRecoveryThread(Connection connection, 
  130.             ITracciaProducer tracciamentoAppender,
  131.             IDiagnosticProducer diagnosticoAppender,
  132.             IDumpProducer dumpAppender, boolean transazioniRegistrazioneDumpHeadersCompactEnabled,
  133.             OpenspcoopAppender appenderProperties, FSRecoveryConfig fsRepositoryConfig) throws EngineException{
  134.         this(fsRepositoryConfig);
  135.         this.connection = connection;
  136.         this.tracciamentoAppender = tracciamentoAppender;
  137.         this.diagnosticoAppender = diagnosticoAppender;
  138.         this.dumpAppender = dumpAppender;
  139.         this.transazioniRegistrazioneDumpHeadersCompactEnabled = transazioniRegistrazioneDumpHeadersCompactEnabled;
  140.     }
  141.     public TimerFSRecoveryThread(String connectionUrl,String driverJDBC,String username, String password, FSRecoveryConfig fsRepositoryConfig) throws EngineException{
  142.         this(fsRepositoryConfig);
  143.         try{
  144.             this.connectionUrl = connectionUrl;
  145.             this.connectionDriver = driverJDBC;
  146.             this.connectionUsername = username;
  147.             this.connectionPassword = password;
  148.             Class.forName(driverJDBC);
  149.             this.connection = DriverManager.getConnection(connectionUrl,username,password);
  150.         }catch(Exception e){
  151.             throw new EngineException(e.getMessage(),e);
  152.         }
  153.     }
  154.     
  155.     /** Costruttore */
  156.     public TimerFSRecoveryThread(FSRecoveryConfig fsRepositoryConfig) throws EngineException{
  157.     
  158.         try{
  159.         
  160.             MonitorProperties props = MonitorProperties.getInstance(fsRepositoryConfig.getLogCore());

  162.             try {
  163.                 this.timeout = Integer.parseInt(props.getProperty(CostantiConfigurazione.FS_RECOVERY_TIMEOUT, "10", true));
  164.             } catch (NumberFormatException e) {
  165.                 this.timeout=10;
  166.             }
  167.             
  168.             this.fsRepositoryConfig = fsRepositoryConfig;
  169.             
  170.             this.daoFactory = DAOFactory.getInstance(this.fsRepositoryConfig.getLogSql());
  171.             this.daoFactoryServiceManagerPropertiesTransazioni = DAOFactoryProperties.getInstance(this.fsRepositoryConfig.getLogSql()).getServiceManagerProperties(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  172.             
  173.         }catch(Exception e){
  174.             throw new EngineException(e.getMessage(),e);
  175.         }
  176.     }
  177.     
  178.     /**
  179.      * Metodo che fa partire il Thread. 
  180.      *
  181.      */
  182.     @Override
  183.     public void run(){
  184.             
  185.         initResources();
  186.         
  187.         while(this.stop == false){
  188.             
  189.             FSRecoveryLibrary.generate(this.fsRepositoryConfig, 
  190.                     this.daoFactory, this.fsRepositoryConfig.getLogSql(), this.daoFactoryServiceManagerPropertiesTransazioni,
  191.                     Costanti.GESTIONE_SERIALIZABLE_ATTESA_ATTIVA, Costanti.GESTIONE_SERIALIZABLE_CHECK_INTERVAL,
  192.                     this.transazioniSM, 
  193.                     this.tracciamentoAppender, this.diagnosticoAppender, 
  194.                     this.dumpAppender, this.transazioniRegistrazioneDumpHeadersCompactEnabled,
  195.                     this.pluginsEventiSM);
  196.                             
  197.             // CheckInterval
  198.             if(this.stop==false){
  199.                 int i=0;
  200.                 while(i<this.timeout){
  201.                     Utilities.sleep(1000);      
  202.                     if(this.stop){
  203.                         break; // thread terminato, non lo devo far piu' dormire
  204.                     }
  205.                     i++;
  206.                 }
  207.             }
  208.         } 
  209.         
  210.         this.fsRepositoryConfig.getLogCore().info("Thread per il recovery da file system terminato");

  212.     }
  213.     
  214.     private void initResources(){
  215.         
  216.         if(this.fsRepositoryConfig.isRipristinoTransazioni()){
  217.             try{
  218.                 
  219.                 if(this.ds!=null){
  220.                     this.transazioniSM = (org.openspcoop2.core.transazioni.dao.IServiceManager) this.daoFactory.getServiceManager(
  221.                             org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance(),
  222.                             this.ds);
  223.                 }
  224.                 else if(this.connection!=null){
  225.                     this.transazioniSM = (org.openspcoop2.core.transazioni.dao.IServiceManager) this.daoFactory.getServiceManager(
  226.                             org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance(),
  227.                             this.connection);
  228.                 }
  229.                 else{
  230.                     this.transazioniSM = (org.openspcoop2.core.transazioni.dao.IServiceManager) this.daoFactory.getServiceManager(
  231.                             org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  232.                 }
  233.                 
  234.             }catch(Exception e){
  235.                 this.fsRepositoryConfig.getLogCore().error("Errore durante l'inizializzazione del Service Manager per le transazioni: "+e.getMessage(),e);
  236.             } 
  237.         }
  238.         
  239.         if(this.fsRepositoryConfig.isRipristinoEventi()){
  240.             try{
  241.                 
  242.                 if(this.ds!=null){
  243.                     this.pluginsEventiSM = (org.openspcoop2.core.eventi.dao.IServiceManager) this.daoFactory.getServiceManager(
  244.                             org.openspcoop2.core.eventi.utils.ProjectInfo.getInstance(),
  245.                             this.ds);
  246.                 }
  247.                 else if(this.connection!=null){
  248.                     this.pluginsEventiSM = (org.openspcoop2.core.eventi.dao.IServiceManager) this.daoFactory.getServiceManager(
  249.                             org.openspcoop2.core.eventi.utils.ProjectInfo.getInstance(),
  250.                             this.connection);
  251.                 }
  252.                 else{
  253.                     this.pluginsEventiSM = (org.openspcoop2.core.eventi.dao.IServiceManager) this.daoFactory.getServiceManager(
  254.                             org.openspcoop2.core.eventi.utils.ProjectInfo.getInstance());
  255.                 }
  256.                 
  257.             }catch(Exception e){
  258.                 this.fsRepositoryConfig.getLogCore().error("Errore durante l'inizializzazione del Service Manager per i plugins eventi: "+e.getMessage(),e);
  259.             } 
  260.         }
  261.         
  262.         if(this.fsRepositoryConfig.isRipristinoTransazioni() && 
  263.                 (this.tracciamentoAppender==null || this.diagnosticoAppender==null)){
  264.         
  265.             try{
  266.             
  267.                 ConfigurazionePdD configPdD = new ConfigurazionePdD();
  268.                 configPdD.setAttesaAttivaJDBC(-1);
  269.                 configPdD.setCheckIntervalJDBC(-1);
  270.                 configPdD.setLoader(new Loader(this.getClass().getClassLoader()));
  271.                 configPdD.setLog(this.fsRepositoryConfig.getLogCore());
  272.                 ProtocolFactoryManager.initialize(this.fsRepositoryConfig.getLogCore(), configPdD, this.fsRepositoryConfig.getDefaultProtocol());
  273.                 
  274.             }catch(Exception e){
  275.                 this.fsRepositoryConfig.getLogCore().error("Errore durante l'inizializzazione del ProtocolFactoryManager: "+e.getMessage(),e);
  276.             } 
  277.         
  278.         }
  279.             
  280.         if(this.fsRepositoryConfig.isRipristinoTransazioni() && this.tracciamentoAppender==null){
  281.             
  282.             try{
  283.             
  284.                 // Init
  285.                 this.tracciamentoAppender = new BasicProtocolFactory(this.fsRepositoryConfig.getLogCore()).createTracciaProducer();
  286.                 OpenspcoopAppender tracciamentoOpenSPCoopAppender = new OpenspcoopAppender();
  287.                 tracciamentoOpenSPCoopAppender.setTipo("__threadLibraryFileSystemRecovery");
  288.                 List<Property> tracciamentoOpenSPCoopAppenderProperties = new ArrayList<Property>();

  290.                 this.addParameters(tracciamentoOpenSPCoopAppenderProperties);

  292.                 tracciamentoOpenSPCoopAppender.setPropertyList(tracciamentoOpenSPCoopAppenderProperties);
  293.                 this.tracciamentoAppender.initializeAppender(tracciamentoOpenSPCoopAppender);
  294.                 this.tracciamentoAppender.isAlive();
  295.                 
  296.             }catch(Exception e){
  297.                 this.fsRepositoryConfig.getLogCore().error("Errore durante l'inizializzazione del TracciamentoAppender: "+e.getMessage(),e);
  298.             } 
  299.         }
  300.         
  301.         if(this.fsRepositoryConfig.isRipristinoTransazioni() && this.diagnosticoAppender==null){
  302.             
  303.             try{
  304.                             
  305.                 // Init
  306.                 this.diagnosticoAppender = new BasicProtocolFactory(this.fsRepositoryConfig.getLogCore()).createDiagnosticProducer();
  307.                 OpenspcoopAppender diagnosticoOpenSPCoopAppender = new OpenspcoopAppender();
  308.                 diagnosticoOpenSPCoopAppender.setTipo("__threadLibraryFileSystemRecovery");
  309.                 List<Property> diagnosticoOpenSPCoopAppenderProperties = new ArrayList<Property>();

  311.                 this.addParameters(diagnosticoOpenSPCoopAppenderProperties);

  313.                 diagnosticoOpenSPCoopAppender.setPropertyList(diagnosticoOpenSPCoopAppenderProperties);
  314.                 this.diagnosticoAppender.initializeAppender(diagnosticoOpenSPCoopAppender);
  315.                 this.diagnosticoAppender.isAlive();
  316.                 
  317.             }catch(Exception e){
  318.                 this.fsRepositoryConfig.getLogCore().error("Errore durante l'inizializzazione del DiagnosticoAppender: "+e.getMessage(),e);
  319.             } 
  320.         }
  321.         
  322.         if(this.fsRepositoryConfig.isRipristinoTransazioni() && this.dumpAppender==null){
  323.             
  324.             try{
  325.                             
  326.                 // Init
  327.                 this.dumpAppender = new BasicProtocolFactory(this.fsRepositoryConfig.getLogCore()).createDumpProducer();
  328.                 OpenspcoopAppender dumpOpenSPCoopAppender = new OpenspcoopAppender();
  329.                 dumpOpenSPCoopAppender.setTipo("__threadLibraryFileSystemRecovery");
  330.                 List<Property> dumpOpenSPCoopAppenderProperties = new ArrayList<Property>();

  332.                 this.addParameters(dumpOpenSPCoopAppenderProperties);

  334.                 dumpOpenSPCoopAppender.setPropertyList(dumpOpenSPCoopAppenderProperties);
  335.                 this.diagnosticoAppender.initializeAppender(dumpOpenSPCoopAppender);
  336.                 this.diagnosticoAppender.isAlive();
  337.                 
  338.             }catch(Exception e){
  339.                 this.fsRepositoryConfig.getLogCore().error("Errore durante l'inizializzazione del DiagnosticoAppender: "+e.getMessage(),e);
  340.             } 
  341.         }
  342.     }
  343.     
  344.     private void addParameters(List<Property> appenderProperties) throws Exception{
  345.         DAOFactoryProperties daoFactoryProperties = DAOFactoryProperties.getInstance(this.fsRepositoryConfig.getLogSql());
  346.         String tipoDatabase = daoFactoryProperties.getTipoDatabase(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  347.         
  348.         String dsJndiName = null;
  349.         String connectionUrl = null;
  350.         String connectionDriver = null;
  351.         String connectionUsername = null;
  352.         String connectionPassword = null;
  353.         if(this.dsJndiName!=null){
  354.             dsJndiName = this.dsJndiName;
  355.         }
  356.         else if(this.connectionUrl!=null){
  357.             connectionUrl = this.connectionUrl;
  358.             connectionDriver = this.connectionDriver;
  359.             connectionUsername = this.connectionUsername;
  360.             connectionPassword = this.connectionPassword;
  361.         }
  362.         else{
  363.             if(daoFactoryProperties.isTipoAccessoTramiteDatasource(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance())){
  364.                 dsJndiName = daoFactoryProperties.getDatasourceJNDIName(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  365.             }
  366.             else{
  367.                 connectionUrl = daoFactoryProperties.getConnectionUrl(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  368.                 connectionDriver = daoFactoryProperties.getConnectionDriverJDBC(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  369.                 connectionUsername = daoFactoryProperties.getConnectionAuthUsername(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  370.                 connectionPassword = daoFactoryProperties.getConnectionAuthPassword(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  371.             }
  372.         }
  373.         
  374.         boolean debug = daoFactoryProperties.isShowSql(org.openspcoop2.core.transazioni.utils.ProjectInfo.getInstance());
  375.         
  376.         OpenSPCoopAppenderUtilities.addParameters(this.fsRepositoryConfig.getLogCore(), appenderProperties, 
  377.                 dsJndiName, 
  378.                 connectionUrl, connectionDriver, connectionUsername, connectionPassword, 
  379.                 tipoDatabase,
  380.                 true, debug);
  381.         
  382.     }
  383. }
Created with JaCoCo 0.8.8.202204050719