OnlineWatchersLLP.C

Go to the documentation of this file.

#include "TROOT.h"
#include "WatcherClient.h"
#include "TBrowser.h"
#include "TFolder.h"

using namespace ADF;
using namespace Gw;

// include there the macros that contains your own setup 
// i.e. what are the watchers you would like to execute for a given data flow.

#include "GANILSetup.C"

// protected by a namespace
namespace _OnlineWatchersLLP_ {
        
        // Crystal in there, just set empty string to remove some of them
        const Int_t gNumberOfCrystals = 15;
        //
        std::string gCrysLabel[gNumberOfCrystals] = {
                "04A",
                "04C",
                "04B",
                "03A",
                "03B",
                "03C",
                "13A",
                "13B",
                "13C",
                "",
                "",
                "",
                "",
                "",
                "",
        };
// in principle all preprocessing actors are one the same node
        std::string gBaseName = "172.16.1.1";
        std::string gMachine[gNumberOfCrystals] = {
                "01",
                "06",
                "05",
                "11",
                "08",
                "09",
                "10",
                "07",
                "12",
                "",
                "",
                "",
                "",
                "",
                "",
        };      
}

using namespace _OnlineWatchersLLP_;

// logic for AGATA local level processing : 1 X YY Z
//  X : in case processes along the chain are on the same machine 0,1,2,3 etc depending on the depth
// YY : crystal number
//  Z : ABC = 012
Int_t ComputePort(std::string &which_crys, Int_t level_in_dataflow)
{
        TString result = "", tmp = which_crys.data();

        tmp.ReplaceAll("A","0");
        tmp.ReplaceAll("B","1");
        tmp.ReplaceAll("C","2");

        result = Form("1%d%s",level_in_dataflow,tmp.Data()); 
        return result.Atoi();                
}

