BeamMonDbuModule.cxx

Go to the documentation of this file.

#include "BeamMonDbuModule.h"
#include "BMFileSummaryFiller.h"
#include "BMSpillFiller.h"

#include <BeamDataUtil/BDSwicCalibrator.h>
#include <BeamDataUtil/BDDevices.h>
#include <BeamDataUtil/BDUniquify.h>

#include <BeamDataUtil/BDEarliest.h>
#include <BeamDataUtil/BDHornCurrent.h>
#include <BeamDataUtil/BDTarget.h>
#include <BeamDataUtil/BDHadMuMon.h>

#include <RawData/RawRecord.h>
#include <RawData/RawBeamMonHeaderBlock.h>
#include <RawData/RawBeamMonBlock.h>


#include <JobControl/JobCModuleRegistry.h>
#include <JobControl/JobCResult.h>
#include <MessageService/MsgService.h>

#include <DataUtil/GetRawBlock.h>
using namespace DataUtil;

CVSID("$Id: BeamMonDbuModule.cxx,v 1.14 2005/11/07 21:38:22 bv Exp $");
JOBMODULE(BeamMonDbuModule,
          "BeamMonDbu", "Update the database with Beam Monitoring info.");

BeamMonDbuModule::BeamMonDbuModule()
    : JobCModule()
    , fPipe()
    , fFileSummaryFiller(0)
    , fSpillFiller(0)
{
    this->FillPipeline();
}
BeamMonDbuModule::~BeamMonDbuModule()
{
    MSG("BD",Msg::kInfo) << " BeamMonDbuModule destructor\n";
    this->Reap();
}

void BeamMonDbuModule::Reap()
{
    if (fSpillFiller) 
        delete fSpillFiller; 
    fSpillFiller = 0;

    if (fFileSummaryFiller)
        delete fFileSummaryFiller; 
    fFileSummaryFiller = 0;

    for (int ind=0; ind<4; ++ind) {
        if (fHadMu[ind]) delete fHadMu[ind];
        fHadMu[ind] = 0;
    }
}

void BeamMonDbuModule::FillPipeline()
{
    BDPipeline::ProcessPipeline& pipeline = fPipe.GetProcessPipeline();

    const char* toroids[] = { "E:TOR101", "E:TR101D", "E:TORTGT", "E:TRTGTD", 0 };
    for (int ind=0; toroids[ind]; ++ind) {
        fProtonIntensity[ind] = new BDScalar();
        fProtonIntensity[ind]->SetDevice(toroids[ind]);
        pipeline.push_back(fProtonIntensity[ind]);
    }
    pipeline.push_back(fEarliest = new BDEarliest);
    pipeline.push_back(fHornCurrent = new BDHornCurrent);
    pipeline.push_back(fTarget = new BDTarget);

    for (int ind=0; ind<4; ++ind) {
        fHadMu[ind] = new BDHadMuMon;
    }

    fFileSummaryFiller = new BMFileSummaryFiller(*fProtonIntensity[3]);
    fSpillFiller = new BMSpillFiller(*fEarliest,fProtonIntensity,
                                     *fHornCurrent,*fTarget,fHadMu);
}


JobCResult BeamMonDbuModule::Ana(const MomNavigator *mom)
{
    static BDUniquify uniqifier;
    vector<BDUniquify::BlockPair> blocks = uniqifier.GetUniqueBlocks(*mom);

    size_t nblocks = blocks.size();

    if (nblocks == 0) {
        MSG("BD",Msg::kWarning)
            << "No good beam monitoring data in MOM\n";
        return JobCResult::kFailed;
    }

    for (size_t iblock=0; iblock<nblocks; ++iblock) {
        const RawBeamMonHeaderBlock& rbmhb = *blocks[iblock].first;
        const RawBeamMonBlock& rbmb = *blocks[iblock].second;

        this->Process(rbmhb,rbmb);
    }
    return JobCResult::kAOK;

}
void BeamMonDbuModule::Process(const RawBeamMonHeaderBlock& rbmhb,
                               const RawBeamMonBlock& rbmb)
{
    vector<string> hadmu_name = BDDevices::HadMuMonitors();
    for (int ind=0; ind<4; ++ind) {
        const RawBeamData* d = rbmb[hadmu_name[ind].c_str()];
        if (!d) {
            MSG("BD",Msg::kDebug)
                << "No device data for " << hadmu_name[ind] << ", skipping\n";
            continue;
        }
        fHadMu[ind]->SetData(*d);
    }

    BDSwicCalibrator::Get().Calibrate(rbmhb,rbmb);

    const int trigger_event = 0xa9; // FIXME: needs to be a configurable param.
    if (rbmb.TclkTriggerEvent() != trigger_event) {
        MSG("BD",Msg::kWarning)
            << "Wrong trigger event: " << rbmb.TclkTriggerEvent()
            << " != " << trigger_event << endl;
        return;
    }

    // Alert each table of new data
    fPipe.SetSpill(rbmhb,rbmb);


    fFileSummaryFiller->Timestamp(rbmhb.GetTimeStamp());
    fFileSummaryFiller->SetTclkTrigger(rbmb.TclkTriggerEvent(),
                                       rbmb.TclkTriggerDelay());

    fSpillFiller->Spill(rbmhb,rbmb);

}

void BeamMonDbuModule::BeginFile()
{
    const char* file = this->GetCurrentFile();
    MSG("BD",Msg::kDebug) << "BeginFile: " << file << endl;
    fFileSummaryFiller->NewFile(file);
}

void BeamMonDbuModule::EndFile()
{
    MSG("BD",Msg::kDebug) << "EndFile\n";
    fFileSummaryFiller->Commit();
}
    
void BeamMonDbuModule::EndJob()
{
    MSG("BD",Msg::kDebug) << "EndJob\n";
    this->Reap();
}
    

---