fReadDavix Class Reference

#include <fReadDavix.h>

Inheritance diagram for fReadDavix:

Collaboration diagram for fReadDavix:

Public Member Functions
	fReadDavix ()
	~fReadDavix ()
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
int64_t	m_offset
Davix::Context	m_c
Davix::RequestParams *	m_davixParam
Davix::DavixError *	m_err
Davix::DavPosix *m_pos	ATLAS_THREAD_SAFE
Davix::X509Credential *	m_cert
DAVIX_FD *	m_fd

Detailed Description

Definition at line 12 of file fReadDavix.h.

Constructor & Destructor Documentation

fReadDavix()

fReadDavix::fReadDavix

(

)

Definition at line 33 of file fReadDavix.cxx.

{
  m_pfd = 0;
  m_offset = 0;
  m_fd = nullptr;
 
  m_davixParam = new Davix::RequestParams();
  m_err = NULL;
  m_pos = new Davix::DavPosix(&m_c);
  //m_pos = &m_c;
 
 
  // enableGridMode
  const char *env_var = NULL;
  if( ( env_var = std::getenv("X509_CERT_DIR")) == NULL){
    env_var = "/etc/grid-security/certificates/";
  }
  m_davixParam->addCertificateAuthorityPath(env_var);
  m_davixParam->setTransparentRedirectionSupport(true);
  m_cert = new Davix::X509Credential();
  m_davixParam->setClientCertCallbackX509(&TDavixFile_http_authn_cert_X509, NULL);
 
}

~fReadDavix()

fReadDavix::~fReadDavix

(

)

Definition at line 57 of file fReadDavix.cxx.

{
  this->closeFile();
}

Member Function Documentation

closeFile()

void fReadDavix::closeFile

(

)

Definition at line 92 of file fReadDavix.cxx.

{
  if(m_pfd != 0) m_pos->close(m_fd, &m_err);
  m_pfd = 0;
}

fileExists()

bool fReadDavix::fileExists

(

std::string

fName

)

const

Definition at line 74 of file fReadDavix.cxx.

{
  Davix::DavixError* err2 = NULL;
  DAVIX_FD* pfd = m_pos->open(m_davixParam, fName.c_str(), O_RDONLY, &err2);
  if(pfd == 0) return false;
  m_pos->close(pfd, &err2);
  return true;
}

getPosition()

int64_t fReadDavix::getPosition

(

)

Definition at line 132 of file fReadDavix.cxx.

{
  if(this->isOpen()) return m_offset;
 
  return -1;
}

isEoF()

bool fReadDavix::isEoF

(

)

Definition at line 67 of file fReadDavix.cxx.

{
 
  return false;
}

isOpen()

bool fReadDavix::isOpen

(

)

Definition at line 62 of file fReadDavix.cxx.

{
  return m_pfd != 0;
}

newReader()

fRead * fReadDavix::newReader

(

)

const

Definition at line 153 of file fReadDavix.cxx.

{
  fReadDavix * nfr = new fReadDavix();
  return (fRead *)nfr;
}

openFile()

void fReadDavix::openFile

(

std::string

fName

)

Definition at line 84 of file fReadDavix.cxx.

{
  if(this->isOpen()) this->closeFile();
  m_fd = m_pos->open(m_davixParam, fName.c_str(), O_RDONLY, &m_err);
  m_offset = 0;
  m_pfd = 1;
}

readData()

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

Definition at line 98 of file fReadDavix.cxx.

{
  if (sizeBytes==0) return;
  if(this->isOpen())
  {
    unsigned int totalRead=0,ntry=0;
    while(sizeBytes > totalRead)
    {
      ssize_t ret = m_pos->pread(m_fd, buffer, sizeBytes, m_offset, &m_err);
      if (ret < 0) {
        std::stringstream mystream;
    mystream << "fReadDavix::readData: can not read data with davix " << m_err->getErrMsg().c_str() << " "  << m_err->getStatus();
    Davix::DavixError::clearError(&m_err);
        EventStorage::ReadingIssue ci(ERS_HERE, mystream.str().c_str());
        ers::warning(ci);
        return;
      } else {
    m_offset += ret;
      }
      totalRead += ret; ++ntry;
      if(ntry>5) {
        std::stringstream mystream;
        mystream << "Problem reading from the data file. "
                    <<"fReadDavix::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 fReadDavix::setPosition

(

int64_t

p

)

Definition at line 139 of file fReadDavix.cxx.

{
  if(this->isOpen()) m_offset = p;
}

setPositionFromEnd()

void fReadDavix::setPositionFromEnd

(

int64_t

p

)

Definition at line 144 of file fReadDavix.cxx.

{
  dav_off_t ret;
  if(this->isOpen()) {
    ret = m_pos->lseek64(m_fd, p, SEEK_END, &m_err);
    m_offset = ret;
  }
}

Member Data Documentation

ATLAS_THREAD_SAFE

Davix::DavPosix* m_pos fReadDavix::ATLAS_THREAD_SAFE

private

Definition at line 35 of file fReadDavix.h.

m_c

Davix::Context fReadDavix::m_c

private

Definition at line 32 of file fReadDavix.h.

m_cert

Davix::X509Credential* fReadDavix::m_cert

private

Definition at line 36 of file fReadDavix.h.

m_davixParam

Davix::RequestParams* fReadDavix::m_davixParam

private

Definition at line 33 of file fReadDavix.h.

m_err

Davix::DavixError* fReadDavix::m_err

private

Definition at line 34 of file fReadDavix.h.

m_fd

DAVIX_FD* fReadDavix::m_fd

private

Definition at line 37 of file fReadDavix.h.

m_offset

int64_t fReadDavix::m_offset

private

Definition at line 31 of file fReadDavix.h.

m_pfd

int fReadDavix::m_pfd

private

Definition at line 30 of file fReadDavix.h.

---

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

• fReadDavix.h
• fReadDavix.cxx