OpenRTMFP/Cumulus Primer（12）IO管理之IO流（续）

OpenRTMFP/Cumulus Primer（12）IO管理之IO流（续）

• Author: 柳大·Poechant（钟超）
• Email: zhongchao.ustc#gmail.com (#->@)
• Blog: Blog.CSDN.net/Poechant
• Date: April 24^th, 2012

0 导语

本文所介绍的 CumulusServer 中用到的 IO 流，是基于 CumulusServer 中的 MemoryIOS 的，可以先阅读《OpenRTMFP/Cumulus Primer（11）IO 管理之IO流》一文，然后再阅读本文。

1 输入流

class MemoryInputStream: public MemoryIOS, public std::istream
{
public:
    MemoryInputStream(const char* pBuffer,Poco::UInt32 bufferSize);
        /// Creates a MemoryInputStream for the given memory area,
        /// ready for reading.
    MemoryInputStream(MemoryInputStream&);
    ~MemoryInputStream();
        /// Destroys the MemoryInputStream.
    char*           current();
};

构造函数、拷贝构造函数和析构函数也都没什么可说的，初始化 MemoryIOS 以及 istream。istream 是 iostream 中的 basic_istream  别名（typedef）。

MemoryInputStream::MemoryInputStream(const char* pBuffer, UInt32 bufferSize):     MemoryIOS(const_cast<char*>(pBuffer), bufferSize), istream(rdbuf()) {}MemoryInputStream::MemoryInputStream(MemoryInputStream& other):    MemoryIOS(other), istream(rdbuf()) {}MemoryInputStream::~MemoryInputStream() {}

唯一的一个成员函数是 current，封装了 MemoryIOS 的 MemoryStreamBuf 成员的 gCurrent 函数：

inline char* MemoryInputStream::current() {    return rdbuf()->gCurrent();}

2 输出流

class MemoryOutputStream: public MemoryIOS, public std::ostream    /// An input stream for reading from a memory area.{public:    MemoryOutputStream(char* pBuffer,Poco::UInt32 bufferSize);        /// Creates a MemoryOutputStream for the given memory area,        /// ready for writing.    MemoryOutputStream(MemoryOutputStream&);    ~MemoryOutputStream();        /// Destroys the MemoryInputStream.    Poco::UInt32    written();    void            written(Poco::UInt32 size);    char*           current();};

2.1 构造函数、拷贝构造函数和析构函数

如下，不赘述了。

MemoryOutputStream::MemoryOutputStream(char* pBuffer, UInt32 bufferSize):     MemoryIOS(pBuffer, bufferSize), ostream(rdbuf()) {}MemoryOutputStream::MemoryOutputStream(MemoryOutputStream& other):    MemoryIOS(other), ostream(rdbuf()) {}MemoryOutputStream::~MemoryOutputStream(){}

2.2 读取和设定已写字节数

读取：

inline Poco::UInt32 MemoryOutputStream::written() {    return rdbuf()->written();}

设定：

inline void MemoryOutputStream::written(Poco::UInt32 size) {    rdbuf()->written(size);}

2.3 当前位置

与 MemoryInputStream 中的封装类似：

inline char* MemoryOutputStream::current() {    return rdbuf()->pCurrent();}

-

转载请注明来自柳大的CSDN博客：Blog.CSDN.net/Poechant

-