---

StreamerInputIndexFile Class Reference

#include <IOPool/Streamer/interface/StreamerInputIndexFile.h>

List of all members.

Public Member Functions
const indexRecIter	begin ()
const indexRecIter	end ()
bool	eof ()
indexRecIter	sort ()
const StartIndexRecord *	startMessage () const
	StreamerInputIndexFile (const std::vector< std::string > &names)
	StreamerInputIndexFile (const std::string &name)
	Class for doing Index Read Operations.
	~StreamerInputIndexFile ()
Private Member Functions
int	readEventMessage ()
	Reads in Start Message.
void	readStartMessage ()
Private Attributes
bool	eof_
std::vector< char >	eventBuf_
uint64	eventBufPtr_
uint32	eventHeaderSize_
std::vector< char >	headerBuf_
std::vector< EventIndexRecord * >	indexes_
std::ifstream *	ist_
	Reads in next EventIndex Record.
StartIndexRecord *	startMsg_

---

Detailed Description

Definition at line 8 of file StreamerInputIndexFile.h.

---

Constructor & Destructor Documentation

StreamerInputIndexFile::StreamerInputIndexFile

(

const std::string &

name

)

[explicit]

Class for doing Index Read Operations.

Definition at line 21 of file StreamerInputIndexFile.cc.

References lat::endl(), FDEBUG, edm::errors::FileOpenError, ist_, readEventMessage(), and readStartMessage().

                                                                   :
  ist_(new std::ifstream(name.c_str(), std::ios_base::binary | std::ios_base::in)),
  startMsg_(0),
  eof_(false),
  eventBufPtr_(0),
  headerBuf_(1000*1000),
  eventBuf_(1000*1000*40),
  eventHeaderSize_(0),
  indexes_(0)
{

  FDEBUG(10) << "Opening Index file" << std::endl;
  if (!ist_->is_open()) {
       throw edm::Exception(errors::FileOpenError, "StreamerInputIndexFile::StreamerInputIndexFile")
          << "Error Opening Input File: "<< name<< "\n";
  } 
  readStartMessage();
  while (readEventMessage()) {
      ;
  }
  
  ist_->close();
  delete ist_;
}

StreamerInputIndexFile::StreamerInputIndexFile

(

const std::vector< std::string > &

names

)

[explicit]

Definition at line 47 of file StreamerInputIndexFile.cc.

References edm::errors::FileOpenError, i, in, ist_, readEventMessage(), and readStartMessage().

                                                                               :
  startMsg_(0),
  eof_(false),
  eventBufPtr_(0),
  headerBuf_(1000*1000),
  eventBuf_(1000*1000*40),
  eventHeaderSize_(0),
  indexes_(0)
{
   for (unsigned int i=0; i!=names.size(); ++i) 
   {
     ist_ = new std::ifstream(names.at(i).c_str(), std::ios_base::binary | std::ios_base::in);
     if (!ist_->is_open())
     {
       throw edm::Exception(errors::FileOpenError, "StreamerInputIndexFile::StreamerInputIndexFile")
          << "Error Opening Input File: "<< names.at(i) << "\n";
     }

       readStartMessage();
       while (readEventMessage()) {
       ;
       }
       ist_->close();
       delete ist_; 
   }
}

StreamerInputIndexFile::~StreamerInputIndexFile

(

)

Definition at line 12 of file StreamerInputIndexFile.cc.

References end(), it, and startMsg_.

{
  delete startMsg_; 

  for(indexRecIter it = this->begin(), itEnd = this->end(); it != itEnd; ++it) {
          delete (*it);
  }
}

---

Member Function Documentation

const indexRecIter StreamerInputIndexFile::begin

(

void

)

[inline]

Definition at line 21 of file StreamerInputIndexFile.h.

References indexes_.

Referenced by sort().

{ return indexes_.begin(); }

const indexRecIter StreamerInputIndexFile::end

(

void

)

[inline]

Definition at line 22 of file StreamerInputIndexFile.h.

References indexes_.

Referenced by ~StreamerInputIndexFile().

{ return indexes_.end(); }

