OnlineWatchersGLP.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"

/*
*/
void OnlineWatchersGLP(TFile *file = 0x0, TFile *file_tag = 0x0)
{
        TDirectory *Watcher_dir = gROOT, *Watcher_dir_tag = gROOT;
        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 //
        // Can scan any kind of data flow       
        WatcherClient *wADF = new WatcherClient("ADF","Watchers on any Agata Frame",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("ADF",wADF) ) {
                Snooper->Add ( wADF  );
        wADF->SetConnection("172.16.1.126", 9002);
        }
        // EB //
    // to analyse the data flow coming out from the Event Builder i.e. a Data Flow composed of event:data:psa Frames
        WatcherClient *wEventPSA = new WatcherClient("EB","Watchers to analyse data after the Event Builder",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("EB",wEventPSA) ){
                Snooper->Add ( wEventPSA );     
        wEventPSA->SetConnection("172.16.1.126", 9000);
        }
/*
        // MERGER //
        // to analyse the data flow coming out from the Merger i.e. a Data Flow composed of any combinaisons of
        //   event:data:pa      
        //   data:ranc1         
        WatcherClient *wMerger = new WatcherClient("MERGER","Watchers to analyse data @ the MERGER level",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("MERGER",wMerger) ){
                Snooper->Add ( wMerger );
                wMerger->SetConnection("10.10.1.118", 9020);
        }
*/
        // TRACKING //
        // to analyse the data flow coming out from the Event Builder i.e. a Data Flow composed of any combinaisons of
        //   event:data:pa      
        //   data:ranc1 
        //   data:tracked
        WatcherClient *wTrack = new WatcherClient("TRACKING","Watchers to analyse data after TRACKING",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("TRACKING",wTrack) ){
                Snooper->Add ( wTrack );
        wTrack->SetConnection("172.16.1.126", 9002);
        }
        
                
// add the main ADF to the list of task 
        
        // 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);


    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(); }