DemoDaqOutputModule.cc

Go to the documentation of this file.

//
// DemoDaqOutputModule
//
// Package: Per (Persistency) Demo class
//
// S. Kasahara 01/2001
//
// Purpose: Simple DemoDaqOutputModule class to show use of Persistency
//          output streams within context of the write of the raw data.
//          This is for use with the DaqDemo.cc program that comes with
//          the Persistency package.
//
#include <string>
#include "MessageService/MsgService.h"
#include "MinosObjectMap/MomNavigator.h"
#include "Persistency/test/DemoDaqOutputModule.h"
#include "Persistency/PerOutputStream.h"
using namespace std;

ostream& operator<<(ostream& ms, const DemoDaqOutputModule& dm) { 
  return dm.Print(ms); 
}

//   Definition of static data members
//   *********************************

//CVSID("$Id: DemoDaqOutputModule.cc,v 1.10 2002/11/19 18:42:37 kasahara Exp $");

// Definition of methods (alphabetical order)
// ******************************************

bool DemoDaqOutputModule::BeginFile(string fullfilepathname, Per::EAccessMode accessmode) {
  //
  //  Purpose:  Begin new file for all streams managed by output stream
  //            manager.
  //
  //  Argument: fullfilepathname  full file path name of output file
  //            accessmode        accessmode in which file is to be opened
  //                              (default = kNew)
  //
  //  Return:  return true if successfully opened file.
  //
  //  Contact:   S. Kasahara
  //

  string streamname="*";  // apply SetFile to all managed streams
  bool openok = fOutputStreamManager.SetFile(streamname,fullfilepathname, accessmode);

  return openok;  // returns true if successful

}

void DemoDaqOutputModule::BeginJob() {
  //
  // Purpose: Perform initialization of streams required at Daq startup.
  //
  // Arguments: none.
  //
  // Return: none.
  //
  // Contact:  S. Kasahara
  //

  PerOutputStream* outstream;
  // Open stream w/name "DaqSnarl" to fill tree "DaqSnarl" (but note
  // that streamname need not be the same as treename) with objects
  // of class "RawRecord" (for now).  One main branch is created with
  // splitlevel = Per::kRecSplit. 
  outstream = fOutputStreamManager.OpenStream("DaqSnarl","DaqSnarl",
                                           "RawRecord","","",Per::kRecSplit);
  if ( outstream ) {
    // Set the AutoSave event interval of this stream.  This will automatically
    // configure the BasketSave event interval of each branch attached to 
    // stream to dump baskets just before the tree save.
    outstream -> SetAutoSave(100,10);
  }
  outstream = fOutputStreamManager.OpenStream("DaqMonitor","DaqMonitor",
                                           "RawRecord","","",Per::kRecSplit);
  if ( outstream ) {
    // Set the AutoSave event interval of this stream.  This will automatically
    // configure the BasketSave event interval of each branch attached to 
    // stream to dump baskets just before the tree save.
    outstream -> SetAutoSave(100,10);
  }

}

void DemoDaqOutputModule::EndFile() {
  //
  //  Purpose:  Close current file for all streams managed by output stream
  //            manager.
  //
  //  Argument: none.
  //
  //  Return:  none.
  //
  //  Contact:   S. Kasahara
  //

  fOutputStreamManager.Write(); // write the trees on all streams to file
  fOutputStreamManager.CloseFile(); // close files on all streams

}

void DemoDaqOutputModule::EndJob() {
  // 
  // Purpose: Close all streams at Daq finish.
  //
  // Arguments: none.
  //
  // Return: none.
  //
  // Contact:  S. Kasahara
  //

  fOutputStreamManager.CloseStream();

}

ostream& DemoDaqOutputModule::Print(ostream& ms) const {
  //
  //  Purpose:  Print status of daq output module on ostream.
  //
  //  Arguments: ms ostream to display on.
  //
  //  Return:  ostream reference.
  //
  //  Contact:   S. Kasahara
  //

  fOutputStreamManager.Print(ms);

  return ms;

}


Int_t DemoDaqOutputModule::Put(const MomNavigator* mom) {
  //  Purpose:  Store new entry with use of output stream manager.
  //
  //  Argument: mom  pointer to MomNavigator
  //
  //  Return:  number of objects actually persisted.
  //
  //  Contact:   S. Kasahara
  //

  // Persist the records from Mom into the appropriate stream(s).
  Int_t nobject = fOutputStreamManager.Put(mom);
  return nobject;

}

---