bool StreamerInputIndexFile::eof

(

void

)

[inline]

Definition at line 19 of file StreamerInputIndexFile.h.

References eof_.

{return eof_; }

int StreamerInputIndexFile::readEventMessage

(

)

[private]

Reads in Start Message.

Not an event message should return

Definition at line 123 of file StreamerInputIndexFile.cc.

References code, HeaderView::code(), lat::endl(), eof_, Header::EVENT, eventBuf_, eventBufPtr_, eventHeaderSize_, Exception, FDEBUG, edm::errors::FileReadError, indexes_, ist_, EventIndexRecord::makeEvent(), and EventIndexRecord::makeOffset().

Referenced by StreamerInputIndexFile().

                                              {
  std::streampos last_pos = ist_->tellg();
  uint32 bufPtr = eventBufPtr_;
  //uint32 bufPtr = eventBufPtr_+1;

  //ist_->clear();
  if (eventBuf_.size() < bufPtr + sizeof(HeaderView)) {
    throw edm::Exception(errors::FileReadError, "StreamerInputFile::readEventMessage")
      << "eventBuf array is about to overflow, just before first read.\n";
  }
  ist_->read((char*)&eventBuf_[bufPtr], sizeof(HeaderView));

  if (ist_->eof() || static_cast<unsigned int>(ist_->gcount()) < sizeof(HeaderView))
  {      
        eof_ = true;
        return 0;
  }

  HeaderView head_(&eventBuf_[bufPtr]);
  uint32 code = head_.code();

  if (code != Header::EVENT) 
     {
     FDEBUG(10) << "Not an event Message "<< std::endl;
     return 0;
     }

  //Bring the pointer at last position, start of event msg
  //ist_->clear();
  ist_->seekg(last_pos);
  
  if (eventBuf_.size() < bufPtr + eventHeaderSize_ + sizeof(uint64)) {
    throw cms::Exception("readEventMessage","StreamerInputFile")
      << "eventBuf array is about to overflow, just before second read.\n";
  }
  ist_->read((char*)&eventBuf_[bufPtr], eventHeaderSize_+sizeof(uint64));
  if (ist_->eof()) {
     eof_= true;
     return 0;
  }

  EventIndexRecord* currentEvMsg = new EventIndexRecord();
  //EventIndexRecord currentEvMsg;
  currentEvMsg->makeEvent((void*)&eventBuf_[bufPtr]);

  uint32 offset_loc = bufPtr + eventHeaderSize_;
   
  currentEvMsg->makeOffset(&eventBuf_[offset_loc]);

  indexes_.push_back(currentEvMsg);

  //This Brings the pointer to end of this Event Msg.
  std::streamoff new_len = eventHeaderSize_ + sizeof(uint64); 

  //How many bytes have read so far
  eventBufPtr_ +=  eventHeaderSize_ + sizeof(uint64);

  //This should be the proper position of the file pointer
  ist_->seekg(last_pos + new_len);
  return 1;
}

void StreamerInputIndexFile::readStartMessage

(

)

[private]

Definition at line 74 of file StreamerInputIndexFile.cc.

References code, HeaderView::code(), eventHeaderSize_, edm::errors::FileReadError, StartIndexRecord::getInit(), headerBuf_, Header::INIT, ist_, StartIndexRecord::makeHeader(), StartIndexRecord::makeInit(), HeaderView::size(), and startMsg_.

