OffsetFileInputImpl Class Reference

Inheritance diagram for OffsetFileInputImpl:

Collaboration diagram for OffsetFileInputImpl:

Public Member Functions
bool	Seek (size_t offset)
virtual bool	Open (const std::string &rxfilename, bool binary)
virtual std::istream &	Stream ()
virtual int32	Close ()
virtual InputType	MyType ()
virtual	~OffsetFileInputImpl ()
Public Member Functions inherited from InputImplBase
virtual	~InputImplBase ()

Static Public Member Functions
static void	SplitFilename (const std::string &rxfilename, std::string *filename, size_t *offset)

Private Attributes
std::string	filename_
bool	binary_
std::ifstream	is_

Detailed Description

Definition at line 556 of file kaldi-io.cc.

Constructor & Destructor Documentation

~OffsetFileInputImpl()

virtual ~OffsetFileInputImpl ( )

inlinevirtual

Definition at line 654 of file kaldi-io.cc.

                                 {
    // Stream will automatically be closed, and we don't care about
    // whether it fails.
  }

Member Function Documentation

Close()

virtual int32 Close ( )

inlinevirtual

Implements InputImplBase.

Definition at line 643 of file kaldi-io.cc.

References KALDI_ERR.

                        {
    if (!is_.is_open())
      KALDI_ERR << "FileInputImpl::Close(), file is not open.";
    // I believe this error can only arise from coding error.
    is_.close();
    // Don't check status.
    return 0;
  }

MyType()

virtual InputType MyType ( )

inlinevirtual

Implements InputImplBase.

Definition at line 652 of file kaldi-io.cc.

References kaldi::kOffsetFileInput.

{ return kOffsetFileInput; }

Open()

virtual bool Open ( const std::string &  rxfilename, bool  binary  )

inlinevirtual

Implements InputImplBase.

Definition at line 602 of file kaldi-io.cc.

References MapOsPath.

                                                              {
    if (is_.is_open()) {
      // We are opening when we have an already-open file.
      // We may have to seek within this file, or else close it and
      // open a different one.
      std::string tmp_filename;
      size_t offset;
      SplitFilename(rxfilename, &tmp_filename, &offset);
      if (tmp_filename == filename_ && binary == binary_) {  // Just seek
        is_.clear();  // clear fail bit, etc.
        return Seek(offset);
      } else {
        is_.close();  // don't bother checking error status of is_.
        filename_ = tmp_filename;
        is_.open(MapOsPath(filename_).c_str(),
                 binary ? std::ios_base::in | std::ios_base::binary
                        : std::ios_base::in);
        if (!is_.is_open()) return false;
        else
          return Seek(offset);
      }
    } else {
      size_t offset;
      SplitFilename(rxfilename, &filename_, &offset);
      binary_ = binary;
      is_.open(MapOsPath(filename_).c_str(),
                binary ? std::ios_base::in | std::ios_base::binary
                      : std::ios_base::in);
      if (!is_.is_open()) return false;
      else
        return Seek(offset);
    }
  }

Seek()

bool Seek ( size_t  offset )

inline

Definition at line 578 of file kaldi-io.cc.

References rnnlm::i.

                           {
    size_t cur_pos = is_.tellg();
    if (cur_pos == offset) return true;
    else if (cur_pos<offset && cur_pos+100 > offset) {
      // We're close enough that it may be faster to just
      // read that data, rather than seek.
      for (size_t i = cur_pos; i < offset; i++)
        is_.get();
      return (is_.tellg() == std::streampos(offset));
    }
    // Try to actually seek.
    is_.seekg(offset, std::ios_base::beg);
    if (is_.fail()) {  // failbit or badbit is set [error happened]
      is_.close();
      return false;  // failure.
    } else {
      is_.clear();  // Clear any failure bits (e.g. eof).
      return true;  // success.
    }
  }

SplitFilename()

static void SplitFilename ( const std::string &  rxfilename, std::string *  filename, size_t *  offset  )

inlinestatic

Definition at line 562 of file kaldi-io.cc.

References kaldi::ConvertStringToInteger(), KALDI_ASSERT, and KALDI_ERR.

                                            {
    size_t pos = rxfilename.find_last_of(':');
    KALDI_ASSERT(pos != std::string::npos);  // would indicate error in calling
    // code, as the filename is supposed to be of the correct form at this
    // point.
    *filename = std::string(rxfilename, 0, pos);
    std::string number(rxfilename, pos+1);
    bool ans = ConvertStringToInteger(number, offset);
    if (!ans)
      KALDI_ERR << "Cannot get offset from filename " << rxfilename
                << " (possibly you compiled in 32-bit and have a >32-bit"
                << " byte offset into a file; you'll have to compile 64-bit.";
  }

Stream()

virtual std::istream& Stream ( )

inlinevirtual

Implements InputImplBase.

Definition at line 636 of file kaldi-io.cc.

References KALDI_ERR.

                               {
    if (!is_.is_open())
      KALDI_ERR << "FileInputImpl::Stream(), file is not open.";
    // I believe this error can only arise from coding error.
    return is_;
  }

Member Data Documentation

binary_

bool binary_

private

Definition at line 660 of file kaldi-io.cc.

filename_

std::string filename_

private

Definition at line 659 of file kaldi-io.cc.

is_

std::ifstream is_

private

Definition at line 661 of file kaldi-io.cc.

---

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

• util/kaldi-io.cc