---

StreamDQMInputFile Class Reference

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

List of all members.

Public Member Functions
const DQMEventMsgView *	currentRecord () const
	Moves the handler to next Event Record.
bool	next ()
	StreamDQMInputFile (const std::string &name)
	Reads a Streamer file.
	~StreamDQMInputFile ()
Private Member Functions
int	readDQMEventMessage ()
	Points to current Record.
Private Attributes
DQMEventMsgView *	currentEvMsg_
std::vector< char >	eventBuf_
std::auto_ptr< std::ifstream >	ist_

---

Detailed Description

Definition at line 10 of file StreamDQMInputFile.h.

---

Constructor & Destructor Documentation

StreamDQMInputFile::StreamDQMInputFile

(

const std::string &

name

)

[explicit]

Reads a Streamer file.

Definition at line 14 of file StreamDQMInputFile.cc.

References Exception, and ist_.

                                                           :
  currentEvMsg_(0),
  ist_(new ifstream(name.c_str())),
  eventBuf_(1000*1000*7)
{

  if (!ist_->is_open()) {
      throw cms::Exception("StreamDQMInputFile","StreamDQMInputFile")
        << "Error Opening Input File: " << name << "\n";
  }

}

StreamDQMInputFile::~StreamDQMInputFile

(

)

Definition at line 8 of file StreamDQMInputFile.cc.

References currentEvMsg_.

{
  //ist_->close();
  delete  currentEvMsg_;
}

---

Member Function Documentation

const DQMEventMsgView* StreamDQMInputFile::currentRecord

(

)

const [inline]

Moves the handler to next Event Record.

Definition at line 21 of file StreamDQMInputFile.h.

References currentEvMsg_.

{ return currentEvMsg_; }

bool StreamDQMInputFile::next

(

void

)

Definition at line 27 of file StreamDQMInputFile.cc.

{
  if (this->readDQMEventMessage()) {
       return true;
  }

  return false;
}

int StreamDQMInputFile::readDQMEventMessage

(

)

[private]

Points to current Record.

Definition at line 36 of file StreamDQMInputFile.cc.

References code, HeaderView::code(), currentEvMsg_, Header::DQM_EVENT, eventBuf_, ist_, NULL, and HeaderView::size().

                                            {

  uint32 last_pos = ist_->tellg();
  uint32 nWant = sizeof(HeaderView);

  ist_->read(&eventBuf_[0], nWant);

  if (ist_->eof() || static_cast<unsigned int>(ist_->gcount()) < nWant) {
        return 0;
  }  

  HeaderView head(&eventBuf_[0]);
  uint32 code = head.code();
  if (code != Header::DQM_EVENT)
    return 0;

  //This includes header
  uint32 eventSize = head.size();
  if (eventBuf_.size() < eventSize) eventBuf_.resize(eventSize);

  if (eventSize > sizeof(DQMEventMsgView)) {
    //Lets read the whole thing again
    nWant = eventSize;
    ist_->seekg(last_pos, std::ios::beg);
    ist_->read(&eventBuf_[0], nWant);
    if (ist_->eof() || static_cast<unsigned int>(ist_->gcount()) < nWant) {
        return 0;
    }
  }

  if (currentEvMsg_ != NULL) {delete currentEvMsg_;}
  currentEvMsg_ = new DQMEventMsgView((void*)&eventBuf_[0]);
  uint32 new_len = last_pos + eventSize; 
  ist_->seekg(new_len, std::ios::beg);
  return 1;
}

---

Member Data Documentation

DQMEventMsgView* StreamDQMInputFile::currentEvMsg_ [private]

Definition at line 28 of file StreamDQMInputFile.h.

Referenced by currentRecord(), readDQMEventMessage(), and ~StreamDQMInputFile().

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

Definition at line 30 of file StreamDQMInputFile.h.

Referenced by readDQMEventMessage().

std::auto_ptr<std::ifstream> StreamDQMInputFile::ist_ [private]

Definition at line 29 of file StreamDQMInputFile.h.

Referenced by readDQMEventMessage(), and StreamDQMInputFile().

---

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

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

---