DemoInputModule.cc

Go to the documentation of this file.

//
// DemoInputModule
//
// Package: Per (Persistency) Demo class
//
// S. Kasahara 04/2001
//
// Purpose: DemoInputModule class illustrates how to initialize and
//          receive data objects from a PerInputStream using a
//          PerInputStreamManager to manage the input streams.
//
#include <string>
#include "MessageService/MsgService.h"
#include "Persistency/test/DemoInputModule.h"
#include "Persistency/PerInputStream.h"

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

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

//CVSID("$Id: DemoInputModule.cc,v 1.10 2001/12/19 05:11:56 kasahara Exp $");

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

bool DemoInputModule::BeginFile(std::string streamname,
                                std::string fullfilepathname, 
                                Per::EAccessMode accessmode) {
  //
  //  Purpose:  Begin new file for stream streamname.
  //
  //  Argument: streamname        streamname on which to begin new file.
  //                              if streamname = "*", set new file on
  //                              all managed streams. 
  //            fullfilepathname  full file path name of output file
  //            accessmode        accessmode in which file is to be opened
  //                              (either kRead or kUpdate) (default = kRead)
  //
  //  Return:  return true if successfully opened file for all managed
  //                       streams.
  //
  //  Contact:   S. Kasahara
  //


  bool openok = fInputStreamManager.SetFile(streamname,fullfilepathname,accessmode);
  return openok;

}

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

  PerInputStream* instream;
  // Open raw data streams (note that streamname need not be same as 
  // treename, although they can be)
  instream = fInputStreamManager.OpenStream("DaqSnarl","DaqSnarl");

  // Set selection string for this stream.  This specifies the cut that the
  // user would like to apply to data members of the object (RawRecord)
  // stored on this stream.  See PerInputStream::SetSelection for more info.
  // instream->SetSelection("((RawDaqSnarlHeader*)fHeader) -> GetSnarl() % 10 == 0"); 
  
}

void DemoInputModule::EndFile(std::string streamname) {
  //
  //  Purpose:  Close current file for specified stream.
  //
  //  Argument: streamname   string  if streamname="*", close file on all
  //                                 managed streams. 
  //
  //  Return:  none.
  //
  //  Contact:   S. Kasahara
  //

  fInputStreamManager.CloseFile(streamname);

  return;

}

void DemoInputModule::EndJob() {
  // 
  // Purpose: Close all streams at job end.
  //
  // Arguments: none.
  //
  // Return: none.
  //
  // Contact:  S. Kasahara
  //

  fInputStreamManager.CloseStream();

}

bool DemoInputModule::IsBegin() const {
  // 
  // Purpose: Check to see if all managed streams have reached beginning of
  //          current set of streams.
  //
  // Arguments: none.
  //
  // Return: none.
  //
  // Contact:  S. Kasahara
  //

  bool isbegin = false;
  if (fInputStreamManager.IsBegin())
    isbegin = true;

  return isbegin;

}

bool DemoInputModule::IsEnd() const {
  // 
  // Purpose: Check to see if all managed streams have reached end of
  //          current tree.
  //
  // Arguments: none.
  //
  // Return: none.
  //
  // Contact:  S. Kasahara
  //

  bool isend = false;
  if (fInputStreamManager.IsEnd())
    isend = true;

  return isend;

}

Int_t DemoInputModule::Next(MomNavigator* mom,Int_t advanceby) {
  //  Purpose:  Retrieve next entry from managed streams satisfying user's
  //            selection string (if specified).  The objects are
  //            extracted from the input streams and loaded into the
  //            input MomNavigator object.
  //
  //  Argument: mom  pointer to MomNavigator
  //            advanceby  number of records to move ahead (default=1)
  //
  //  Return:  returns the number of records retrieved.  
  //
  //  Contact:   S. Kasahara
  //

  Int_t nobject = fInputStreamManager.Next(mom,advanceby);
  return nobject;

}

Int_t DemoInputModule::Previous(MomNavigator* mom,Int_t rewindby) {
  //  Purpose:  Retrieve previous entry from managed streams satisfying user's
  //            selection string (if specified).  The objects are
  //            extracted from the input streams and loaded into the
  //            input MomNavigator object.
  //
  //  Argument: mom  pointer to MomNavigator
  //            rewindby  number of records to move back by (default=1)
  //
  //  Return:  returns the number of records retrieved.  
  //
  //  Contact:   S. Kasahara
  //

  Int_t nobject = fInputStreamManager.Previous(mom,rewindby);
  return nobject;

}

std::ostream& DemoInputModule::Print(std::ostream& ms) const {
  // Purpose:  Print status of demo input model on std::ostream.
  //
  // Arguments: ms std::ostream to display on.
  //
  // Return: std::ostream reference.
  //
  // Contact: S. Kasahara
  //

  fInputStreamManager.Print(ms);

  return ms;

}

---