core/include/SCycleController.h

Go to the documentation of this file.

// Dear emacs, this is -*- c++ -*-
// $Id: SCycleController.h 331 2012-11-20 17:12:44Z krasznaa $
/***************************************************************************
 * @Project: SFrame - ROOT-based analysis framework for ATLAS
 * @Package: Core
 *
 * @author Stefan Ask       <Stefan.Ask@cern.ch>           - Manchester
 * @author David Berge      <David.Berge@cern.ch>          - CERN
 * @author Johannes Haller  <Johannes.Haller@cern.ch>      - Hamburg
 * @author A. Krasznahorkay <Attila.Krasznahorkay@cern.ch> - CERN/Debrecen
 *
 ***************************************************************************/

#ifndef SFRAME_CORE_SCycleController_H
#define SFRAME_CORE_SCycleController_H

// STL include(s):
#include <vector>

// ROOT include(s):
#include "TString.h"

// Local include(s):
#include "SLogger.h"
#include "SError.h"

// Forward declaration(s):
class TProof;
class ISCycleBase;

class SCycleController {

public:
   SCycleController( const TString& xmlConfigFile );
   virtual ~SCycleController();

   virtual void Initialize() throw( SError );
   virtual void ExecuteAllCycles() throw( SError );
   virtual void ExecuteNextCycle() throw( SError );

   virtual void SetConfig( const TString& xmlConfigFile ) { m_xmlConfigFile = xmlConfigFile; }

   void AddAnalysisCycle( ISCycleBase* cycleAlg );

   UInt_t GetCurCycle() { return m_curCycle; }

private:
   void DeleteAllAnalysisCycles();
   void InitProof( const TString& server, const Int_t& nodes);
   void ShutDownProof();
   void WriteCycleOutput( TList* olist, const TString& filename,
                          const TString& config,
                          Bool_t update ) const;

   std::vector< ISCycleBase* > m_analysisCycles;
   std::vector< TString > m_parPackages;

   UInt_t  m_curCycle;
   Bool_t  m_isInitialized;
   TString m_xmlConfigFile;

   TProof* m_proof;

   mutable SLogger m_logger;

}; // class SCycleController

#endif // SFRAME_CORE_SCycleController_H