RunFileModule.cxx

Go to the documentation of this file.

// $Id: RunFileModule.cxx,v 1.9 2006/02/01 20:04:12 rhatcher Exp $
//
// RunFileModule is a JobCModule that writes out to the run file
//
// Author: B. Speakman 2004.10.23
//
#include <fstream>
#include <iostream>
#include <math.h>

#include "TFile.h"
#include "TString.h"
#include "TSystem.h"
#include "TTimeStamp.h"

#include "CandData/CandRecord.h"
#include "CandData/CandHeader.h"

#include "JobControl/JobCModuleRegistry.h"
#include "MessageService/MsgService.h"
#include "MinosObjectMap/MomNavigator.h"
#include "Plex/PlexSEIdAltL.h"
#include "Plex/PlexHandle.h"

#include "RawData/RawRecord.h"
#include "RawData/RawDaqSnarlHeader.h"
#include "RawData/RawDigit.h"
#include "RawData/RawDigitDataBlock.h"
#include "RawData/RawDaqHeaderBlock.h"

#include "RunFileModule.h"
#include "UtilRSM.h"
#include "RSM.h"

using namespace std;

ClassImp(RunFileModule)

CVSID("$Id: RunFileModule.cxx,v 1.9 2006/02/01 20:04:12 rhatcher Exp $");
JOBMODULE(RunFileModule, "RunFileModule", "build run files");

RunFileModule::RunFileModule() {
  RSMSyn << "RunFileModule::RunFileModule" << endl;
  fRunNum = 0;
  fSubRunNum = 0;
  fOutMode = ios::out | ios::app;
  fRunOUT = false;
}

RunFileModule::~RunFileModule() {
  RSMSyn << "RunFileModule::~RunFileModule" << endl;
}

void RunFileModule::RunFileOUT() {
  RSMDeb << "RunFileModule::RunFileOUT" << endl;

  if (fRunOUT) {
    RSMErr << "Multiple output attempt for: " <<
      fRunNum << "-" << fSubRunNum << endl;
    return;
  }

  if (fRunNum==0 && fSubRunNum==0) {
    RSMDeb << "Output attempt for: " <<
      fRunNum << "-" << fSubRunNum << endl;
    return;
  }

  ofstream fout(fRunFileFull.c_str(),fOutMode);

  char det = 'F';
  if(fDet==Detector::kFar) det = 'F';
  if(fDet==Detector::kNear) det = 'N';
  char file_out[25];
  sprintf(file_out,"%c%08d_%04d.mdaq.root",det,fRunNum,fSubRunNum);
  fout << file_out << endl;
  fout.close();

  fRunOUT = true;

  //remove the .building_[] file
  gSystem->Unlink(fBuildFileFull.c_str());

  return;
}

void RunFileModule::BuildFileOUT() {
  RSMDeb << "RunFileModule::BuildFileOUT" << endl;

  if (fRunNum==0 && fSubRunNum==0) {
    RSMDeb << "Output attempt for: " <<
      fRunNum << "-" << fSubRunNum << endl;
    return;
  }

  ofstream fout(fBuildFileFull.c_str(),fOutMode);

  char det = 'F';
  if(fDet==Detector::kFar) det = 'F';
  if(fDet==Detector::kNear) det = 'N';
  char file_out[25];
  sprintf(file_out,"%c%08d_%04d.mdaq.root",det,fRunNum,fSubRunNum);
  fout << file_out << endl;
  fout.close();
  return;
}

JobCResult RunFileModule::Ana(const MomNavigator *mom) {
  JobCResult result(JobCResult::kPassed);// The default result

  RawRecord* rawrec=0;

  TIter momitr = const_cast<MomNavigator*>(mom)->FragmentIter();
  TObject* momobj=0;
  while ((momobj=momitr())) {
    if ((rawrec=dynamic_cast<RawRecord*>(momobj))) {
      const RawDaqHeader* dhdr =
        dynamic_cast<const RawDaqHeader*>(rawrec->GetRawHeader());

      if (fRunNum!=dhdr->GetRun() || fSubRunNum!=dhdr->GetSubRun()) {
        RSMDeb << "Run change: " <<
          fRunNum << "-" << fSubRunNum << " -> " <<
          dhdr->GetRun() << "-" << dhdr->GetSubRun() << endl;
        RunFileOUT();

        fRunOUT = false;
        fRunNum = dhdr->GetRun();
        fSubRunNum = dhdr->GetSubRun();
        fDet = dhdr->GetVldContext().GetDetector();
        BuildFileOUT();
      }
    }
  }
  return result;
}

void RunFileModule::BeginJob() {
  RSMSyn << "RunFileModule::BeginJob" << endl;
  fRunNum = 0;
  fSubRunNum = 0;
  fOutMode = ios::out | ios::app;
  fRunOUT = false;
}

void RunFileModule::EndJob() {
  RSMSyn << "RunFileModule::EndJob" << endl;

  RSMDeb << "Final output in EndJob: " <<
    fRunNum << "-" << fSubRunNum << endl;
  RunFileOUT();
}

const Registry& RunFileModule::DefaultConfig() const {
  RSMSyn << "RunFileModule::DefaultConfig" << endl;

  static Registry r;

  string name = this->JobCModule::GetName();
  r.SetName((name+".config.default").c_str());
  r.UnLockValues();

  r.Set("RunFileName","GenericMode.run");
  r.Set("RunFileDir","./");

  r.LockValues();

  return r;
}

void RunFileModule::Config(const Registry& r) {
  RSMSyn << "RunFileModule::Config" << endl;
  const char* tmps = 0;

  if(r.Get("RunFileName",tmps)) fRunFileName=tmps;
  if(r.Get("RunFileDir",tmps)) fRunFileDir=tmps;

  if(!UtilRSM::CheckDir(fRunFileDir.c_str())) exit(0);

  fRunFileFull = fRunFileDir + "/" + fRunFileName;
  fBuildFileFull = fRunFileDir + "/.building_" + fRunFileName;
}

---