IoInputStreamItr Class Reference

#include <IoInputStreamItr.h>

Inheritance diagram for IoInputStreamItr:

List of all members.

Public Member Functions
	IoInputStreamItr (const char *streamlist="")
	~IoInputStreamItr ()
bool	IsValid () const
const char *	GetFormat () const
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)
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)
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 Attributes
PerInputStreamManager	fInputStreamManager
bool	fIsValid

---

Constructor & Destructor Documentation

IoInputStreamItr::IoInputStreamItr (  const char *  streamlist = ""  )

Definition at line 27 of file IoInputStreamItr.cxx. References Streams(). : fIsValid(true) { //====================================================================== // Argument: Delimiter separated list of streams to open. //====================================================================== this -> Streams(streamlist); }

IoInputStreamItr::~IoInputStreamItr (   )

Definition at line 36 of file IoInputStreamItr.cxx. References PerInputStreamManager::CloseStream(), fInputStreamManager, IoDataStreamItr::GetSourceName(), and MSG. { //====================================================================== // Destructor //====================================================================== MSG("Io",Msg::kDebug) << "Close streams " << this->GetSourceName() << "\n"; fInputStreamManager.CloseStream(); }

---

Member Function Documentation

void IoInputStreamItr::AddFile (  const char *  fullfilepathname, int  at = -1, const char *  streamlist = "*" )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 377 of file IoInputStreamItr.cxx. References PerInputStreamManager::AddFile(), find(), fInputStreamManager, Per::GetAssociatedStreamList(), PerInputStreamManager::GetOpenedStream(), and UtilString::StringTok(). { //====================================================================== // Purpose: Add file fullfilepathname to index position at in filelist // associated with the stream(s) in streamlist. If streamlist == "*", // files will be applied to all managed streams, otherwise streamlist // is a delimiter separated list of streams. // // Arguments: fullfilepathname filename. // at the index position in the file list at which to // insert the new file. Set = -1 (default) => insert // at end of file list. // streamlist Delimiter separated list of streams (e.g. // "DaqSnarl,DaqMonitor") on which to apply action. // If streamlist = "*" (default) => apply to all streams. // // Return: none. // // Contact: S. Kasahara //====================================================================== // parse delimiter separate streamlist into a vector of streamnames std::vector<std::string> vstreams; UtilString::StringTok(vstreams,streamlist,":,;/ "); std::vector<std::string>::iterator vsItr; int nstream = 0; for ( vsItr = vstreams.begin(); vsItr != vstreams.end(); vsItr++ ) { std::string streamname = *vsItr; if ( fInputStreamManager.GetOpenedStream(streamname) ) { nstream += fInputStreamManager.AddFile(fullfilepathname,at,streamname); } std::string assocstreams = Per::GetAssociatedStreamList(streamname.c_str()); if ( !assocstreams.empty() ) { // parse delimiter separated streamlist into a vector of streamnames std::vector<std::string> assocstreamlist; UtilString::StringTok(assocstreamlist, std::string(assocstreams),":,;/ "); std::vector<std::string>::iterator astrItr; // Add file to associated streams for ( astrItr = assocstreamlist.begin(); astrItr!= assocstreamlist.end(); astrItr++ ) { std::string assocstreamname = *astrItr; // Check to see if assocstreamname isn't already in input streamlist // This is lame at best and needs to be fixed. typedef std::vector<std::string>::const_iterator vs_citer; vs_citer aspos = std::find(vstreams.begin(),vstreams.end(), assocstreamname); if ( aspos == vstreams.end() ) { if ( fInputStreamManager.GetOpenedStream(assocstreamname) ) { nstream +=fInputStreamManager.AddFile(fullfilepathname,at,assocstreamname); } } } } } return; }

int IoInputStreamItr::Decrement (  int  n = 1, MomNavigator *  m = 0 )  [virtual]

Implements IoDataStreamItr. Definition at line 68 of file IoInputStreamItr.cxx. References fInputStreamManager, and PerInputStreamManager::Previous(). { //====================================================================== // Rewind n record sets. Returns number of record sets rewound. //====================================================================== return fInputStreamManager.Previous(m,n); }

int IoInputStreamItr::DefineStream (  const char *  streamname, const char *  treename )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 106 of file IoInputStreamItr.cxx. References PerInputStreamManager::CloseStream(), fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::OpenStream(). { //====================================================================== // Define stream with name streamname to serve tree of name treename. //====================================================================== MSG("Io",Msg::kDebug) << "Define stream " << streamname << " to serve tree " << treename << endl; if ( fInputStreamManager.GetOpenedStream(streamname) ) { fInputStreamManager.CloseStream(streamname); } fInputStreamManager.OpenStream(streamname,treename); return 1; }

const char * IoInputStreamItr::GetCurrentFile (  const char *  streamname = "*"  )  const [virtual]

Reimplemented from IoDataStreamItr. Definition at line 439 of file IoInputStreamItr.cxx. References fInputStreamManager, and PerStreamManager::GetCurrentFile(). { //====================================================================== // Purpose: Return current file of specified stream. // // Arguments: streamname If specified as "*", returns current file of // first open stream. // // Return: current file name // // Contact: S. Kasahara //====================================================================== return (fInputStreamManager.GetCurrentFile(streamname)).c_str(); }

const char* IoInputStreamItr::GetFormat (   )  const [inline, virtual]

Implements IoDataStreamItr. Definition at line 27 of file IoInputStreamItr.h. { return "input"; }

JobCResult IoInputStreamItr::GoTo (  const VldContext &  vld, MomNavigator *  m = 0 )  [virtual]

Implements IoDataStreamItr. Definition at line 77 of file IoInputStreamItr.cxx. References fInputStreamManager, Per::GetVldBegin(), Per::GetVldEnd(), and PerInputStreamManager::RecordsAt(). { //====================================================================== // Go directly to a record with a specified validity context. Will // stop at record set one past requested validity if exact match not // available. Returns: // JobCResult::kBeginOfInputStream if at begin of streams // JobCResult::kEndOfInputStream if at end of streams // JobCResult::kAOK if all okay //====================================================================== const VldContext& newVld = fInputStreamManager.RecordsAt(m,vld); if ( newVld == Per::GetVldEnd() ) return JobCResult::kEndOfInputStream; if ( newVld == Per::GetVldBegin() ) return JobCResult::kBeginOfInputStream; return JobCResult::kAOK; // success }

int IoInputStreamItr::GoToEOF (   )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 94 of file IoInputStreamItr.cxx. References fInputStreamManager, and PerInputStreamManager::RecordsAt(). { //====================================================================== // Advance to the end of all files //====================================================================== fInputStreamManager.RecordsAt((MomNavigator*)0,Per::GetVldEnd()); return 1; }

JobCResult IoInputStreamItr::GoToFile (  const char *  fullfilepathname, const char *  streamlist = "*" )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 490 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GoToFile(), and UtilString::StringTok(). { //====================================================================== // Purpose: GoToFile filename in filelist of specified streams. // // Arguments: filename full file path name of file in streamlist. // streamlist Delimiter separated list of streams (e.g. // "DaqSnarl,DaqMonitor") on which to apply action. // If streamlist = "*" (default) => apply to all streams. // // Return: JobCResult::kAOK if advance successful and file opened okay on // at least one requested stream, or // JobCResult::kWarning, if requested file not found in file list or // file open error occured on all requested // streams. // // Contact: S. Kasahara //====================================================================== int nstream = 0; // parse delimiter separate streamlist into a vector of streamnames std::vector<std::string> vstreams; UtilString::StringTok(vstreams,streamlist,":,;/ "); std::vector<std::string>::iterator vsItr; for ( vsItr = vstreams.begin(); vsItr != vstreams.end(); vsItr++ ) { std::string streamname = *vsItr; nstream += fInputStreamManager.GoToFile(filename,streamname); } if ( !nstream ) return JobCResult::kWarning; return JobCResult::kAOK; }

JobCResult IoInputStreamItr::GoToFile (  int  i, const char *  streamlist = "*" )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 455 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GoToFile(), and UtilString::StringTok(). { //====================================================================== // Purpose: GoToFile at position n in filelist of specified streams. // // Arguments: n index of file in filelist. // streamlist Delimiter separated list of streams (e.g. // "DaqSnarl,DaqMonitor") on which to apply action. // If streamlist = "*" (default) => apply to all streams. // // Return: JobCResult::kAOK if advance successful and file opened okay on // at least one requested stream, or // JobCResult::kWarning, if requested file number out of range, or // file open error occured on all requested // streams. // // Contact: S. Kasahara //====================================================================== int nstream = 0; // parse delimiter separate streamlist into a vector of streamnames std::vector<std::string> vstreams; UtilString::StringTok(vstreams,streamlist,":,;/ "); std::vector<std::string>::iterator vsItr; for ( vsItr = vstreams.begin(); vsItr != vstreams.end(); vsItr++ ) { std::string streamname = *vsItr; nstream += fInputStreamManager.GoToFile(n,streamname); } if ( !nstream ) return JobCResult::kWarning; return JobCResult::kAOK; }

int IoInputStreamItr::Increment (  int  n = 1, MomNavigator *  m = 0 )  [virtual]

Implements IoDataStreamItr. Definition at line 58 of file IoInputStreamItr.cxx. References fInputStreamManager, and PerInputStreamManager::Next(). { //====================================================================== // Advance n record sets. Returns number of record sets advanced. //====================================================================== return fInputStreamManager.Next(m,n); }

bool IoInputStreamItr::IsValid (   )  const [inline, virtual]

Implements IoDataStreamItr. Definition at line 26 of file IoInputStreamItr.h. { return fIsValid; }

std::ostream & IoInputStreamItr::ListFile (  std::ostream &  os, const char *  streamlist = "*" )  const [virtual]

Reimplemented from IoDataStreamItr. Definition at line 653 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::ListFile(), and UtilString::StringTok(). { //====================================================================== // 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 //====================================================================== // parse delimiter separated streamlist into a vector of streamnames std::vector<std::string> vstreams; UtilString::StringTok(vstreams,streamlist,":,;/ "); std::vector<std::string>::iterator vsItr; for ( vsItr = vstreams.begin(); vsItr != vstreams.end(); vsItr++ ) { std::string streamname = *vsItr; fInputStreamManager.ListFile(os,streamname); } return os; }

int IoInputStreamItr::LoadRecords (  MomNavigator *  m  )  [virtual]

Implements IoDataStreamItr. Definition at line 47 of file IoInputStreamItr.cxx. References fInputStreamManager, and PerInputStreamManager::Get(). { //====================================================================== // Retrieve current record set from manager. Returns number of records // loaded. //====================================================================== int nrecord = fInputStreamManager.Get(m); return nrecord; }

JobCResult IoInputStreamItr::NextFile (  int  n = 1, const char *  streamlist = "*" )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 525 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::IsEndOfFiles(), PerInputStreamManager::NextFile(), and UtilString::StringTok(). { //====================================================================== // Purpose: Advance forward n files in filelist of specified stream(s). // // Arguments: n number of files by which to advance.(default = 1) // streamlist Delimiter separated list of streams (e.g. // "DaqSnarl,DaqMonitor") on which to apply action. // If streamlist = "*" (default) => apply to all streams. // // Return: JobCResult::kAOK if advance successful and file opened okay for // at least one stream, or // JobCResult::kWarning if advance successful, but file open // failed. // JobCResult::kEndOfInputStream, if at end of file list for // all requested streams. // // Contact: S. Kasahara //====================================================================== int nstream = 0; // parse delimiter separate streamlist into a vector of streamnames std::vector<std::string> vstreams; UtilString::StringTok(vstreams,streamlist,":,;/ "); std::vector<std::string>::iterator vsItr; if ( vstreams.empty() ) return JobCResult::kAOK; // no streams requested bool isWarning = false; for ( vsItr = vstreams.begin(); vsItr != vstreams.end(); vsItr++ ) { std::string streamname = *vsItr; int nOK = fInputStreamManager.NextFile(n,streamname); if ( !nOK ) { // Failed to advance to file but not at end of files means open failure if ( !fInputStreamManager.IsEndOfFiles(streamname) ) isWarning = true; } else nstream += nOK; } if ( !nstream ) { if ( isWarning ) return JobCResult::kWarning; else return JobCResult::kEndOfInputStream; } return JobCResult::kAOK; }

JobCResult IoInputStreamItr::PrevFile (  int  n = 1, const char *  streamlist = "*" )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 573 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::IsBeginOfFiles(), PerInputStreamManager::PrevFile(), and UtilString::StringTok(). { //====================================================================== // Purpose: Rewind backward n files in filelist of specified stream(s). // // Arguments: n number of files by which to rewind.(default = 1) // streamlist Delimiter separated list of streams (e.g. // "DaqSnarl,DaqMonitor") on which to apply action. // Set = "*" (default) => apply to all streams. // // Return: JobCResult::kAOK if rewind successful and file opened okay for // at least one stream, or // JobCResult::kWarning if rewind successful, but file open // failed. // JobCResult::kBeginOfInputStream, if at end of file list for // all requested streams. // // Contact: S. Kasahara //====================================================================== int nstream = 0; // parse delimiter separate streamlist into a vector of streamnames std::vector<std::string> vstreams; UtilString::StringTok(vstreams,streamlist,":,;/ "); std::vector<std::string>::iterator vsItr; if ( vstreams.empty() ) return JobCResult::kAOK; // no streams requested bool isWarning = false; for ( vsItr = vstreams.begin(); vsItr != vstreams.end(); vsItr++ ) { std::string streamname = *vsItr; int nOK = fInputStreamManager.PrevFile(n,streamname); if ( !nOK ) { // Failed to advance to file but not at begin of files means open failure if ( !fInputStreamManager.IsBeginOfFiles(streamname) ) isWarning = true; } else nstream += nOK; } if ( !nstream ) { if ( isWarning ) return JobCResult::kWarning; else return JobCResult::kBeginOfInputStream; } return JobCResult::kAOK; }

void IoInputStreamItr::RemoveFile (  const char *  fullfilepathname = "*", const char *  streamlist = "*" )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 621 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::RemoveFile(), and UtilString::StringTok(). { //====================================================================== // Purpose: Remove file filename from filelist associated with the // stream(s) in streamlist. If filename = "*", all files are // removed. // // Arguments: filename full file path name of file to remove. If "*", // all files will be removed from file list. // streamlist Delimiter separated list of streams (e.g. // "DaqSnarl,DaqMonitor") on which to apply action. // If streamlist = "*" (default) => apply to all streams. // // Return: none. // // Contact: S. Kasahara //====================================================================== int nstream = 0; // parse delimiter separate streamlist into a vector of streamnames std::vector<std::string> vstreams; UtilString::StringTok(vstreams,streamlist,":,;/ "); std::vector<std::string>::iterator vsItr; for ( vsItr = vstreams.begin(); vsItr != vstreams.end(); vsItr++ ) { std::string streamname = *vsItr; nstream += fInputStreamManager.RemoveFile(filename,streamname); } return; }

int IoInputStreamItr::Select (  const char *  stream, const char *  selection, bool  isRequired = false )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 196 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::SetSelection(). { //====================================================================== // Set the selection cuts for named stream. Returns 0 if stream not // open, else 1. //====================================================================== int isOpen = 0; MSG("Io",Msg::kDebug) << "Set selection string " << selection << " for stream " << stream << endl; if ( std::string(stream) == "*" ) { fInputStreamManager.SetSelection(stream,selection,isRequired); isOpen = 1; } else if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetSelection(stream,selection,isRequired); isOpen = 1; } return isOpen; }

int IoInputStreamItr::SetMaxFileRepeat (  const char *  stream, int  numRepeat )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 306 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::SetMaxFileRepeat(). { //====================================================================== // Set the number of times to reuse a file before moving to the next one // in the named stream. // Returns 0 if stream not open, else 1. //====================================================================== int isOpen = 0; if (numRepeat < 0) numRepeat = 0; MSG("Io",Msg::kDebug) << "Set number of times to reuse each file from stream " << stream << " = " << numRepeat << endl; if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetMaxFileRepeat(stream,numRepeat); isOpen = 1; } return isOpen; }

int IoInputStreamItr::SetMeanMom (  const char *  stream, double  mean )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 326 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::SetMeanMom(). { //====================================================================== // Set the mean #evts for named stream. // Returns 0 if stream not open, else 1. //====================================================================== int isOpen = 0; MSG("Io",Msg::kDebug) << "Set mean number of events to push to Mom from stream " << stream << " = " << mean << endl; if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetMeanMom(stream,mean); isOpen = 1; } return isOpen; }

int IoInputStreamItr::SetPerOwnedDisabled (  const char *  stream, bool  perowneddisabled = true )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 219 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::SetPerOwnedDisabled(). { //====================================================================== // Used to disable PerOwned for named stream. Returns 0 if stream not // open, else 1. //====================================================================== int isOpen = 0; MSG("Io",Msg::kDebug) << "SetPerOwnedDisabled " << perowneddisabled << " for stream " << stream << endl; if ( std::string(stream) == "*" ) { fInputStreamManager.SetPerOwnedDisabled(stream,perowneddisabled); isOpen = 1; } else if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetPerOwnedDisabled(stream,perowneddisabled); isOpen = 1; } return isOpen; }

int IoInputStreamItr::SetPushRandom (  const char *  stream, bool  setRandom )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 344 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::SetPushRandom(). { //====================================================================== // Set whether to push a random/constant #evts for named stream to Mom. // Returns 0 if stream not open, else 1. //====================================================================== int isOpen = 0; MSG("Io",Msg::kDebug) << "Set push " << ((setRandom)? "random " : "constant ") << "number of events to push to Mom from stream " << stream << endl; if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetPushRandom(stream,setRandom); isOpen = 1; } return isOpen; }

void IoInputStreamItr::SetRandomSeed (  int  rSeed  )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 363 of file IoInputStreamItr.cxx. References fInputStreamManager, MSG, and PerInputStreamManager::SetRandomSeed(). { //====================================================================== // Set the random seet for the InputStreamManager //====================================================================== MSG("Io",Msg::kDebug) << "Set InputStreamManager random seed to " << rSeed << endl; fInputStreamManager.SetRandomSeed(rSeed); }

int IoInputStreamItr::SetSequenceMode (  const char *  stream, Per::ESequenceMode  sequencemode )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 242 of file IoInputStreamItr.cxx. References Per::AsString(), fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::SetSequenceMode(). { //====================================================================== // Set the sequence mode for named stream. Returns 0 if stream not // open, else 1. //====================================================================== int isOpen = 0; MSG("Io",Msg::kDebug) << "Set sequence mode " << Per::AsString(sequenceMode) << " for stream " << stream << endl; if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetSequenceMode(stream,sequenceMode); isOpen = 1; } return isOpen; }

int IoInputStreamItr::SetTestMode (  const char *  stream, bool  testmode )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 262 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerStreamManager::SetTestMode(). { //====================================================================== // Set the test mode for named stream. Returns 0 if stream not // open, else 1. //====================================================================== int isOpen = 0; std::string testModeStr = "false"; if ( testMode ) testModeStr = "true"; MSG("Io",Msg::kDebug) << "Set test mode " << testModeStr.c_str() << " for stream " << stream << endl; if ( std::string(stream) == "*" ) { fInputStreamManager.SetTestMode(stream,testMode); isOpen = 1; } else if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetTestMode(stream,testMode); isOpen = 1; } return isOpen; }

int IoInputStreamItr::SetWindow (  const char *  stream, double  lower, double  upper )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 288 of file IoInputStreamItr.cxx. References fInputStreamManager, PerInputStreamManager::GetOpenedStream(), MSG, and PerInputStreamManager::SetWindow(). { //====================================================================== //Set the window for named stream. Returns 0 if stream not open, else //1. //====================================================================== int isOpen = 0; MSG("Io",Msg::kDebug) << "Set window [" << lower << ", " << upper << "] for stream " << stream << endl; if ( fInputStreamManager.GetOpenedStream(stream) ) { fInputStreamManager.SetWindow(stream,lower,upper); isOpen = 1; } return isOpen; }

int IoInputStreamItr::Streams (  const char *  streamlist  )  [virtual]

Reimplemented from IoDataStreamItr. Definition at line 125 of file IoInputStreamItr.cxx. References PerInputStreamManager::CloseStream(), find(), fInputStreamManager, Per::GetAssociatedStreamList(), PerStreamManager::GetNumStream(), PerInputStreamManager::GetOpenedStream(), PerStreamManager::GetStreamMap(), MSG, PerInputStreamManager::OpenStream(), IoDataStreamItr::SetSourceName(), and UtilString::StringTok(). Referenced by IoInputStreamItr(). { //====================================================================== // Modify open streams to match those specified in streams. streams // is a delimiter separated list of streamnames. Returns number of // streams open. //====================================================================== this -> SetSourceName(streams); MSG("Io",Msg::kDebug) << "Set streams " << streams << endl; // parse delimiter separate streamlist into a vector of streamnames std::vector<std::string> streamlist; UtilString::StringTok(streamlist,std::string(streams),":,;/ "); std::vector<std::string>::iterator strItr; // Add streams not previously opened for ( strItr = streamlist.begin(); strItr != streamlist.end(); strItr++ ) { std::string streamname = *strItr; if ( !fInputStreamManager.GetOpenedStream(streamname) ) { fInputStreamManager.OpenStream(streamname,streamname); } } // Close streams not in requested list const PerStreamManager::StreamMap& smap = fInputStreamManager.GetStreamMap(); for ( PerStreamManager::StreamMapConstItr citr = smap.begin(); citr!= smap.end(); ++citr ) { std::string streamname = citr->first; typedef std::vector<std::string>::const_iterator vs_citer; vs_citer vpos = std::find(streamlist.begin(),streamlist.end(),streamname); if ( vpos == streamlist.end() ) { fInputStreamManager.CloseStream(streamname); } } // Open streams associated with those in requested list. Since assocated // streams may in turn have associated streams, this is done as a while // loop until no more streams are added bool isNewStream = true; while ( isNewStream ) { isNewStream = false; for ( PerStreamManager::StreamMapConstItr citr = smap.begin(); citr!= smap.end(); ++citr ) { std::string streamname = citr->first; std::string assocstreams = Per::GetAssociatedStreamList(streamname.c_str()); if ( !assocstreams.empty() ) { // parse delimiter separated streamlist into a vector of streamnames std::vector<std::string> assocstreamlist; UtilString::StringTok(assocstreamlist, std::string(assocstreams),":,;/ "); std::vector<std::string>::iterator astrItr; // Add associated streams not previously opened for ( astrItr = assocstreamlist.begin(); astrItr!= assocstreamlist.end(); astrItr++ ) { std::string assocstreamname = *astrItr; if ( !fInputStreamManager.GetOpenedStream(assocstreamname) ) { fInputStreamManager.OpenStream(assocstreamname,assocstreamname); isNewStream = true; } } } } } return fInputStreamManager.GetNumStream(); }

---

Member Data Documentation

PerInputStreamManager IoInputStreamItr::fInputStreamManager [private]

Definition at line 63 of file IoInputStreamItr.h. Referenced by AddFile(), Decrement(), DefineStream(), GetCurrentFile(), GoTo(), GoToEOF(), GoToFile(), Increment(), ListFile(), LoadRecords(), NextFile(), PrevFile(), RemoveFile(), Select(), SetMaxFileRepeat(), SetMeanMom(), SetPerOwnedDisabled(), SetPushRandom(), SetRandomSeed(), SetSequenceMode(), SetTestMode(), SetWindow(), Streams(), and ~IoInputStreamItr().

bool IoInputStreamItr::fIsValid [private]

Definition at line 64 of file IoInputStreamItr.h.

---

The documentation for this class was generated from the following files:

• IoInputStreamItr.h
• IoInputStreamItr.cxx

---