OpenRTMFP/Cumulus Primer(20)Cumulus的一个线程启动 Bug
Cumulus 中的线程都是继承自 Startable,在其中封装 Poco::Thread 成员,使得一些有关线程的操作更方便。Startable 中的 start 函数如下:
void Startable::start() {
if(!_stop)
return;
ScopedLock<fastmutex> lock(_mutex);
<span class="keyword" style="font-weight: bold; ">if</span>(_haveToJoin) {
_thread.join();
_haveToJoin=<span class="keyword" style="font-weight: bold; ">false</span>;
}
<span class="keyword" style="font-weight: bold; ">try</span> {
DEBUG(<span class="string" style="color: rgb(136, 0, 0); ">"Try to start up a new thread inherited from Startable"</span>);
_thread.start(_process);
_haveToJoin = <span class="keyword" style="font-weight: bold; ">true</span>;
ScopedLock<fastmutex> lock(_mutexStop);
_stop=<span class="keyword" style="font-weight: bold; ">false</span>;
} <span class="keyword" style="font-weight: bold; ">catch</span> (Poco::Exception& ex) {
ERROR(<span class="string" style="color: rgb(136, 0, 0); ">"Impossible to start the thread : %s"</span>,ex.displayText().c_str());
}
}
</fastmutex></fastmutex>
这样一个类继承 Startable 的话,并启动时传入自己,则会调用到 Startable::start(),然后调用到该类自己的 run() 函数。一般来说这个函数会一个循环,以 SocketManager 为例:
void SocketManager::run() {
…
while(running()) {
…
}
}
我们要看看这个 running() 是怎么回事,如下:
inline bool Startable::running() const {
return !_stop;
}
很简单,就是通过 Startable::_stop 成员来判断是否还需要继续循环下去。那么这个 _stop 是什么时候被设置为 false 的呢?就是上面的 start(),这里存在的一个问题就是先 start 线程,再设置 _stop 为 false。
_thread.start(_process);
_stop=false;
而 start() 之后 run() 的时候就开始通过 running() 来判断 _stop 值了。所以你会在使用 Cumulus 时,发现有时候启动起来的线程个数不对。正常情况下应该有四个线程:
它们是:
- 主线程
- RTMFPServer 线程
- MainSockets 线程
- RTMFPManager 线程
而异常情况可能是 MainSockets 没有启动,甚至 MainSockets 和 RTMFPManager 都没有启动。
MainSockets 没有启动的情况,这时客户端是无法接入成功的。
MainSockets 和 RTMFPManager 都没有启动的情况 T.T
具体是哪个线程没有启动成功可以通过 GDB 查看。
解决办法就是将 _stop 的设置操作,在启动线程之前。不过要注意锁要同时移动,并且在产生异常时设置 _stop 值为 true。
void Startable::start() {
if(!_stop)
return;
ScopedLock<fastmutex> lock(_mutex);
<span class="keyword" style="font-weight: bold; ">if</span>(_haveToJoin) {
_thread.join();
_haveToJoin=<span class="keyword" style="font-weight: bold; ">false</span>;
}
<span class="keyword" style="font-weight: bold; ">try</span> {
DEBUG(<span class="string" style="color: rgb(136, 0, 0); ">"Try to start up a new thread inherited from Startable"</span>);
{
ScopedLock<fastmutex> lock(_mutexStop);
_stop=<span class="keyword" style="font-weight: bold; ">false</span>;
}
_thread.start(_process);
_haveToJoin = <span class="keyword" style="font-weight: bold; ">true</span>;
} <span class="keyword" style="font-weight: bold; ">catch</span> (Poco::Exception& ex) {
{
ScopedLock<fastmutex> lock(_mutexStop);
_stop = <span class="keyword" style="font-weight: bold; ">true</span>; <span class="comment" style="color: rgb(136, 136, 136); ">// June 25th, 2012, Michael@YY</span>
}
ERROR(<span class="string" style="color: rgb(136, 0, 0); ">"Impossible to start the thread : %s"</span>,ex.displayText().c_str());
}
}
</fastmutex></fastmutex></fastmutex>
-
转载请注明来自柳大·Poechant(钟超)的CSDN博客:Blog.CSDN.net/Poechant
-
分享到:
相关推荐
OpenRTMFP Cumulus Primer()入门介绍与部署CumulusServer.pdf
cumulus4.4.0 镜像,可加载到EVE环境。测试好使。
这本食谱在 vanilla Debian 上创建了一个交换机覆盖,并且还部署在 Cumulus 路由器/交换机上。 要求 测试 访问 Debian Wheezy 盒子 生产 访问 Cumulus HCL [1] 开关(Accton AS6701_32X,这就是这本食谱最初的目的)...
openrtmfp又名Cumulus Server是一个完全开源和跨平台的可扩展的RTMFP服务器脚本。Cumulus Server在GPL 框架下遵循速度、优势、跨平台、轻量和高质量代码。Cumulus Server的每一个版本都是通过严格测试和审核的。可...
高性能计算云 目标 ...$ vi /opt/hpccloud/cumulus/cumulus/conf/config.json +- > Fix host to be localhost +- > baseUrl: " http://localhost:8080/api/v1 " , $ sudo service celeryd restar
#资源达人分享计划#
这里给出了cumulus/OpenRTMFP的git官网提到的视频会话样例的AS3代码,包括服务器端和客户端两部分,我已经在<使用Cumulus和Flash Player搭建视频会议示例>http://blog.csdn.net/tao_627/article/details/18041473中给...
积云框架 :open_book: 文献资料 最新文档。 文档。 更多信息 有关此项目的更多信息,以及有关NASA的地球观测系统数据和信息系统(EOSDIS)及其云工作的更多信息,请联系或访问 。...这是用于Cumulus开
用于C的Cumulus通过与镜像与创建,获取,更新和删除远程资源相关的HTTP请求的方法,为REST服务提供了一个简单的低级接口。 它是如此简单易用,以至于使将iOS或Mac应用程序连接到Web服务变得异常简单。 专为速度而...
大名鼎鼎的WP-CUMULUS 3D标签云,已经改成支持中文标签,可在.htm自行添加标签链接,可以单机玩耍测试,不需要安装WordPress然后装插件~~ 主要是有些童鞋只是想要3D标签云动画,所以就提取重要文件出来稍作修改下.
积云Cumulus 是的免费、开源替代品,它利用您自己的 S3 进行存储。下载您可以在下载最新版本更改默认截图目录这是可选的。 默认情况下,OS X 会将屏幕截图放在您的桌面上。 但是,如果您希望他们去其他地方,您可以...
包括swfobject.js和tagcolud.swf中文支持文件。
NULL 博文链接:https://lullabyus.iteye.com/blog/790150
不错的标签云,喜欢立体效果的博客主或者网站主可以试试看哦!强力推荐
Cumulus集成测试项目[已弃用] 注意:此存储库不再维护。 该存储库的内容已移至。 什么是积云? Cumulus是NASA未来地球科学数据流的基于云的数据提取,存档,分发和管理原型。 阅读 安装 nvm use npm install 在...
用于为 Cumulus API 生成和部署仪表板的代码。 文档 其他页面: 配置 仪表板由从 Cumulus API 检索到的数据填充。 在构建和部署仪表板之前,必须预先确定和设置 Cumulus API 的环境。 配置仪表板所需的信息可在app/...
Mellanox Cumulus学习,基本使用,培训资源
完美支持中文wp-cumulus插件源码(无锯齿无抖动7K大小)
Flex P2P 音视频流客户端(Cumulus支持)
Hugo包含一个本地开发服务器,用于构建和查看仓库的实时更改。 要构建和查看实时站点: 从扩展安装Hugo 0.65.3版本。 用hugo version验证雨果。 该站点支持Hugo 0.65.3版。 hugo version命令的输出应为: Hugo ...