Referenced by StreamerInputIndexFile().

                                              {
  //Read magic+reserved fileds at the start of file 
  //ist_->clear();
  ist_->read((char*)&headerBuf_[0], sizeof(StartIndexRecordHeader));
  if (ist_->eof() || static_cast<unsigned int>(ist_->gcount()) < sizeof(StartIndexRecordHeader)) {
        return;
   }  
  //Read Header from the start of init message to find the size
  ist_->read((char*)&headerBuf_[sizeof(StartIndexRecordHeader)], sizeof(HeaderView));
  if (ist_->eof() || static_cast<unsigned int>(ist_->gcount()) < sizeof(HeaderView))
  {
        throw edm::Exception(errors::FileReadError, "StreamerInputFile::readStartMessage")
              << "Empty file encountered\n";
  }

  HeaderView head(&headerBuf_[sizeof(StartIndexRecordHeader)]);
  uint32 code = head.code();
  if (code != Header::INIT) // ** Not an init message should return ****** /
  {
    throw edm::Exception(errors::FileReadError, "StreamerInputFile::readStartMessage")
              << "Expecting an init Message at start of file\n";
    return;
  }
  uint32 headerSize = head.size();
  //Bring the pointer at start of Start Message (Starts after file header magic+reserved)
  ist_->seekg(sizeof(StartIndexRecordHeader), std::ios::beg);
  if (headerBuf_.size() < (sizeof(StartIndexRecordHeader) + headerSize))
    headerBuf_.resize(sizeof(StartIndexRecordHeader) + headerSize);
  ist_->read((char*)&headerBuf_[sizeof(StartIndexRecordHeader)], headerSize);
 
  delete startMsg_;
   
  startMsg_ = new StartIndexRecord();
  startMsg_->makeHeader(&headerBuf_[0]);
  //Init msg lies just after StartIndexRecordHeader
  startMsg_->makeInit(&headerBuf_[sizeof(StartIndexRecordHeader)]);
   
  //   As the size of index record is unknown as of yet the 
  //   ist_ can over run, so it may have reached EOF
  //   it needs to be reset, before its positioned correctly.

  ist_->clear();
  //Bring ist_ at the end of record
  headerSize = (startMsg_->getInit())->headerSize(); 
  ist_->seekg(sizeof(StartIndexRecordHeader)+headerSize, std::ios::beg);

  eventHeaderSize_ = (startMsg_->getInit())->eventHeaderSize();
}

indexRecIter StreamerInputIndexFile::sort

(

)

Definition at line 203 of file StreamerInputIndexFile.cc.

References begin(), header_event_sorter(), header_run_sorter(), and edm::sort_all().

                                          {
  //Run sorting is required ?? 
  sort_all(*this, header_run_sorter);
  sort_all(*this, header_event_sorter);
  return this->begin();
}

const StartIndexRecord* StreamerInputIndexFile::startMessage

(

)

const [inline]

Definition at line 17 of file StreamerInputIndexFile.h.

References startMsg_.

{ return startMsg_; }

---

Member Data Documentation

bool StreamerInputIndexFile::eof_ [private]

Definition at line 34 of file StreamerInputIndexFile.h.

Referenced by eof(), and readEventMessage().

std::vector<char> StreamerInputIndexFile::eventBuf_ [private]

Definition at line 39 of file StreamerInputIndexFile.h.

Referenced by readEventMessage().

uint64 StreamerInputIndexFile::eventBufPtr_ [private]

Definition at line 36 of file StreamerInputIndexFile.h.

Referenced by readEventMessage().

uint32 StreamerInputIndexFile::eventHeaderSize_ [private]

Definition at line 40 of file StreamerInputIndexFile.h.

Referenced by readEventMessage(), and readStartMessage().

std::vector<char> StreamerInputIndexFile::headerBuf_ [private]

Definition at line 38 of file StreamerInputIndexFile.h.

Referenced by readStartMessage().

std::vector<EventIndexRecord*> StreamerInputIndexFile::indexes_ [private]

Definition at line 42 of file StreamerInputIndexFile.h.

Referenced by begin(), end(), and readEventMessage().

std::ifstream* StreamerInputIndexFile::ist_ [private]

Reads in next EventIndex Record.

Definition at line 30 of file StreamerInputIndexFile.h.

Referenced by readEventMessage(), readStartMessage(), and StreamerInputIndexFile().

StartIndexRecord* StreamerInputIndexFile::startMsg_ [private]

Definition at line 32 of file StreamerInputIndexFile.h.

Referenced by readStartMessage(), startMessage(), and ~StreamerInputIndexFile().

---

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

• IOPool/Streamer/interface/StreamerInputIndexFile.h
• IOPool/Streamer/src/StreamerInputIndexFile.cc

---