#include <fReadXRootD.h>

Inheritance diagram for fReadXRootD:

Collaboration diagram for fReadXRootD:

Public Member Functions
	fReadXRootD ()
	~fReadXRootD ()
bool	isOpen ()
bool	isEoF ()
bool	fileExists (std::string fName) const
void	openFile (std::string fName)
void	closeFile ()
void	readData (char *buffer, unsigned int sizeBytes)
int64_t	getPosition ()
void	setPosition (int64_t p)
void	setPositionFromEnd (int64_t p)
fRead *	newReader () const

Private Attributes
int	m_pfd

Detailed Description

Definition at line 10 of file fReadXRootD.h.

Constructor & Destructor Documentation

◆ fReadXRootD()

fReadXRootD::fReadXRootD ( )

Definition at line 21 of file fReadXRootD.cxx.

{
  m_pfd = 0;
}

◆ ~fReadXRootD()

fReadXRootD::~fReadXRootD ( )

Definition at line 26 of file fReadXRootD.cxx.

{
  this->closeFile();
}

Member Function Documentation

◆ closeFile()

void fReadXRootD::closeFile ( )

Definition at line 58 of file fReadXRootD.cxx.

{
  if(m_pfd != 0) XrdPosixXrootd::Close(m_pfd);
  m_pfd = 0;
}

◆ fileExists()

bool fReadXRootD::fileExists ( std::string fName ) const

Definition at line 43 of file fReadXRootD.cxx.

{
  int pfd = XrdPosixXrootd::Open(fName.c_str(), O_RDONLY);
  if(pfd == 0) return false;
  XrdPosixXrootd::Close(pfd);
  return true;
}

◆ getPosition()

int64_t fReadXRootD::getPosition ( )

Definition at line 88 of file fReadXRootD.cxx.

{
  if(this->isOpen()) return  XrdPosixXrootd::Lseek(m_pfd, 0, SEEK_CUR);
  return -1;
}

◆ isEoF()

bool fReadXRootD::isEoF ( )

Definition at line 36 of file fReadXRootD.cxx.

{
//xrd eof??
  return false;
}

◆ isOpen()

bool fReadXRootD::isOpen ( )

Definition at line 31 of file fReadXRootD.cxx.

{
  return m_pfd != 0;
}

◆ newReader()

fRead * fReadXRootD::newReader ( ) const

Definition at line 104 of file fReadXRootD.cxx.

{
  fReadXRootD * nfr = new fReadXRootD();
  return nfr;
}

◆ openFile()

void fReadXRootD::openFile ( std::string fName )

Definition at line 52 of file fReadXRootD.cxx.

{
  if(this->isOpen()) this->closeFile();
  m_pfd = XrdPosixXrootd::Open(fName.c_str(), O_RDONLY);
}

◆ readData()

void fReadXRootD::readData	(	char *	buffer,
		unsigned int	sizeBytes )

Definition at line 64 of file fReadXRootD.cxx.

{
  if (sizeBytes==0) return;
  if(this->isOpen())
  {
    unsigned int totalRead=0,ntry=0;
    while(sizeBytes > totalRead)
    {
      int ret = XrdPosixXrootd::Read(m_pfd,buffer,sizeBytes);
      totalRead += ret; ++ntry;
      if(ntry>5) {
        std::stringstream mystream;
        mystream << "Problem reading from the data file. "
                    <<"fReadXRootD::readData asked to read "<<sizeBytes
                    <<" bytes and managed to read only "<<totalRead
                    <<" bytes.";
        EventStorage::ReadingIssue ci(ERS_HERE, mystream.str().c_str());
        ers::warning(ci);
        return;
      }
    }
  }
}

◆ setPosition()

void fReadXRootD::setPosition ( int64_t p )

Definition at line 94 of file fReadXRootD.cxx.

{
  if(this->isOpen()) XrdPosixXrootd::Lseek(m_pfd, (long long)p, SEEK_SET);
}

◆ setPositionFromEnd()

void fReadXRootD::setPositionFromEnd ( int64_t p )

Definition at line 99 of file fReadXRootD.cxx.

{
  if(this->isOpen()) XrdPosixXrootd::Lseek(m_pfd, (long long)p, SEEK_END);
}

Member Data Documentation

◆ m_pfd

int fReadXRootD::m_pfd

private

Definition at line 28 of file fReadXRootD.h.

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

Public Member Functions

Private Attributes