PipeInputImpl Class Reference

Inheritance diagram for PipeInputImpl:

Collaboration diagram for PipeInputImpl:

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

Private Attributes
std::string	filename_
FILE *	f_
PipebufType *	fb_
std::istream *	is_

Detailed Description

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

Constructor & Destructor Documentation

PipeInputImpl()

PipeInputImpl ( )

inline

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

: f_(NULL), is_(NULL) { }

~PipeInputImpl()

virtual ~PipeInputImpl ( )

inlinevirtual

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

References OutputImplBase::Close().

                           {
    if (is_)
      Close();
  }

Member Function Documentation

Close()

virtual int32 Close ( )

inlinevirtual

Implements InputImplBase.

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

References KALDI_ERR, and KALDI_WARN.

                        {
    if (is_ == NULL)
      KALDI_ERR << "PipeInputImpl::Close(), file is not open.";
    delete is_;
    is_ = NULL;
    int32 status;
#ifdef _MSC_VER
    status = _pclose(f_);
#else
    status = pclose(f_);
#endif
    if (status)
      KALDI_WARN << "Pipe " << filename_ << " had nonzero return status "
                 << status;
    f_ = NULL;
#ifndef _MSC_VER
    delete fb_;
    fb_ = NULL;
#endif
    return status;
  }

MyType()

virtual InputType MyType ( )

inlinevirtual

Implements InputImplBase.

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

References kaldi::kPipeInput.

{ return kPipeInput; }

Open()

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

inlinevirtual

Implements InputImplBase.

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

References KALDI_ASSERT, KALDI_WARN, and kaldi::PrintableRxfilename().

                                                              {
    filename_ = rxfilename;
    KALDI_ASSERT(f_ == NULL);  // Make sure closed.
    KALDI_ASSERT(rxfilename.length() != 0 &&
           rxfilename[rxfilename.length()-1] == '|');  // should end with '|'
    std::string cmd_name(rxfilename, 0, rxfilename.length()-1);
#if defined(_MSC_VER) || defined(__CYGWIN__)
    f_ = popen(cmd_name.c_str(), (binary ? "rb" : "r"));
#else
    f_ = popen(cmd_name.c_str(), "r");
#endif

    if (!f_) {  // Failure.
      KALDI_WARN << "Failed opening pipe for reading, command is: "
                 << cmd_name << ", errno is " << strerror(errno);
      return false;
    } else {
#ifndef _MSC_VER
      fb_ = new PipebufType(f_,  // Using this constructor won't lead the
                                 // destructor to close the stream.
                                 (binary ? std::ios_base::in|
                                  std::ios_base::binary
                                  :std::ios_base::in));
      KALDI_ASSERT(fb_ != NULL);  // or would be alloc error.
      is_ = new std::istream(fb_);
#else
      is_ = new std::ifstream(f_);
#endif
      if (is_->fail() || is_->bad()) return false;
      if (is_->eof()) {
        KALDI_WARN << "Pipe opened with command "
                   << PrintableRxfilename(rxfilename)
                   << " is empty.";
        // don't return false: empty may be valid.
      }
      return true;
    }
  }

Stream()

virtual std::istream& Stream ( )

inlinevirtual

Implements InputImplBase.

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

References KALDI_ERR.

                               {
    if (is_ == NULL)
      KALDI_ERR << "PipeInputImpl::Stream(), object not initialized.";
    // I believe this error can only arise from coding error.
    return *is_;
  }

Member Data Documentation

f_

FILE* f_

private

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

fb_

PipebufType* fb_

private

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

filename_

std::string filename_

private

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

is_

std::istream* is_

private

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

---

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

• util/kaldi-io.cc