IoInputStreamItr.h

Go to the documentation of this file.

// $Id: IoInputStreamItr.h,v 1.9 2009/01/05 05:55:13 schubert Exp $
//
// Iterator for input data streams
//
// messier@huhepl.harvard.edu
#ifndef IOINPUTSTREAMITR_H
#define IOINPUTSTREAMITR_H
#ifndef IODATASTREAMITR_H
#include "IoModules/IoDataStreamItr.h"
#endif
#ifndef PERINPUTSTREAMMANAGER_H
#include "Persistency/PerInputStreamManager.h"
#endif

class MomNavigator;

class IoInputStreamItr : public IoDataStreamItr
{
public:
  IoInputStreamItr(const char* streamlist="");
  ~IoInputStreamItr();

  // Must provide these, no default implementation given
  bool IsValid() const { return fIsValid; }
  const char* GetFormat() const { return "input"; }
  int LoadRecords(MomNavigator* m);
  int Increment(int n=1, MomNavigator* m=0);
  int Decrement(int n=1, MomNavigator* m=0);
  JobCResult GoTo(const VldContext& vld, MomNavigator* m=0);

  // Override default implementation
  int  GoToEOF();
  int  DefineStream(const char* streamname, const char* treename);
  int  Streams(const char* streamlist);
  int  Select(const char* stream, const char* selection, bool isRequired = false);
  int  SetSequenceMode(const char* stream, Per::ESequenceMode sequencemode);
  int  SetPerOwnedDisabled(const char* stream, bool perowneddisabled = true);
  
  int  SetTestMode(const char* stream, bool testmode);
  int  SetWindow(const char* stream, double lower, double upper);

  int  SetMaxFileRepeat(const char* stream, int numRepeat);
  int  SetMeanMom(const char* stream, double mean);
  int  SetPushRandom(const char* stream, bool setRandom);
  void SetRandomSeed(int rSeed);

  // Override default file handling
  void AddFile(const char* fullfilepathname, int at = -1,
               const char* streamlist = "*");
  const char* GetCurrentFile(const char* streamname = "*") const;
  JobCResult GoToFile(int i, const char* streamlist = "*");
  JobCResult GoToFile(const char* fullfilepathname,const char* streamlist="*");
  JobCResult NextFile(int n = 1, const char* streamlist = "*");
  JobCResult PrevFile(int n = 1, const char* streamlist = "*");
  void RemoveFile(const char* fullfilepathname = "*",
                  const char* streamlist = "*");
  std::ostream& ListFile(std::ostream& os, const char* streamlist = "*") const;

private:
  
  PerInputStreamManager fInputStreamManager; // input stream manager
  bool fIsValid;  // valid input stream iterator

};

#endif

---