DemoDaq.cc

Go to the documentation of this file.

#include "TROOT.h"
#include "TTabCom.h"
#include "TTree.h"
#include "Persistency/test/DemoDaqOutputModule.h"
#include "MessageService/MsgService.h"
#include "MinosObjectMap/MomNavigator.h"
#include "RawData/RawRecord.h"
#include "RawData/RawDaqSnarlHeader.h"
#include "RawData/RawDigitDataBlock.h"

TROOT root("DemoDaq","MINOS Persistency Package Demo Daq");
MomNavigator* FillEntry(Int_t entry); 

CVSID("$Id: DemoDaq.cc,v 1.12 2007/11/11 05:10:38 rhatcher Exp $");
//
// This demo program illustrates how the Daq could make use
// of the persistency package classes to persist raw data to file.
// This demo uses the DemoDaqOutputModule class 
// to interface to the persistency package classes.
//
// Argument:  nent = number of entries to generate (default = 1000)
//
// S. Kasahara  04/2001
//

int main(int argc, char **argv) {

  // gDebug = TTabCom::kDebug;  // Activate for extra debug printout

  MsgStream& ms = MSGSTREAM("Per",Msg::kInfo);
  ms.SetLogLevel(Msg::kInfo);

  Int_t nent = 1000;  // default number of entries
  if (argc > 1) {
    nent = atoi(argv[1]);
  }

  DemoDaqOutputModule daqmod;  // create a daq output module object


  daqmod.BeginJob();  // performs output stream initialization

  ms << "\nThis demo shows how the Daq could make use of the\n"
     << "persistency classes to write data to file. " 
     << nent << " RawRecords\n"
     << "are artificially filled and written to stream DaqSnarl in\n"
     << "file testdaq.root.\n" << endl;

  //TTree::SetMaxTreeSize(10000); // to force file change
  bool openok = daqmod.BeginFile("testdaq.root",Per::kRecreate);   

  if( !openok ) {
    ms << "Output file failed to open.  Demo program requires\n"
       << " ability to write to current working directory. Please check\n"
       << " write access and try again." << endl;
    daqmod.EndJob();
    return 0;
  }
  else {
    ms << "Successfully opened output file testdaq.root.\n"
       << "Status of output stream manager before filling entries:\n\n" 
       << daqmod << endl;
  }

  ms.SetLogLevel(Msg::kDebug);
  // Begin entry loop
  MomNavigator* mom; //"mom" is a container for all records produced in the entry
  for (Int_t ient=0; ient < nent; ient++) {
    mom = FillEntry(ient);  // artificially fills records  
    if ( mom ) daqmod.Put(mom); //records are persisted to the output streams
    delete mom; // clean up records managed by mom. 
  }
  
  ms << "\nStatus of output stream manager after filling "<< nent
     << " entries in stream DaqSnarl:\n\n" << daqmod << endl;

  daqmod.EndFile(); // close file on all managed streams

  daqmod.EndJob(); // close all streams

  return 0;

}

MomNavigator* FillEntry(Int_t snarl) {
  //
  // Function FillEntry artificially fills a DaqSnarl and loads it
  // into a MomNavigator object.
  //

  // Create daq frame header
  Int_t run = 1; // run number
  Short_t subrun = 1; // subrun number
  Short_t runtype = 1;
  Detector::Detector_t dtype = Detector::kCalib;  // detector type
  SimFlag::SimFlag_t simflg = SimFlag::kData;  // data source
  VldTimeStamp tstamp((time_t)(snarl+1),0); // time stamp 
  VldContext vldc(dtype,simflg,tstamp);
  UInt_t trigsrc = 0x01;  // physics trigger
  UInt_t errcode = 1; //error code 
  UInt_t timeframe = 2;
  UInt_t nrawdigits = 10;
  UInt_t spilltype = 0;
  RawDaqSnarlHeader* hdr = new RawDaqSnarlHeader(vldc,run,subrun,runtype,
              timeframe,snarl,trigsrc,errcode,nrawdigits,spilltype);
  // Construct daq frame record passing it the header
  RawRecord* record = new RawRecord(hdr);

  // Construct block of data words
  const Int_t nwords = 100;
  Int_t array[nwords];
  for (Int_t iwrd = 0; iwrd < nwords; iwrd++) {
    array[iwrd]=1;
  }
  RawDigitDataBlock* dblock = new RawDigitDataBlock(array);
  
  record -> AdoptRawBlock(dblock);

  // Give record to Mom to be adopted, record, header, & datablock will be
  // deleted when Mom is deleted.
  MomNavigator* mom = new MomNavigator();
  mom -> AdoptFragment(record);

  // We could also create and store in Mom other records produced in this
  // entry
  return mom;

}

---