DemoInput.cc

Go to the documentation of this file.

#include "TROOT.h"
#include "TTabCom.h"
#include "RawData/RawRecord.h"
#include "Persistency/test/DemoInputModule.h"
#include "MessageService/MsgService.h"
#include "MinosObjectMap/MomNavigator.h"

TROOT root("DemoInput","MINOS Persistency Package Demo Input");

CVSID("$Id: DemoInput.cc,v 1.7 2002/10/21 03:12:56 kasahara Exp $");
//
// This demo program illustrates how the DemoInputModule could
// be used to read records back into memory. 
//
// S. Kasahara  04/2001
//

int main() {

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

  DemoInputModule dinmod;  // create a demo input module object


  dinmod.BeginJob();  // performs input stream initialization

  ms << "\nThis demo program shows how the offline framework\n"
     << "could make use of the persistency classes to read data from\n"
     << "file.  It attempts to retrieve RawRecords from file testdaq.root\n"        << "generated by DemoDaq.\n" << endl;

  // tell all(="*") managed input streams to open file testdaq.root
  bool openok = dinmod.BeginFile("*","testdaq.root",Per::kRead);   

  ms.SetLogLevel(Msg::kVerbose); // I don't know why I have to do this

  if( !openok ) {
    ms << "Input file failed to open.  Demo program requires\n"
       << "that DemoDaq be run first to generate the test file\n"
       << "testdaq.root in the current working directory.  Please run\n"
       << "DemoDaq and then try again." << endl;
    dinmod.EndJob();
    return 0;
  }
  else {
    ms << "Successfully opened input file testdaq.root.\n"
       << "Status of input stream manager before retrieving entries:\n\n"
       << dinmod << endl; 
  }

  // Begin entry loop
  Int_t nent = 0;
  while ( ! dinmod.IsEnd() ) {
    //"mom" is a container for all records retrieved in the entry  
    MomNavigator* mom = new MomNavigator();
    if (dinmod.Next(mom)) nent++; //records are retrieved from the input stream
    if ( ! dinmod.IsEnd() ) {
    RawRecord* rawrecord = dynamic_cast<RawRecord*>(mom -> GetFragment("RawRecord"));
    ms << "Received rawrecord " << nent << " from stream "
               << rawrecord -> GetTempTags().GetCharString("stream")
               << " tree " << rawrecord -> GetTempTags().GetCharString("tree")
               << " index " << rawrecord -> GetTempTags().GetInt("index")
               << " file " << rawrecord -> GetTempTags().GetCharString("file")
               << endl;
    }
    delete mom; // clean up records managed by mom. 
  }

  ms << "Demo job finished record retrieval after " << nent << " entries." << endl;
  ms << "Status of input stream manager at end of job:\n\n" << dinmod << endl;

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

  dinmod.EndJob(); // close all streams

  return 0;

}

---