`
Poechant
  • 浏览: 229700 次
博客专栏
Bebe66e7-3a30-3fc9-aeea-cfa3b474b591
Nginx高性能Web服务...
浏览量:24333
5738817b-23a1-3a32-86de-632d7da73b1e
Cumulus实时媒体服务...
浏览量:22105
社区版块
存档分类
最新评论

OpenRTMFP/Cumulus Primer(10)IO 管理之流缓冲区

 
阅读更多

OpenRTMFP/Cumulus Primer(10)IO 管理之流缓冲区

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

本文主要分析 MemoryStream.h 文件中定义的类。

1 了解 std::streambuf

首先要了解 streambuf 内置了一个 get 指针和一个 put 指针。streambuf 的所有操作基本都是对这两个指针的操作。其一些成员函数的缩写中的 g 和 p 就分别表示 get pointer 和 put pointer。

1.1 单步移动内置指针

  • Increase get pointer: Advances the get pointer by n positions. The get pointer is the internal pointer that points to the next location in the controlled input sequence.

      void gbump ( int n );
    
  • Increase put pointer: Advances the put pointer by n positions. The put pointer is the internal pointer that points to the next location of the controlled output sequence.

      void pbump ( int n );
    

1.2 获取 get 指针和 put 指针的位置

  • Pointer to current position of input sequence: Returns a reference to the current element of the controlled input sequence (i.e., the “get pointer”).

      char * gptr ( ) const;
    
  • Pointer to current position of output sequence: Returns a reference to the current element of the output sequence (the put pointer).

      char * pptr ( ) const;
    

1.3 设置 get 和 put 指针可达区域的上下界

  • Set input sequence pointers: Sets values for the pointers that define both the boundaries of the accessible part of the controlled input sequence and the get pointer itself.

      void setg ( char* gbeg, char* gnext, char* gend );
    
  • gbeg: New value for the pointer to the beginning of the accessible part of the controlled input sequence.
  • gnext: New value for the get pointer, which points to the next element within the controlled input sequence where the next input operation shall be performed.
  • gend: New value for the end pointer, just past the end of the accessible part of the controlled input sequence.
  • Set output sequence pointers: Sets the values that define the boundaries of the accessible part of the controlled output sequence.

      void setp ( char* pbeg, char* pend );
    
  • pbeg: New value for the pointer to the beginning of the accessible part of the controlled output sequenceand put pointer.
  • pend: New value for the end pointer, just past the end of the accessible part of the controlled output sequence.

2 MemoryStreamBuf

类定义:

class MemoryStreamBuf: public std::streambuf {
    friend class ScopedMemoryClip;
public:
    MemoryStreamBuf(char* pBuffer,Poco::UInt32 bufferSize);
    MemoryStreamBuf(MemoryStreamBuf&);
    ~MemoryStreamBuf();

    void            next(Poco::UInt32 size); // Explaint below
    Poco::UInt32    written(); // Explaint below
    void            written(Poco::UInt32 size);
    Poco::UInt32    size();  // Explaint below
    void            resize(Poco::UInt32 newSize); // Explaint below
    char*           begin(); // Explaint below
    void            position(Poco::UInt32 pos=0); // Explaint below
    char*           gCurrent(); // Explaint below
    char*           pCurrent(); // Explaint below

private:
    virtual int overflow(int_type c);
    virtual int underflow();
    virtual int sync();

    Poco::UInt32    _written;
    char*           _pBuffer;
    Poco::UInt32    _bufferSize;

    MemoryStreamBuf();
    MemoryStreamBuf& operator = (const MemoryStreamBuf&);
};

ScopedMemoryClip 是 MemoryStreamBuf 的友元,其内部有 MemoryStreamBuf 的成员,这里暂且不管。构造函数传入的参数是缓冲区的地址和缓冲区大小(字节数)。拷贝构造函数和析构函数不必赘述。

2.1 移动内置的 get 和 put 指针:

put 和 get 指针都移动:

void MemoryStreamBuf::next(UInt32 size) {
    pbump(size);
    gbump(size);
}

2.2 获取 get 和 put 指针当前位置:

封装 streambuf 的 gptr 和 pptr:

inline char* MemoryStreamBuf::gCurrent() {
    return gptr();
}
inline char* MemoryStreamBuf::pCurrent() {
    return pptr();
}

2.3 获取缓冲区的起始位置和大小:

依赖于内置成员变量pBuffer 和bufferSize:

inline char* MemoryStreamBuf::begin() {
    return _pBuffer;
}

inline Poco::UInt32 MemoryStreamBuf::size() {
    return _bufferSize;
}

2.4 缓冲区的已写字节数

读取(其中也可能发生设置操作):

UInt32 MemoryStreamBuf::written() {
    int written = pCurrent() - begin(); // 已写字节数
    if (written < 0)
        written = 0;
    if (written > _written) // 保存已写字节数
        _written = (UInt32)written;
    return _written;
}

设置:

void MemoryStreamBuf::written(UInt32 size) {
    _written=size;
}

2.5 显式设定 put 和 get 指针位置

设定 put 和 get 指针为以缓冲区首地址为开始偏移量为 pos 的位置:

void MemoryStreamBuf::position(UInt32 pos) {

    // 保存已写字节数
    written(); // Save nb char written

    // 移动 put 指针
    setp(_pBuffer, _pBuffer + _bufferSize);
    if (pos > _bufferSize)
        pos = _bufferSize;
    pbump((int) pos);

    // 移动 get 指针
    setg(_pBuffer, _pBuffer + pos, _pBuffer + _bufferSize);
}

2.6 修改缓冲区大小

void MemoryStreamBuf::resize(UInt32 newSize) {
    // 大小标识
    _bufferSize = newSize;

    // gptr 当前位置
    int pos = gCurrent() - _pBuffer;
    if (pos > _bufferSize) pos = _bufferSize;

    // 设置 gptr 可达范围和当前位置
    setg(_pBuffer, _pBuffer + pos, _pBuffer + _bufferSize); 
    // pptr 当前位置
    pos = pCurrent() - _pBuffer;
    if (pos > _bufferSize) pos = _bufferSize;

    // 设置 pptr 可达范围和当前位置
    setp(_pBuffer,_pBuffer + _bufferSize);
        pbump(pos);
}

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

构造函数会设定 pptr 和 gptr,并初始化pBuffer 和bufferSize

MemoryStreamBuf::MemoryStreamBuf(char* pBuffer, UInt32 bufferSize):     _pBuffer(pBuffer),_bufferSize(bufferSize),_written(0) {
    setg(_pBuffer, _pBuffer,_pBuffer + _bufferSize);
    setp(_pBuffer, _pBuffer + _bufferSize);
}

析构函数会拷贝对方的pBuffer、bufferSizse、_written,并设定 gptr、pptr。注意设定 pptr 时,要分别调用 setp 和 pbump,因为 setp 仅将 pptr 设定为传入的首个参数值(与可达范围的首地址相同)。

MemoryStreamBuf::MemoryStreamBuf(MemoryStreamBuf& other):   _pBuffer(other._pBuffer),_bufferSize(other._bufferSize),_written(other._written) {
    setg(_pBuffer, other.gCurrent(), _pBuffer + _bufferSize);
    setp(_pBuffer, _pBuffer + _bufferSize);
    pbump((int)(other.pCurrent()-_pBuffer));
}

析构函数:

MemoryStreamBuf::~MemoryStreamBuf() {
}

Reference

  1. http://www.cplusplus.com/reference/iostream/streambuf/gbump/
  2. http://www.cplusplus.com/reference/iostream/streambuf/pbump/

-

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

-

分享到:
评论

相关推荐

    OpenRTMFP Cumulus Primer()入门介绍与部署CumulusServer.pdf

    《OpenRTMFP Cumulus Primer 入门与CumulusServer部署》 OpenRTMFP (Real Time Media Flow Protocol) 是一种技术,它为Flash实时应用提供了高并发扩展能力。OpenRTMFP/Cumulus是基于GNU General Public License的...

    Flex P2P 音视频流客户端(Cumulus支持)

    Cumulus库不仅实现了OpenRTMFP协议,还提供了一套灵活的API,使得开发者能够方便地控制和管理P2P连接。 在压缩包中的"flashyy-protocwrapper"文件,可能是用于编解码协议消息的工具。在Flex P2P 音视频流客户端中,...

    cumulus-linux-4.4.0-vx-amd64-qemu.zip

    Cumulus Linux 4.4.0 是一个专为网络设备设计的开源操作系统,它将Linux的强大功能与网络硬件的灵活性相结合。这个版本是为AMD64架构设计的,并且已经打包成了一个适用于QEMU(Quick Emulator)的虚拟机镜像文件,...

    cumulus-linux-cookbook:用于管理积云开关的手册

    这本食谱在 vanilla Debian 上创建了一个交换机覆盖,并且还部署在 Cumulus 路由器/交换机上。 要求 测试 访问 Debian Wheezy 盒子 生产 访问 Cumulus HCL [1] 开关(Accton AS6701_32X,这就是这本食谱最初的目的)...

    wp-cumulus(支持中文标签)

    **wp-cumulus插件详解** `wp-cumulus`是一款专门为WordPress博客设计的炫酷三维标签云插件。这款插件以其独特的视觉效果和良好的用户体验,在众多的WordPress标签云插件中脱颖而出。通过使用`wp-cumulus`,用户可以...

    cumulus(浑天仪)使用手册

    Cumulus可能提供了API接口,允许开发者通过编程方式与之交互,实现自动化任务或集成到其他系统中。学习如何使用这些API是提高工作效率的重要环节,通常涉及到HTTP请求、JSON数据格式和认证机制等知识。 数据可视化...

    wp-cumulus

    首先,你需要登录到WordPress的后台管理界面,然后在插件部分选择“添加新插件”,在搜索框中输入"wp-cumulus" 进行查找。找到插件后,点击“安装现在”按钮,待安装完成后再点击“激活插件”。一旦激活,你可以在...

    Cumulus:一个基于网络编码的分布式文件系统.pdf

    【 Cumulus:基于网络编码的分布式文件系统 】 在分布式计算领域,分布式文件系统是支撑大规模数据处理和存储的关键技术之一。Cumulus 是一个创新性的分布式文件系统,它利用网络编码理论来优化系统的容错能力和...

    HPCCloud:基于 CloudWeb 的仿真环境

    高性能计算云 目标 ...$ vi /opt/hpccloud/cumulus/cumulus/conf/config.json +- &gt; Fix host to be localhost +- &gt; baseUrl: " http://localhost:8080/api/v1 " , $ sudo service celeryd restar

    wp-cumulus_3D云标签

    首先,你需要在WordPress的后台插件管理页面中搜索“wp-cumulus”,找到后点击“安装”按钮,待插件下载并安装完毕后,激活即可。另外,你也可以选择从官方插件网站下载zip文件,然后通过WordPress后台的“上传插件...

    cumulus:Cumulus框架+ Cumulus API

    Cumulus核心回购是管理的 。 Lerna负责安装此存储库中的软件包和任务的依赖关系。 通常,可以在目录中找到Cumulus的npm软件包,而在目录中可以找到工作流任务。 为了帮助减少在此monorepo中安装软件包依赖项所需的...

    Cumulus官网视频会议样例代码

    这里给出了cumulus/OpenRTMFP的git官网提到的视频会话样例的AS3代码,包括服务器端和客户端两部分,我已经在&lt;使用Cumulus和Flash Player搭建视频会议示例&gt;http://blog.csdn.net/tao_627/article/details/18041473中给...

    cumulus-integration-tests:Cumulus工作流的集成测试[已弃用]

    Cumulus是NASA未来地球科学数据流的基于云的数据提取,存档,分发和管理原型。 阅读 安装 nvm use npm install 在本地运行测试 这些测试是针对AWS运行的,因此需要进行Cumulus部署。 使用此存储库中的配置来设置...

    RTMFP服务器脚本CumulusServer.zip

    openrtmfp又名Cumulus Server是一个完全开源和跨平台的可扩展的RTMFP服务器脚本。Cumulus Server在GPL 框架下遵循速度、优势、跨平台、轻量和高质量代码。Cumulus Server的每一个版本都是通过严格测试和审核的。可...

    Cumulus:CloudApp 的开源替代品,利用您自己的 S3 进行存储

    积云Cumulus 是的免费、开源替代品,它利用您自己的 S3 进行存储。下载您可以在下载最新版本更改默认截图目录这是可选的。 默认情况下,OS X 会将屏幕截图放在您的桌面上。 但是,如果您希望他们去其他地方,您可以...

    3D标签云单机中文版 WP-CUMULUS 1.23

    大名鼎鼎的WP-CUMULUS 3D标签云,已经改成支持中文标签,可在.htm自行添加标签链接,可以单机玩耍测试,不需要安装WordPress然后装插件~~ 主要是有些童鞋只是想要3D标签云动画,所以就提取重要文件出来稍作修改下.

    drupal -cumulus

    Drupal 是一个广泛使用的开源内容管理系统(CMS),它允许用户创建和管理复杂的网站。在这个特定的场景中,我们关注的是 Drupal 的两个模块:Tagadelic 和 Cumulus,它们都是用来实现标签云(Tag Cloud)效果的。 ...

    Mellanox Cumulus 培训资源

    Mellanox Cumulus学习,基本使用,培训资源

    wp-cumulus.rar_TagCloud._TagCloud.as_flex cumul_wp cumulus_wp cu

    【标题】"wp-cumulus.rar" 是一个与WordPress相关的压缩包,其中包含"TagCloud._TagCloud.as",这表明它与创建和展示WordPress标签云的插件有关。"flex cumul_wp cumulus_wp cu"暗示这个插件可能是用Adobe Flex技术...

    Python库 | cumulus-1.1.0.tar.gz

    这个库可能涉及云计算、数据处理或与之相关的领域,因为“cumulus”在自然界中通常指的是云朵,而在计算术语中,它可能暗示着云服务或分布式计算。 首先,我们需要了解如何安装和使用这个库。对于一个tar.gz文件,...

Global site tag (gtag.js) - Google Analytics