我想将数据从我的C程序发送到外部管道,如下所示:
FILE* file = popen("my_prog -opt | other_prog","w"); std::ostream fileStream = some_function(file); fileStream << "some data";
我明白没有简单的,跨平台的方式来做第二行,但是有什么办法可以使用别的东西来完成同样的事情吗?我不需要使用popen,但我确实需要使用ostream.它需要使用clang和gcc进行编译,但最好是与任何编译器配合使用.我也可以改变我如何处理管道,但是我没有my_prog或other_prog的源代码.
解决方法
直接使用FILE *创建流缓冲区作为底层目标,并使用这样的流缓冲区创建相应的std :: ostream.它会大致看起来像这样:
#include <stdio.h> #include <streambuf> #include <ostream> class stdiobuf : public std::streambuf { enum { bufsize = 2048 }; char buffer[bufsize]; FILE* fp; int (*close)(FILE*); int overflow(int c) { if (c != std::char_traits<char>::eof()) { *this->pptr() = std::char_traits<char>::to_char_type(c); this->pbump(1); } return this->sync() ? std::char_traits<char>::eof() : std::char_traits<char>::not_eof(c); } int sync() { std::streamsize size(this->pptr() - this->pbase()); std::streamsize done(this->fp? fwrite(this->pbase(),1,size,this->fp): 0); this->setp(this->pbase(),this->epptr()); return size == done? 0: -1; } public: stdiobuf(FILE* fp,int(*close)(FILE*) = fclose) : fp(fp),close(close) { this->setp(this->buffer,this->buffer + (this->fp? bufsize - 1: 0)); } ~stdiobuf() { this->sync(); this->fp && this->close(this->fp); } }; class opipestream : private virtual stdiobuf,public std::ostream { public: opipestream(std::string const& pipe) : stdiobuf(popen(pipe.c_str(),"w"),pclose),std::ios(static_cast<std::streambuf*>(this)),std::ostream(static_cast<std::streambuf*>(this)) { } }; int main() { opipestream out("/usr/bin/sed -e 's/^/xxxx /'"); out << "Hello\n"; out << "world\n"; }
基本思想是您可以通过实现流缓冲区来创建新流.上述实施应当相当完整.当不完整的缓冲区可以改进时的错误处理,尽管最可能的错误是管道关闭,并且没有太多的可以做的事情.