GANIL/OnlineWatchersGLP.C

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (c) IPNL, IN2P3, CNRS                                       *
 *   Contibutor(s) :                                                       *
 *      Olivier Stezowski stezow(AT)ipnl.in2p3.fr [2014]                   *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/

#include "TROOT.h"
#include "TBrowser.h"
#include "WatcherClient.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 "WatchersConfig.h"
#include "SetupWatchers.C"

/*
*/
void OnlineWatchersGLP(TFile *file = 0x0, TFile *file_tag = 0x0, Bool_t start_loop = false)
{
        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);
    if ( start_loop ) {
        LoopControl *control = (LoopControl *)Snooper->GetListOfTasks()->FindObject("LoopControl");
        if ( control ) {
            control->SetAutoTime(3600); // save every hours
        }
    }
    
        // 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.125", 9021);
//      }
        // EB //
        // to analyse the data flow coming out from the Event Builder i.e. a Data Flow composed of event:data:pa Frames 
        WatcherClient *wEventPSA = new WatcherClient("EB","Watchers to analyse data after the Event Builder",Watcher_dir,Watcher_dir_tag);
        if ( SetupWatchers("EB",wEventPSA,"_Built") ){
                Snooper->Add ( wEventPSA );     
        wEventPSA->SetConnection("172.16.1.125", 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,"_Merged") ){
                Snooper->Add ( wMerger );
        wMerger->SetConnection("172.16.1.125", 9001);
        }
        // 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,"_Tracked") ){
                Snooper->Add ( wTrack );
        wTrack->SetConnection("172.16.1.125", 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);
    
    if ( !gROOT->IsBatch() ) {
        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);
    }
    if ( start_loop )
        Snooper->ExecuteTask("l");
}

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