IoDummyStreamItr.cxx

Go to the documentation of this file.

//
// IoDummyStreamItr
//
// Dummy data stream to allow job control cycling with no input data 
// stream.
// 
// Author: S. Kasahara 11/05
//

#include "IoModules/IoDummyStreamItr.h"
#include "MessageService/MsgService.h"

CVSID("$Id: IoDummyStreamItr.cxx,v 1.2 2006/03/05 18:17:21 rhatcher Exp $");

//......................................................................
IoDummyStreamItr::IoDummyStreamItr() : fIsValid(true) {
//======================================================================
// Default constructor
//======================================================================
  
  return;
}

//......................................................................

IoDummyStreamItr::~IoDummyStreamItr() {
//======================================================================
// Destructor
//======================================================================

}

//......................................................................

int IoDummyStreamItr::LoadRecords(MomNavigator* /* m */) {
//======================================================================
// Returns number of records loaded.
//======================================================================
  int nrecord = 0;
  return nrecord;
}

//......................................................................

int IoDummyStreamItr::Increment(int n, MomNavigator* /* m */) {
//======================================================================
// Advance n record sets.  Returns number of record sets advanced.
//======================================================================
  return n;
}

//......................................................................

int IoDummyStreamItr::Decrement(int n, MomNavigator* /* m */) {
//======================================================================
// Rewind n record sets. Returns number of record sets rewound.
//======================================================================
  return n;
}

//......................................................................

JobCResult IoDummyStreamItr::GoTo(const VldContext& vld,MomNavigator* /* m */){
//======================================================================
// Go directly to a record with a specified validity context. 
//======================================================================

  MSG("Io",Msg::kWarning) << "IoDummy GoTo " << vld 
                          << " not supported. Ignored!" << endl;

  return JobCResult::kAOK; // success
}

//......................................................................

int IoDummyStreamItr::GoToEOF() {
//======================================================================
// Advance to the end of all files
//======================================================================
  MSG("Io",Msg::kWarning) <<
    "IoDummy GoToEOF not supported. Ignored!" << endl;

  return 1;
}

//......................................................................

int IoDummyStreamItr::DefineStream(const char* /* streamname */,
                                   const char* /* treename */)
{
//======================================================================
// Define stream with name streamname to serve tree of name treename.
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy DefineStream not supported. Ignored!" << endl;

  return 1;
}

//......................................................................

int IoDummyStreamItr::Streams(const char* /* streams */) {
//======================================================================
// Modify open streams to match those specified in streams.  streams
// is a delimiter separated list of streamnames. Returns number of
// streams open.
//======================================================================

//  MSG("Io",Msg::kWarning) <<
//    "IoDummy Streams " << streams << " not supported. Ignored!" << endl;

  return 0;
}

//......................................................................

int IoDummyStreamItr::Select(const char* /* stream */, 
                            const char* /* selection */,bool /* isRequired */){
//======================================================================
// Set the selection cuts for named stream.  Returns 0 if stream not
// open, else 1.
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy Select not supported. Ignored!" << endl;

  return 0;

}

//......................................................................

int IoDummyStreamItr::SetSequenceMode(const char* /* stream */, 
                                      Per::ESequenceMode /* sequenceMode */) {
//======================================================================
// Set the sequence mode for named stream.  Returns 0 if stream not
// open, else 1.
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy Select not supported. Ignored!" << endl;

  return 0;

}

//......................................................................

int IoDummyStreamItr::SetWindow(const char* /* stream */, 
                                double /* lower */, double /* upper */) {
//======================================================================
//Set the window for named stream.  Returns 0 if stream not open, else 1
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy Select not supported. Ignored!" << endl;

  return 0;

}

//......................................................................

void IoDummyStreamItr::AddFile(const char* /* fullfilepathname */,int /* at */,
                               const char* /* streamlist */) { 
//======================================================================
// Purpose: Add file fullfilepathname to index position at in filelist
//          associated with the stream(s) in streamlist. 
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy AddFile not supported. Ignored!" << endl;

  return;

}

//......................................................................

const char* IoDummyStreamItr::GetCurrentFile(const char* /* streamname */) 
                                                                     const { 
//======================================================================
// Purpose: Return current file of specified stream.
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy GetCurrentFile not supported. Ignored!" << endl;
  return "";

}

//......................................................................

JobCResult IoDummyStreamItr::GoToFile( int /* n */, 
                                       const char* /* streamlist */ ) { 
//======================================================================
// Purpose: GoToFile at position n in filelist of specified streams.
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy GoToFile not supported. Ignored!" << endl;

  return JobCResult::kAOK;

}

//......................................................................

JobCResult IoDummyStreamItr::GoToFile(const char* /* filename */, 
                                      const char* /* streamlist */) { 
//======================================================================
// Purpose: GoToFile filename in filelist of specified streams.
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy GoToFile not supported. Ignored!" << endl;

  return JobCResult::kAOK;
}

//......................................................................

JobCResult IoDummyStreamItr::NextFile(int /* n */, 
                                      const char* /* streamlist */) { 
//======================================================================
// Purpose: Advance forward n files in filelist of specified stream(s).
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy NextFile not supported. Ignored!" << endl;

  return JobCResult::kAOK;

}

//......................................................................

JobCResult IoDummyStreamItr::PrevFile(int /* n */, 
                                      const char* /* streamlist */) { 
//======================================================================
// Purpose: Rewind backward n files in filelist of specified stream(s).
//======================================================================

  MSG("Io",Msg::kWarning) <<
    "IoDummy PrevFile not supported. Ignored!" << endl;

  return JobCResult::kAOK;

}

//......................................................................

void IoDummyStreamItr::RemoveFile(const char* /* filename */,
                                  const char* /* streamlist */){
//======================================================================
// Purpose: Remove file filename from filelist associated with the
//          stream(s) in streamlist.  
//======================================================================

// No managed files to remove.
  return;

}

//......................................................................

std::ostream& IoDummyStreamItr::ListFile(std::ostream& os, 
                                         const char* /* streamlist */) const { 
//======================================================================
// Purpose: List files in file list of specified stream(s).
//
// Arguments: os  ostream to direct print.
//            streamlist Delimiter separated list of streams (e.g.
//                       "DaqSnarl,DaqMonitor") on which to apply action.
//                       If streamlist = "*" (default) => apply to all streams.
// 
// Return: ostream reference.
// 
// Contact: S. Kasahara
//======================================================================

  os << "IoDummyStreamItr::ListFile: No input files." << endl;
  
  return os;
}

---