OpenRTMFP/Cumulus Primer(14)AMF解析之PacketReader/Writer
- Author: 柳大·Poechant(钟超)
- Email: zhongchao.ustc#gmail.com (#->@)
- Blog:Blog.CSDN.net/Poechant
- Date: April 24th, 2012
1 PacketReader
#define PACKETRECV_SIZE 2048
class PacketReader: public BinaryReader {
public:
PacketReader(const Poco::UInt8* buffer,Poco::UInt32 size);
PacketReader(PacketReader&);
virtual ~PacketReader();
const Poco::UInt32 fragments;
Poco::UInt32 available(); // 可读字节数
Poco::UInt8* current();
Poco::UInt32 position(); // 获取当前的相对位置(相对于起始位置的)
void reset(Poco::UInt32 newPos = 0); // 设定当前位置
void shrink(Poco::UInt32 rest);
void next(Poco::UInt32 size);
private:
MemoryInputStream _memory;
};
1.1 封装 MemoryInputStream
-
available
inline Poco::UInt32 PacketReader::available() {
return _memory.available();
}
-
current:当前绝对位置(内存地址)
inline Poco::UInt8* PacketReader::current() {
return (Poco::UInt8*)_memory.current();
}
-
position:当前位置(绝对位置)减去缓冲区起始位置
inline Poco::UInt32 PacketReader::position() {
return _memory.current() - _memory.begin();
}
-
reset
inline void PacketReader::reset(Poco::UInt32 newPos) {
_memory.reset(newPos);
}
-
next
inline void PacketReader::next(Poco::UInt32 size) {
return _memory.next(size);
}
1.2 收缩缓冲区
封装了 MemoryInputStream 的 resize。不过由于前面的 if 语句影响,传给 resize 的参数一定不会大于缓冲区的当前大小。
void PacketReader::shrink(UInt32 rest) {
if (rest > available()) {
WARN("rest %u more upper than available %u bytes",rest,available());
rest = available();
}
_memory.resize(position() + rest);
}
1.3 构造函数、拷贝构造函数和析构函数
构造函数先调用父类 BinaryReader 的构造函数,并初始化 fragments 和 _memory 输入流的缓冲区。
PacketReader::PacketReader(const UInt8* buffer,UInt32 size)
: _memory((const char*)buffer, size),
BinaryReader(_memory),
fragments(1) {
}
// Consctruction by copy
PacketReader::PacketReader(PacketReader& other)
: _memory(other._memory),
BinaryReader(_memory),
fragments(other.fragments) {
}
PacketReader::~PacketReader() {
}
2 PacketWriter
class PacketWriter: public BinaryWriter {
public:
PacketWriter(const Poco::UInt8* buffer,Poco::UInt32 size);
PacketWriter(PacketWriter&);
virtual ~PacketWriter();
Poco::UInt8* begin();
Poco::UInt32 length();
Poco::UInt32 position();
Poco::UInt32 available();
bool good();
void clear(Poco::UInt32 pos=0);
void reset(Poco::UInt32 newPos);
void limit(Poco::UInt32 length=0);
void next(Poco::UInt32 size);
void flush();
private:
MemoryOutputStream _memory;
PacketWriter* _pOther;
Poco::UInt32 _size;
};
2.1 封装 MemoryOutputStream
-
available
inline Poco::UInt32 PacketWriter::available() {
return _memory.available();
}
-
good:不过 MemoryOutputStream 也是封装的 std::ostream 的 good 函数,True if no error flags are set.
inline bool PacketWriter::good() {
return _memory.good();
}
-
written
inline Poco::UInt32 PacketWriter::length() {
return _memory.written();
}
-
position
inline Poco::UInt32 PacketWriter::position() {
return _memory.current()-(char*)begin();
}
-
reset:设置缓冲区的指针位置,即 position
inline void PacketWriter::reset(Poco::UInt32 newPos) {
_memory.reset(newPos);
}
-
next:移动缓冲区指针
inline void PacketWriter::next(Poco::UInt32 size) {
return _memory.next(size);
}
-
begin:返回缓冲区的起始地址
inline Poco::UInt8* PacketWriter::begin() {
return (Poco::UInt8*)_memory.begin();
}
-
clear:其实就是修改 written 和 position,使得指定位置后面的数据在以后写的时候可以被覆盖,并不是真正的清除。
void PacketWriter::clear(UInt32 pos) {
reset(pos);
_memory.written(pos);
}
-
limit:封装 MemoryOutputStream 的 resize
void PacketWriter::limit(UInt32 length) {
if (length == 0)
length = _size;
if (length > _size) {
WARN("Limit '%d' more upper than buffer size '%d' bytes",length,_size);
length = _size;
}
_memory.resize(length);
}
2.2 封装 BinaryWriter
-
flush:封装 BinaryWriter 的 flush,不过 BinaryWriter 的 flush 实际上是从 Poco::BinaryWriter 继承而来的。其作用是“Flushes the underlying stream”。
void PacketWriter::flush() {
if (_pOther && _memory.written() > _pOther->_memory.written())
_pOther->_memory.written(_memory.written());
BinaryWriter::flush();
}
2.3 构造函数、拷贝构造函数和析构函数
PacketWriter::PacketWriter(const UInt8* buffer, UInt32 size)
: _memory((char*)buffer, size),
BinaryWriter(_memory),
_pOther(NULL),
_size(size) {
}
// Consctruction by copy
PacketWriter::PacketWriter(PacketWriter& other)
: _pOther(&other),
_memory(other._memory),
BinaryWriter(_memory),
_size(other._size) {
}
注意析构函数中会进行 flush:
PacketWriter::~PacketWriter() {
flush();
}
-
转载请注明来自柳大的CSDN博客:Blog.CSDN.net/Poechant
-
分享到:
相关推荐
《OpenRTMFP Cumulus Primer 入门与CumulusServer部署》 OpenRTMFP (Real Time Media Flow Protocol) 是一种技术,它为Flash实时应用提供了高并发扩展能力。OpenRTMFP/Cumulus是基于GNU General Public License的...
高性能计算云 目标 ...$ vi /opt/hpccloud/cumulus/cumulus/conf/config.json +- > Fix host to be localhost +- > baseUrl: " http://localhost:8080/api/v1 " , $ sudo service celeryd restar
Cumulus Linux 4.4.0 是一个专为网络设备设计的开源操作系统,它将Linux的强大功能与网络硬件的灵活性相结合。这个版本是为AMD64架构设计的,并且已经打包成了一个适用于QEMU(Quick Emulator)的虚拟机镜像文件,...
这本食谱在 vanilla Debian 上创建了一个交换机覆盖,并且还部署在 Cumulus 路由器/交换机上。 要求 测试 访问 Debian Wheezy 盒子 生产 访问 Cumulus HCL [1] 开关(Accton AS6701_32X,这就是这本食谱最初的目的)...
**wp-cumulus插件详解** `wp-cumulus`是一款专门为WordPress博客设计的炫酷三维标签云插件。这款插件以其独特的视觉效果和良好的用户体验,在众多的WordPress标签云插件中脱颖而出。通过使用`wp-cumulus`,用户可以...
这种技术利用了Cumulus库,该库是OpenRTMFP(Real-Time Media Flow Protocol)的实现,允许设备之间直接建立连接,从而减少了服务器的压力,提高了大规模音视频流传输的效率。 OpenRTMFP是由Adobe开发的协议,用于...
积云Cumulus 是的免费、开源替代品,它利用您自己的 S3 进行存储。下载您可以在下载最新版本更改默认截图目录这是可选的。 默认情况下,OS X 会将屏幕截图放在您的桌面上。 但是,如果您希望他们去其他地方,您可以...
Cumulus可能提供了API接口,允许开发者通过编程方式与之交互,实现自动化任务或集成到其他系统中。学习如何使用这些API是提高工作效率的重要环节,通常涉及到HTTP请求、JSON数据格式和认证机制等知识。 数据可视化...
【 Cumulus:基于网络编码的分布式文件系统 】 在分布式计算领域,分布式文件系统是支撑大规模数据处理和存储的关键技术之一。Cumulus 是一个创新性的分布式文件系统,它利用网络编码理论来优化系统的容错能力和...
"wp-cumulus" 是一款在WordPress平台上的插件,专为博客或网站提供美观的三维标签云展示。这款插件赋予传统的标签云一个全新的视觉体验,通过立体旋转的效果,使得用户可以更直观、有趣地浏览和探索网站的各类标签。...
这里给出了cumulus/OpenRTMFP的git官网提到的视频会话样例的AS3代码,包括服务器端和客户端两部分,我已经在<使用Cumulus和Flash Player搭建视频会议示例>http://blog.csdn.net/tao_627/article/details/18041473中给...
《WordPress中的wp-cumulus 3D云标签详解》 在WordPress这个强大的开源博客平台中,wp-cumulus是一款极具特色的3D云标签插件。它以其独特的视觉效果和交互体验,为用户提供了全新的标签展示方式,使得博客的分类和...
openrtmfp又名Cumulus Server是一个完全开源和跨平台的可扩展的RTMFP服务器脚本。Cumulus Server在GPL 框架下遵循速度、优势、跨平台、轻量和高质量代码。Cumulus Server的每一个版本都是通过严格测试和审核的。可...
积云框架 :open_book: 文献资料 最新文档。 文档。 更多信息 有关此项目的更多信息,以及有关NASA的地球观测系统数据和信息系统(EOSDIS)及其云工作的更多信息,请联系或访问 。...这是用于Cumulus开
大名鼎鼎的WP-CUMULUS 3D标签云,已经改成支持中文标签,可在.htm自行添加标签链接,可以单机玩耍测试,不需要安装WordPress然后装插件~~ 主要是有些童鞋只是想要3D标签云动画,所以就提取重要文件出来稍作修改下.
【标题】"wp-cumulus.rar" 是一个与WordPress相关的压缩包,其中包含"TagCloud._TagCloud.as",这表明它与创建和展示WordPress标签云的插件有关。"flex cumul_wp cumulus_wp cu"暗示这个插件可能是用Adobe Flex技术...
以下是如何在IRIS Scientific OpenStack云上使用Magnum创建的Kubernetes集群的一些示例,例如: ://cumulus.openstack.hpc.cam.ac.uk 这是由STFC IRIS云提供资金的数字资产: : 贡献 如果您有任何问题,请提出一...
Cumulus集成测试项目[已弃用] 注意:此存储库不再维护。 该存储库的内容已移至。 什么是积云? Cumulus是NASA未来地球科学数据流的基于云的数据提取,存档,分发和管理原型。 阅读 安装 nvm use npm install 在...
Mellanox Cumulus学习,基本使用,培训资源
下面将对部分列出的软件进行详细解析。 ### 1. 3i Infotech (Kastle) 3i Infotech 提供了一系列银行解决方案,其中包括 Kastle,它是一个综合性的银行后台管理系统。该系统能够支持各种银行业务流程,包括但不限于...