GANIL/OnlineWatchersLLP.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 "SetupWatchers.C"

void OnlineWatchersLLP(TFile *file = 0x0, TFile *file_tag = 0x0, Bool_t start_loop = false);
void OnlineWatchersLLP(TString entrypoint, TString CrystalSel="");
Bool_t CheckCrystal(TString crystal);

// protected by a namespace
namespace _OnlineWatchersLLP_ {

TString CrystalSelection="";

// Crystal in there, just set empty string to remove some of them
const Int_t gNumberOfCrystals = 32;
//
std::string gCrysLabel[gNumberOfCrystals] = {
    "00A",
    "00B",
    "00C",
    "02A",
    "02B",
    "02C",
    "03A",
    "03B",
    "03C",
    "04A",
    "04B",
    "04C",
    "05A",
    "05B",
    "05C",
    "09B",
    "09C",
    "10A",
    "10B",
    "10C",
//    "11A",
    "11B",
    "11C",
    "12A",
    "12B",
    "12C",
    "13A",
    "13B",
    "13C",
    "14A",
    "14B",
    "14C",
};
// in principle all preprocessing actors are one the same node
std::string gBaseName = "172.16.1.1";
std::string gMachine[gNumberOfCrystals] = {
    "14",
    "21",
    "12",
    "23",
    "22",
    "19",
    "18",
    "08",
    "09",
    "01",
    "05",
    "15",
    "55",
    "24",
    "29",
    "26",
    "56",
    "16",
    "17",
    "11",
//    "28",
    "02",
    "57",
    "25",
    "04",
    "03",
    "10",
    "07",
    "20",
    "13",
    "06",
    "27",
};

TString EntryPoint="";
}


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(TString entrypoint, TString CrystalSel)
{
    EntryPoint = entrypoint;

    CrystalSelection = CrystalSel;

    OnlineWatchersLLP(new TFile("Out/OnlineLLPHistory.root","UPDATE"),new TFile("Out/TagOnlineLLPHistory.root","UPDATE"),true);
}


void OnlineWatchersLLP(TFile *file, TFile *file_tag, Bool_t start_loop)
{
    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 -------------------------------------------------------------
    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(),gCrysLabel[0].data()) , ComputePort(gCrysLabel[0],0) );
    }
    */
    
    // Crystal -------------------------------------------------------------
    // to know if a Watcher has been added to the dispatcher
    TString tmp = EntryPoint.Copy();
    tmp.ReplaceAll("CCRYSTAL","");

    if((EntryPoint!="" &&tmp.Contains("CRYSTAL")) || EntryPoint=="")
    {
        for (Int_t i = 0; i < gNumberOfCrystals ; i++ )
        {
            // not in the setup
            if ( gCrysLabel[i] == "" || ! CheckCrystal(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);
        }
    }
    // CCrystal -------------------------------------------------------------
    // to know if a Watcher has been added to the dispatcher
    if((EntryPoint!="" && EntryPoint.Contains("CCRYSTAL") )|| EntryPoint=="")
    {
        for (Int_t i = 0; i < gNumberOfCrystals ; i++ ) {

            // not in the setup
            if ( gCrysLabel[i] == "" || ! CheckCrystal(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;
        }
    }

    // PSA -------------------------------------------------------------
    // to know if a Watcher has been added to the dispatcher
    if((EntryPoint!="" && EntryPoint.Contains("PSA") )|| EntryPoint=="")
    {
        for (Int_t i = 0; i < gNumberOfCrystals ; i++ ) {
            // not in the setup
            if ( gCrysLabel[i] == "" || ! CheckCrystal(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;
        }
    }
    //
    // 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 *wAnc = new WatcherClient("ANC","Watchers on ancillary Data",Watcher_dir,Watcher_dir_tag);
    if ( SetupWatchers("RANC0",wAnc) ) {
        Snooper->Add ( wAnc );
        wAnc->SetConnection( "172.16.1.194", 14102);
    }
    else
        delete wAnc;


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

Bool_t CheckCrystal(TString crystal)
{
    if(CrystalSelection=="")
        return true;
    else if (CrystalSelection.Contains(crystal))
            return true;
    else
        return false;
}