agapro/ApplyTracking/EmulatorControl.h

Go to the documentation of this file.

#ifndef _EmulatorControl
#define _EmulatorControl

#include "TTask.h"
#include "TTimer.h"
#include "Rtypes.h"

#include "NarvalInterface.h"

class BaseEmulatorChain
{
private:
    // Name of the directory containing the run number
    TString RunDir;
    // Run Number
    Int_t RunNumber;
    
private:
    TString DoROOTAFPConf(Int_t which_run, const char *path, const char *which_adf_data, const char *run_pat,  Option_t *opt_adf_pattern, const char *tmp_rootafp_filename);
    
public:
        BaseEmulatorChain() : RunDir(""), RunNumber(0)
    {;}
        virtual ~BaseEmulatorChain()
    {;}
    
    TString GetRunDir() const
    {
        return RunDir;
    }
    
    Int_t GetRunNumber() const
    {
        return RunNumber;
    }
    
    virtual Bool_t Init()
    {
        return false;
    }
    virtual Bool_t Init(const Char_t *rootafp);
    virtual Bool_t Init(Int_t which_run, const char *path, const char *which_adf_data, const char *run_name_pattern, Option_t *opt_adf_pattern);
    
        virtual Bool_t Run(UInt_t /* max_loop */ = kMaxUInt)
    { return true; }
    
    virtual ADF::NarvalProducer *GetBaseProducer()
    {
        return 0x0;
    }
        virtual ADF::NarvalConsumer *GetBaseConsumer()
        {
                return 0x0;
        }
};

class EmulatorControl : public TTask 
{
private:
        BaseEmulatorChain *fEmulator;
        UInt_t fNbLoop;
    UInt_t fCurrentLoop;
        Bool_t fIsRunning;
        TTimer  *fTimer;

private:
        virtual Bool_t HandleTimer(TTimer* timer);

public:
        EmulatorControl() : 
                TTask("_EmulatorControl","0"), 
                fEmulator(0x0),
        fNbLoop(0),
        fCurrentLoop(0),
                fIsRunning(false),
        fTimer(new TTimer())
                        {;}
        EmulatorControl(BaseEmulatorChain *emulator) : 
                TTask("_EmulatorControl","0"), 
                fEmulator(emulator),
        fNbLoop(0),
        fCurrentLoop(0),
        fIsRunning(false),
        fTimer(new TTimer())
                        {;}
        virtual ~EmulatorControl()
        { 
                if ( fEmulator)
                        delete fEmulator;
    }

        void Run(UInt_t max_loop = kMaxUInt); //*MENU*
    void Destroy(); //*MENU*

    void Stop();

    TTimer *GetTimer(){return fTimer;}


        void Save(Option_t *opt = "*"); //*MENU*

        ClassDef(EmulatorControl,0)  // to start an emulator from task folder
};


#endif