void OnlineWatchersLLP(TFile *file = 0x0, TFile *file_tag = 0x0, Bool_t full = false)
{               
        TDirectory *Watcher_dir = gROOT, *Watcher_dir_tag = gROOT;
//      TDirectory *Watcher_dir = 0x0, *Watcher_dir_tag = 0x0;
        
        if ( file ) 
                Watcher_dir = file;
        if ( file_tag ) 
                Watcher_dir_tag = file_tag;
        
        // main task.
        // Adding all emulators to this helps to loop in case Option is l in ExecuteTasks
        TTask *Snooper = new LoopOnTasks(Watcher_dir,Watcher_dir_tag);
        
// ADF -------------------------------------------------------------
        WatcherClient *wADF = new WatcherClient("ADF","Watchers on any Agata Frame",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("ADF",wADF) ) {
                Snooper->Add ( wADF  );
        wADF->SetConnection( Form("%s%s",gBaseName.data(),gMachine[1].data()), ComputePort(gCrysLabel[1],2) );
        }
// Crystal -------------------------------------------------------------
        // to know if a Watcher has been added to the dispatcher 
        if ( full ) {
                for (Int_t i = 0; i < gNumberOfCrystals ; i++ ) {
                        // not in the setup
                        if ( gCrysLabel[i] == "" )
                                continue;       
                        
                        WatcherClient *wCrys = new WatcherClient(Form("Crystal_%s",gCrysLabel[i].data()),
                                                        "Watchers on Crystal Frame",Watcher_dir,Watcher_dir_tag);
                        if ( SetupWatchers("CRYSTAL",wCrys,gCrysLabel[i].data()) ) {
                                wCrys->SetConnection(Form("%s%s",gBaseName.data(),gMachine[i].data()), ComputePort(gCrysLabel[i],0) );
                                Snooper->Add ( wCrys );
                        }
                        else delete wCrys;
                        Int_t p = ComputePort(gCrysLabel[i],0);
                        printf("%d \n",p);
                }
        }
        else {
                WatcherClient *wCrys = new WatcherClient("CRYSTAL","Watchers on Crystal Frame",Watcher_dir,Watcher_dir_tag);
                if ( SetupWatchers("CRYSTAL",wCrys) )
                        Snooper->Add ( wCrys );         
                else delete wCrys;
        }
// CCrystal -------------------------------------------------------------
        // to know if a Watcher has been added to the dispatcher 
        if ( full ) {
                for (Int_t i = 0; i < gNumberOfCrystals ; i++ ) {
                        
                        // not in the setup
                        if ( gCrysLabel[i] == "" )
                                continue;       
                        
                        WatcherClient *wCrys = new WatcherClient(Form("CCrystal_%s",gCrysLabel[i].data()),
                                                        "Watchers on Calibrated Crystal Frame",Watcher_dir,Watcher_dir_tag);
                        if ( SetupWatchers("CCRYSTAL",wCrys,gCrysLabel[i].data()) ) {
                                wCrys->SetConnection(Form("%s%s",gBaseName.data(),gMachine[i].data()), ComputePort(gCrysLabel[i],1) );
                                Snooper->Add ( wCrys );
                        }
                        else delete wCrys;
                }
        }
        else {
                WatcherClient *wCrys = new WatcherClient("CCRYSTAL","Watchers on Calibrated Crystal Frame",Watcher_dir,Watcher_dir_tag);
                if ( SetupWatchers("CCRYSTAL",wCrys) )
                        Snooper->Add ( wCrys );         
                else delete wCrys;
        }
// PSA -------------------------------------------------------------
        // to know if a Watcher has been added to the dispatcher 
        if ( full ) {
                for (Int_t i = 0; i < gNumberOfCrystals ; i++ ) {
                        // not in the setup
                        if ( gCrysLabel[i] == "" )
                                continue;       
                        
                        WatcherClient *wPSA = new WatcherClient(Form("PSA_%s",gCrysLabel[i].data()),
                                                        "Watchers on PSA Frame",Watcher_dir,Watcher_dir_tag);
                        if ( SetupWatchers("PSA",wPSA,gCrysLabel[i].data()) ) {
                                wPSA->SetConnection(Form("%s%s",gBaseName.data(),gMachine[i].data()), ComputePort(gCrysLabel[i],2));
                                Snooper->Add ( wPSA );
                        }
                        else delete wPSA;
                }
        }
        else {
                WatcherClient *wPSA = new WatcherClient("PSA","Watchers on PSA Frame",Watcher_dir,Watcher_dir_tag);
                if ( SetupWatchers("PSA",wPSA) )
                        Snooper->Add ( wPSA );          
                else delete wPSA;
        }
// ANCILLARY 
        /*
        WatcherClient *wAnc0 = new WatcherClient("ANC_PRO","Watchers on ancillary Data (ranc0)",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("RANC0",wAnc0) ) {
                Snooper->Add ( wAnc0 );
            wAnc0->SetConnection("10.10.1.102", 9013);          
        }
        else 
                delete wAnc0;
        */
        /*      
        WatcherClient *wAnc1 = new WatcherClient("ANC_FIL","Watchers on ancillary Data (ranc1)",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("RANC1",wAnc1) ) {
                Snooper->Add ( wAnc1 );
        wAnc1->SetConnection("172.16.1.102", 9026);             
        }
        else 
                delete wAnc1; 

        WatcherClient *wAncGSI = new WatcherClient("ANC_GSI","Watchers on ancillary Data (GSI)",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("ANC_GSI",wAncGSI) ) {
                Snooper->Add ( wAncGSI );
            wAncGSI->SetConnection( Form("%s%s",gBaseName.data(),"91"), 8000);          
        }
        else 
                delete wAncGSI;
        */
        
// add the main ADF to the list of task 
        TSRateCollector *TSCollector = new TSRateCollector("GTS_Rate","Global Timestamp rates");
        TSCollector->SetDirectory(Watcher_dir,Watcher_dir_tag);
        Snooper->Add(TSCollector);
        DoTSRateCollector(Snooper,TSCollector);
        
        gROOT->GetListOfTasks()->Add(Snooper);

/*              for (Int_t i = 0; i < gNumberOfCrystals ; i++ ) {
                        printf("%d %s %d \n",i,gCrysLabel[i].data(),ComputePort(gCrysLabel[i],0) );
                        printf("%d %s %d \n",i,gCrysLabel[i].data(),ComputePort(gCrysLabel[i],1) );
                        printf("%d %s %d \n",i,gCrysLabel[i].data(),ComputePort(gCrysLabel[i],2) );
                } */


    TBrowser *b = (TBrowser*)gROOT->GetListOfBrowsers()->Last();

    TFolder *GwWatchersFolder = (TFolder*)gROOT->GetRootFolder()->FindObject("GwWatchers");
    if(GwWatchersFolder) b->Add(GwWatchersFolder);

    TFolder *RootFilesFolder = (TFolder*)gROOT->GetRootFolder()->FindObject("ROOT Files");
    if(RootFilesFolder) b->Add(RootFilesFolder);

}

void CloseOnlineWatchers() { gROOT->GetListOfTasks()->At(0)->Delete(); }