In This Package:

RRawStream Class Reference

#include <RRawStream.h>

Inheritance diagram for RRawStream:

[legend]Collaboration diagram for RRawStream:[legend]List of all members.

Public Member Functions
	RRawStream ()
	RRawStream (const char *filename)
virtual	~RRawStream ()
void	close ()
	ifstream-like
void	open (const char *filename)
bool	is_open () const
bool	good () const
bool	operator! () const
	Not operator. !stream returns true if in bad/failed state.
RRawStream &	read (char *s, int n)
RRawStream &	ignore (int n=1)
Private Attributes
TFile *	m_file
TTree *	m_tree
Int32	m_buffer [50000]
Int32	m_size
Int32	m_currentEntry
Int32	m_currentPosi
bool	m_entryEnd

---

Detailed Description

Definition at line 26 of file RRawStream.h.

---

Constructor & Destructor Documentation

RRawStream::RRawStream

(

)

Definition at line 24 of file RRawStream.cc.

                      :
  m_file(0),m_tree(0),m_size(0),
  m_currentEntry(-1),m_currentPosi(0),m_entryEnd(true)
{
  sanity();
}

RRawStream::RRawStream

(

const char *

filename

)

Definition at line 31 of file RRawStream.cc.

                                            :
  m_file(0),m_tree(0),m_size(0),
  m_currentEntry(-1),m_currentPosi(0),m_entryEnd(true)
{
  sanity();
  this->open(filename);
}

RRawStream::~RRawStream

(

)

[virtual]

Definition at line 39 of file RRawStream.cc.

{
  this->close();
}

---

Member Function Documentation

void RRawStream::close

(

)

[virtual]

ifstream-like

Implements IInputStream.

Definition at line 44 of file RRawStream.cc.

{
  if(!m_file) return;

  m_file->Close();
  delete m_file;
  m_file=0;

}

void RRawStream::open

(

const char *

filename

)

[virtual]

Implements IInputStream.

Definition at line 54 of file RRawStream.cc.

{
  // open a file
  m_file = TFile::Open( filename, "READ" );
  if(!m_file)  {
    cout<<"RRawStream::Failed to open "<<filename<<endl;
    abort();
  }
  if( !(m_file->IsOpen()) )  {
    cout<<"RRawStream::Failed to open "<<filename<<endl;
    abort();
  }

  // get the tree
  m_tree = (TTree*)m_file->Get("RRawTree");
  if(!m_tree)  {
    cout<<"RRawStream::Failed to get TTree RRawTree"<<endl;
    abort();
  }

  // set branch address
  m_tree->SetBranchAddress("size",&m_size);
  m_tree->SetBranchAddress("buffer",m_buffer);
    
  // reset current entry number to -1
  m_currentEntry=-1;
        
  // reset reading status of current entry
  m_currentPosi=0;
  m_entryEnd=true;
}

bool RRawStream::is_open

(

)

const [virtual]

Implements IInputStream.

Definition at line 86 of file RRawStream.cc.

{
  if(!m_file) 
    return false;
  else
    return m_file->IsOpen();
}

bool RRawStream::good

(

)

const [virtual]

Implements IInputStream.

Definition at line 94 of file RRawStream.cc.

{
  if (!is_open()) return false;
  return !m_file->IsZombie();
}

bool RRawStream::operator!

(

)

const [virtual]

Not operator. !stream returns true if in bad/failed state.

Implements IInputStream.

Definition at line 101 of file RRawStream.cc.

{
  if (!this->is_open()) return true;
  return !good();
}

RRawStream & RRawStream::read	(	char *	s,
		int	n
	)			[virtual]

Implements IInputStream.

Definition at line 107 of file RRawStream.cc.

{
  // Need to handle the case of reaching to the end of one entry
  if(m_entryEnd) {
    m_currentEntry++;
    m_tree->GetEntry(m_currentEntry);
    m_entryEnd=false;
    m_currentPosi = 0;

    /*
    cout<<"RRawStream::New Entry "<<m_size<<endl;
    for(int i=0;i<m_size;i++) {
      cout<<(unsigned int)m_buffer[i]<<" ";
    }
    cout<<endl;
    */
  }

  if( m_currentPosi+n <= m_size * 4 )  {
    memcpy(s, (char*)(m_buffer) + m_currentPosi, n);
    m_currentPosi+=n;
  }  else  {
    cout<<"RRawStream::Asking data over one root entry boundary"<<endl;
    abort();
  }

  // Mark the end
  if(m_currentPosi == m_size * 4 ) {
    m_entryEnd = true;
  }

  return *this;
}

RRawStream & RRawStream::ignore

(

int

n = 1

)

[virtual]

Implements IInputStream.

Definition at line 141 of file RRawStream.cc.

{
  // The same as read(...), just without memcpy
  
  // Need to handle the case of reaching to the end of one entry
  if(m_entryEnd) {
    m_currentEntry++;
    m_tree->GetEntry(m_currentEntry);
    m_entryEnd=false;
    m_currentPosi = 0;

    /*
    cout<<"RRawStream::New Entry "<<m_size<<endl;
    for(int i=0;i<m_size;i++) {
      cout<<(unsigned int)m_buffer[i]<<" ";
    }
    cout<<endl;
    */
  }

  m_currentPosi+=n;

  // Mark the end
  if(m_currentPosi == m_size * 4 ) {
    m_entryEnd = true;
  }

  return *this;
}

---

Member Data Documentation

TFile* RRawStream::m_file [private]

Definition at line 46 of file RRawStream.h.

TTree* RRawStream::m_tree [private]

Definition at line 47 of file RRawStream.h.

Int32 RRawStream::m_buffer[50000] [private]

Definition at line 49 of file RRawStream.h.

Int32 RRawStream::m_size [private]

Definition at line 50 of file RRawStream.h.

Int32 RRawStream::m_currentEntry [private]

Definition at line 53 of file RRawStream.h.

Int32 RRawStream::m_currentPosi [private]

Definition at line 56 of file RRawStream.h.

bool RRawStream::m_entryEnd [private]

Definition at line 59 of file RRawStream.h.

---

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

• /home/dayabay/installs/trunk_2011_04_11_opt/NuWa-trunk/dybgaudi/DataModel/RawData/RawData/RRawStream.h
• /home/dayabay/installs/trunk_2011_04_11_opt/NuWa-trunk/dybgaudi/DataModel/RawData/src/RRawStream.cc

---