OpenRTMFP/Cumulus Primer(19)独立使用CumulusLib时的线程安全Bug
OpenRTMFP/Cumulus 提供了 CumulusLib 可以供其他 RTMFP 应用使用,而不局限于 CumulusServer。
一般来说,Thread A 会准备好要 push 的消息,然后 Thread A 向消息队列 push 消息。
但是 CumulusLib 中实现的,是 Thread A 向消息队列 push 消息,然后根据这个消息在队列中的指针,再向消息内填写字段。并期望如下:
由于在 CumulusServer 中,一个 Client 只在一个线程内被操作,相应的 FlowWriter 也不会出现跨线程的问题。但是如果单独使用 CumulusLib,如果出现线程通信,并且共享 FlowWriter 的话,就会共享消息队列,此时可能出现这种情况。
这就导致了很严重的错误,会使得进程崩溃。修正的方式,可以是将消息完全准备好之后,再放入队列,如下:
/*
* author: michael
* date: June 6th, 2012
* type: add
*/
MessageBuffered* FlowWriter::createAMFMessage(const std::string& name)
// signature.empty() means that we are on the flowWriter of FlowNull
if (!(_closed || signature.empty() || _band.failed())) {
MessageBuffered* pMessage = new MessageBuffered();
MessageBuffered& message(*pMessage);
writeResponseHeader(message.rawWriter,name,0);
return pMessage;
}
MessageBuffered& message(_MessageNull);
writeResponseHeader(message.rawWriter,name,0);
return NULL;
}
然后再调用时最后再增加 push 操作:
/*
* author: michael
* date: June 6th, 2012
* type: add
*/
void FlowWriter::pushAMFMessage(MessageBuffered* pMessage) {
if (pMessage != NULL) {
_messages.push_back(pMessage);
}
}
这样就使得消息的数据被写完了,才被放入队列中,如下:
不过如果考虑线程安全,多个线程对同一个消息队列进行操作时,就要加锁:
/*
* author: michael
* date: June 6th, 2012
* type: add
*/
void FlowWriter::pushAMFMessage(MessageBuffered* pMessage) {
if (pMessage != NULL) {
Poco::Mutex::ScopedLock lock(msgQueueMutex);
_messages.push_back(pMessage);
}
}
这样就基本解决了这个线程安全问题。
另外,使用 CumulusLib 要遵循 GPL 协议,一定不要忘记。
-
转载请注明来自柳大·Poechant(钟超)的CSDN博客:Blog.CSDN.net/Poechant
-
分享到:
相关推荐
OpenRTMFP Cumulus Primer()入门介绍与部署CumulusServer.pdf
NULL 博文链接:https://lullabyus.iteye.com/blog/790150
高性能计算云 目标 ...$ vi /opt/hpccloud/cumulus/cumulus/conf/config.json +- > Fix host to be localhost +- > baseUrl: " http://localhost:8080/api/v1 " , $ sudo service celeryd restar
这本食谱在 vanilla Debian 上创建了一个交换机覆盖,并且还部署在 Cumulus 路由器/交换机上。 要求 测试 访问 Debian Wheezy 盒子 生产 访问 Cumulus HCL [1] 开关(Accton AS6701_32X,这就是这本食谱最初的目的)...
cumulus4.4.0 镜像,可加载到EVE环境。测试好使。
这里给出了cumulus/OpenRTMFP的git官网提到的视频会话样例的AS3代码,包括服务器端和客户端两部分,我已经在<使用Cumulus和Flash Player搭建视频会议示例>http://blog.csdn.net/tao_627/article/details/18041473中给...
Mellanox Cumulus学习,基本使用,培训资源
积云Cumulus 是的免费、开源替代品,它利用您自己的 S3 进行存储。下载您可以在下载最新版本更改默认截图目录这是可选的。 默认情况下,OS X 会将屏幕截图放在您的桌面上。 但是,如果您希望他们去其他地方,您可以...
openrtmfp又名Cumulus Server是一个完全开源和跨平台的可扩展的RTMFP服务器脚本。Cumulus Server在GPL 框架下遵循速度、优势、跨平台、轻量和高质量代码。Cumulus Server的每一个版本都是通过严格测试和审核的。可...
积云框架 :open_book: 文献资料 最新文档。 文档。 更多信息 有关此项目的更多信息,以及有关NASA的地球观测系统数据和信息系统(EOSDIS)及其云工作的更多信息,请联系或访问 。...这是用于Cumulus开
Cumulus集成测试项目[已弃用] ... 运行测试时,默认情况下,测试将使用spec/config.yml定义的配置来尝试执行工作流程。 这些变量是在CircleCI上运行测试所必需的。 可以在您自己的spec/config.override
大名鼎鼎的WP-CUMULUS 3D标签云,已经改成支持中文标签,可在.htm自行添加标签链接,可以单机玩耍测试,不需要安装WordPress然后装插件~~ 主要是有些童鞋只是想要3D标签云动画,所以就提取重要文件出来稍作修改下.
包括swfobject.js和tagcolud.swf中文支持文件。
不错的标签云,喜欢立体效果的博客主或者网站主可以试试看哦!强力推荐
#资源达人分享计划#
Flex P2P 音视频流客户端(Cumulus支持)
NVIDIA网络文档 NVIDIA(英伟达)这是Cumulus Networks文档的源存储库,位于docs.cumulusnetworks.com。 该站点使用静态站点生成器 。 安装文档并运行本地服务器 ... 保存对源文件的任何更改时,Hugo都会监视并重建
人们从头开始设想了Cumulus会使用Grand Central Dispatch(CGD),从而实现大规模并发-可以进行的速度和宽度不受硬件和系统的限制。 和别人一起玩 根据设计,Cumulus只会做一件事情,而一件事情做得很好:与REST资源...
用于为 Cumulus API 生成和部署仪表板的代码。 文档 其他页面: 配置 仪表板由从 Cumulus API 检索到的数据填充。 在构建和部署仪表板之前,必须预先确定和设置 Cumulus API 的环境。 配置仪表板所需的信息可在app/...
以下是如何在IRIS Scientific OpenStack云上使用Magnum创建的Kubernetes集群的一些示例,例如: ://cumulus.openstack.hpc.cam.ac.uk 这是由STFC IRIS云提供资金的数字资产: : 贡献 如果您有任何问题,请提出一...