X-Git-Url: https://git.saurik.com/wxWidgets.git/blobdiff_plain/e4edebc0964cc3010d058daab4f662838f6b43e7..8e77fd8bca165aab9709649d79a7cbc6a172d4e1:/include/wx/unix/pipe.h?ds=sidebyside diff --git a/include/wx/unix/pipe.h b/include/wx/unix/pipe.h index 356ee9d394..e4799024ed 100644 --- a/include/wx/unix/pipe.h +++ b/include/wx/unix/pipe.h @@ -46,10 +46,20 @@ public: { wxLogSysError(_("Pipe creation failed")); - return FALSE; + return false; } - return TRUE; + return true; + } + + // switch the given end of the pipe to non-blocking IO + bool MakeNonBlocking(Direction which) + { + const int flags = fcntl(m_fds[which], F_GETFL, 0); + if ( flags == -1 ) + return false; + + return fcntl(m_fds[which], F_SETFL, flags | O_NONBLOCK) == 0; } // return TRUE if we were created successfully @@ -74,7 +84,10 @@ public: for ( size_t n = 0; n < WXSIZEOF(m_fds); n++ ) { if ( m_fds[n] != INVALID_FD ) + { close(m_fds[n]); + m_fds[n] = INVALID_FD; + } } } @@ -85,7 +98,7 @@ private: int m_fds[2]; }; -#if wxUSE_STREAMS +#if wxUSE_STREAMS && wxUSE_FILE #include "wx/wfstream.h" @@ -105,7 +118,21 @@ public: virtual bool CanRead() const; }; -#endif // wxUSE_STREAMS +// ---------------------------------------------------------------------------- +// wxPipeOutputStream: stream for writing to a pipe +// ---------------------------------------------------------------------------- + +class wxPipeOutputStream : public wxFileOutputStream +{ +public: + wxPipeOutputStream(int fd) : wxFileOutputStream(fd) { } + + // Override the base class version to ignore "pipe full" errors: this is + // not an error for this class. + size_t OnSysWrite(const void *buffer, size_t size); +}; + +#endif // wxUSE_STREAMS && wxUSE_FILE #endif // _WX_UNIX_PIPE_H_