PipeOutputImpl Class Reference

Inheritance diagram for PipeOutputImpl:

Collaboration diagram for PipeOutputImpl:

Public Member Functions
	PipeOutputImpl ()
virtual bool	Open (const std::string &wxfilename, bool binary)
virtual std::ostream &	Stream ()
virtual bool	Close ()
virtual	~PipeOutputImpl ()
Public Member Functions inherited from OutputImplBase
virtual	~OutputImplBase ()

Private Attributes
std::string	filename_
FILE *	f_
PipebufType *	fb_
std::ostream *	os_

Detailed Description

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

Constructor & Destructor Documentation

PipeOutputImpl()

PipeOutputImpl ( )

inline

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

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

~PipeOutputImpl()

virtual ~PipeOutputImpl ( )

inlinevirtual

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

References OutputImplBase::Close(), KALDI_ERR, and kaldi::PrintableWxfilename().

                            {
    if (os_) {
      if (!Close())
        KALDI_ERR << "Error writing to pipe " << PrintableWxfilename(filename_);
    }
  }

Member Function Documentation

Close()

virtual bool Close ( )

inlinevirtual

Implements OutputImplBase.

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

References KALDI_ERR, and KALDI_WARN.

                       {
    if (os_ == NULL) KALDI_ERR << "PipeOutputImpl::Close(), file is not open.";
    bool ok = true;
    os_->flush();
    if (os_->fail()) ok = false;
    delete os_;
    os_ = NULL;
    int 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 ok;
  }

Open()

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

inlinevirtual

Implements OutputImplBase.

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

References KALDI_ASSERT, and KALDI_WARN.

                                                              {
    filename_ = wxfilename;
    KALDI_ASSERT(f_ == NULL);  // Make sure closed.
    KALDI_ASSERT(wxfilename.length() != 0 && wxfilename[0] == '|');  // should
    // start with '|'
    std::string cmd_name(wxfilename, 1);
#if defined(_MSC_VER) || defined(__CYGWIN__)
    f_ = popen(cmd_name.c_str(), (binary ? "wb" : "w"));
#else
    f_ = popen(cmd_name.c_str(), "w");
#endif
    if (!f_) {  // Failure.
      KALDI_WARN << "Failed opening pipe for writing, command is: "
                 << cmd_name << ", errno is " << strerror(errno);
      return false;
    } else {
#ifndef _MSC_VER
      fb_ = new PipebufType(f_,  // Using this constructor won't make the
                                 // destructor try to close the stream when
                                 // we're done.
                                  (binary ? std::ios_base::out|
                                   std::ios_base::binary
                                   :std::ios_base::out));
      KALDI_ASSERT(fb_ != NULL);  // or would be alloc error.
      os_ = new std::ostream(fb_);
#else
      os_ = new std::ofstream(f_);
#endif
      return os_->good();
    }
  }

Stream()

virtual std::ostream& Stream ( )

inlinevirtual

Implements OutputImplBase.

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

References KALDI_ERR.

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

Member Data Documentation

f_

FILE* f_

private

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

fb_

PipebufType* fb_

private

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

filename_

std::string filename_

private

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

os_

std::ostream* os_

private

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

---

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

• util/kaldi-io.cc