LSSTApplications  8.0.0.0+107,8.0.0.1+13,9.1+18,9.2,master-g084aeec0a4,master-g0aced2eed8+6,master-g15627eb03c,master-g28afc54ef9,master-g3391ba5ea0,master-g3d0fb8ae5f,master-g4432ae2e89+36,master-g5c3c32f3ec+17,master-g60f1e072bb+1,master-g6a3ac32d1b,master-g76a88a4307+1,master-g7bce1f4e06+57,master-g8ff4092549+31,master-g98e65bf68e,master-ga6b77976b1+53,master-gae20e2b580+3,master-gb584cd3397+53,master-gc5448b162b+1,master-gc54cf9771d,master-gc69578ece6+1,master-gcbf758c456+22,master-gcec1da163f+63,master-gcf15f11bcc,master-gd167108223,master-gf44c96c709
LSSTDataManagementBasePackage
Public Member Functions | Private Member Functions | Private Attributes | List of all members
lsst::ap::io::SequentialFileReader Class Reference

A sequential reader for uncompressed files. Uses standard (blocking) IO calls. More...

#include <FileIo.h>

Inheritance diagram for lsst::ap::io::SequentialFileReader:
lsst::ap::io::SequentialReader lsst::ap::io::SequentialIoBase

Public Member Functions

 SequentialFileReader (std::string const &fileName)
 
virtual ~SequentialFileReader ()
 
virtual std::size_t read (unsigned char *const buf, std::size_t const size)
 
- Public Member Functions inherited from lsst::ap::io::SequentialIoBase
 SequentialIoBase ()
 
virtual ~SequentialIoBase ()=0
 
bool finished () const
 Returns true if there are no more bytes available for reading. More...
 
bool failed () const
 Returns true if a read operation failed. More...
 
State getState () const
 Returns the state of the SequentialReader. More...
 

Private Member Functions

void cleanup ()
 
void cleanup (State const state)
 

Private Attributes

int _fd
 

Additional Inherited Members

- Public Types inherited from lsst::ap::io::SequentialIoBase
enum  State { IN_PROGRESS = 0, FINISHED, FAILED }
 
- Protected Attributes inherited from lsst::ap::io::SequentialIoBase
State _state
 

Detailed Description

A sequential reader for uncompressed files. Uses standard (blocking) IO calls.

Definition at line 106 of file FileIo.h.

Constructor & Destructor Documentation

lsst::ap::io::SequentialFileReader::SequentialFileReader ( std::string const &  fileName)
explicit

Definition at line 90 of file FileIo.cc.

92  :
93  _fd(-1)
94 {
95  int const fd = openFile(fileName, false, O_RDONLY);
96  if (fd == -1) {
97  _state = FINISHED;
98  return;
99  }
100  _fd = fd;
101 }
lsst::ap::io::SequentialFileReader::~SequentialFileReader ( )
virtual

Definition at line 104 of file FileIo.cc.

Member Function Documentation

void lsst::ap::io::SequentialFileReader::cleanup ( )
private

Definition at line 107 of file FileIo.cc.

107  {
108  if (_fd != -1) {
109  ::close(_fd);
110  _fd = -1;
111  }
112 }
void lsst::ap::io::SequentialFileReader::cleanup ( State const  state)
inlineprivate

Definition at line 123 of file FileIo.h.

123  {
124  cleanup();
125  _state = state;
126  }
std::size_t lsst::ap::io::SequentialFileReader::read ( unsigned char *const  buf,
std::size_t const  len 
)
virtual

Reads up to len bytes from an underlying storage device into buf and returns the number of bytes actually read.

Implements lsst::ap::io::SequentialReader.

Definition at line 115 of file FileIo.cc.

118  {
119  if (len == 0) {
120  return 0;
121  }
122  if (buf == 0) {
123  throw LSST_EXCEPT(ex::InvalidParameterError,
124  "null pointer to read destination");
125  }
126  if (_state == FAILED) {
127  throw LSST_EXCEPT(ex::IoError,
128  "read() called on a failed SequentialFileReader");
129  } else if (_state == FINISHED) {
130  return 0;
131  }
132 
133  ::ssize_t n = ::read(_fd, buf, len);
134  if (n < 0) {
135  cleanup(FAILED);
136  throw LSST_EXCEPT(ex::IoError,
137  (boost::format("read() failed, errno: %1%") % errno).str());
138  } else if (n == 0) {
139  cleanup(FINISHED);
140  }
141  return static_cast<std::size_t>(n);
142 }
virtual std::size_t read(unsigned char *const buf, std::size_t const size)
Definition: FileIo.cc:115
#define LSST_EXCEPT(type,...)
Definition: Exception.h:46

Member Data Documentation

int lsst::ap::io::SequentialFileReader::_fd
private

Definition at line 120 of file FileIo.h.


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