onlinemonitor/trbmonitor/TTrbAnalysis.cxx (r4864/r4070)

Go to the documentation of this file.

#include "TTrbAnalysis.h"

#include <stdlib.h>

#include "TCanvas.h"
#include "TH1.h"
#include "TFile.h"

#include "Go4EventServer.h"
#include "TGo4AnalysisStep.h"
#include "TGo4Version.h"

#include "TTrbEvent.h"
#include "TTrbProc.h"
#include "TGo4StepFactory.h"
#include "TGo4MbsEvent.h"

TTrbAnalysis::TTrbAnalysis() :
        TGo4Analysis(),
        fRawEvent(0),
        fUnpackEvent(0),
        fSize(0),
        fEvents(0)
{
        TGo4Log::Error("Wrong constructor TTrbAnalysis()!");
}

TTrbAnalysis::TTrbAnalysis(int argc, char** argv) :
        TGo4Analysis(argc, argv),
        fRawEvent(0),
        fUnpackEvent(0),
        fSize(0),
        fEvents(0)
{
        if (!TGo4Version::CheckVersion(__GO4BUILDVERSION__))
        {
           TGo4Log::Error("Go4 version mismatch");
                exit(-1);
        }

        TGo4Log::Info("TTrbAnalysis: Create");


        TGo4StepFactory* factory1 = new TGo4StepFactory ("Unpack-factory");

        factory1->DefUserEventSource ("TTrbSource");                    
        factory1->DefInputEvent ("RawEvent","TGo4MbsEvent");    
        factory1->DefEventProcessor ("UnpackProc", "TTrbProc"); 
        factory1->DefOutputEvent ("UnpackEvent", "TTrbEvent");  

        TGo4UserSourceParameter* source1 = new TGo4UserSourceParameter ("test.hld");
        TGo4FileStoreParameter* store1 = new TGo4FileStoreParameter (Form("%sOutput", argv[0]));
        store1->SetOverwriteMode (kTRUE);
        TGo4AnalysisStep* step1 = new TGo4AnalysisStep ("Unpack",factory1,source1,store1,0);

        step1->SetSourceEnabled (kTRUE);
        step1->SetStoreEnabled (kFALSE);                
        step1->SetProcessEnabled (kTRUE);
        step1->SetErrorStopEnabled (kTRUE);

        AddAnalysisStep(step1);
}

TTrbAnalysis::~TTrbAnalysis()
{
   TGo4Log::Info("TTrbAnalysis: Delete");
}

Int_t TTrbAnalysis::UserPreLoop()
{
   TGo4Log::Info("TTrbAnalysis: PreLoop");

        fRawEvent = dynamic_cast<TGo4MbsEvent*> (GetInputEvent("Unpack"));              // of step "Unpack"
        fUnpackEvent = dynamic_cast<TTrbEvent*> (GetOutputEvent("Unpack"));
        fEvents = 0;

        fSize = (TH1D*)GetHistogram("Eventsize");
        if (fSize==0)
        {
                fSize = new TH1D ("Eventsize", "Read columns", Trb_BUFSIZE/32, 0, Trb_BUFSIZE);
                AddHistogram (fSize);
        }

//      ClearObjects ("Histograms");

        return 0;
}

Int_t TTrbAnalysis::UserPostLoop()
{
        TFile calibHistoFile("calibHistos.root", "recreate");

        calibHistoFile.Close();

        TGo4Log::Info("TTrbAnalysis: PostLoop");
        TGo4Log::Info("Total events: %d", fEvents);
        fUnpackEvent = 0;               
        fRawEvent = 0;
        fEvents = 0;
        return 0;
}

Int_t TTrbAnalysis::UserEventFunc()
{
        Int_t value = 0;
        if (fRawEvent) value = fRawEvent->GetDlen();
        fSize->Fill(value);             
        fEvents++;
        return 0;
}