OpenRTMFP/Cumulus Primer(8)CumulusServer主进程主循环分析
该主循环在RTMFPServer::run(const volatile bool& terminate)
函数中。RTMFPServer
覆盖Startable
的run(const volatile bool &terminate)
方法。
void RTMFPServer::run(const volatile bool& terminate) {
1 绑定地址
CumulusServer
的 IP 地址和端口:
SocketAddress address("0.0.0.0",_port);
_socket.bind(address,true);
绑定CumulusEdge
的 IP 地址和端口:
SocketAddress edgesAddress("0.0.0.0",_edgesPort);
if (_edgesPort>0)
_edgesSocket.bind(edgesAddress,true);
发送者(Client)的 IP 地址和端口:
SocketAddress sender;
UInt8 buff[PACKETRECV_SIZE];
int size = 0;
while (!terminate) {
bool stop=false;
bool idle = realTime(stop);
if(stop)
break;
_handshake.isEdges=false;
2 CumulusServer
接收数据:
CumulusServer
的 socket 有数据可读:
if (_socket.available() > 0) {
try {
从 socket 读取:
- 把数据存到 buff,
- 把发送者地址赋给 sender,
-
把所读长度返回给 size */
size = _socket.receiveFrom(buff,sizeof(buff),sender);
处理CumulusServer
的 socket 产生的异常:
} catch(Exception& ex) {
DEBUG("Main socket reception : %s",ex.displayText().c_str());
_socket.close();
_socket.bind(address,true);
continue;
}
2 如果CumulusEdge
端口存在且 edge socket 可用。
CumulusEdge
的 socket 有数据可读:
} else if (_edgesPort > 0 && _edgesSocket.available() > 0) {
try {
size = _edgesSocket.receiveFrom(buff, sizeof(buff), sender);
_handshake.isEdges = true;
} catch(Exception& ex) {
DEBUG("Main socket reception : %s", ex.displayText().c_str());
_edgesSocket.close();
_edgesSocket.bind(edgesAddress, true);
continue;
}
Edge* pEdge = edges(sender);
if (pEdge)
pEdge->update();
3 CumulusServer
和CumulusEdge
的 socket 都没有数据:
} else {
CumulusServer
空闲:
if (idle) {
主线程等待一秒。
Thread::sleep(1);
if (!_timeLastManage.isElapsed(_freqManage)) {
Just middle session
if (_middle) {
Sessions::Iterator it;
for (it = _sessions.begin(); it != _sessions.end(); ++it) {
Middle* pMiddle = dynamic_cast<Middle*>(it->second);
if (pMiddle)
pMiddle->manage();
}
}
} else {
_timeLastManage.update();
manage();
}
}
continue;
}
4 发送方的 ip 被禁:
if (isBanned(sender.host())) {
INFO("Data rejected because client %s is banned",
sender.host().toString().c_str());
continue;
}
5 数据包长度小于可能的最小值(12)
if (size < RTMFP_MIN_PACKET_SIZE) {
ERROR("Invalid packet");
continue;
}
PacketReader packet(buff,size);
Session* pSession = findSession(RTMFP::Unpack(packet));
if (!pSession)
continue;
if (!pSession->checked)
_handshake.commitCookie(*pSession);
给CumulusEdge
或者自己(CumulusServer
)的 socket:
pSession->setEndPoint(_handshake.isEdges ? _edgesSocket : _socket,sender);
pSession->receive(packet);
}
_handshake.clear();
_sessions.clear();
_socket.close();
if (_edgesPort>0)
_edgesSocket.close();
if(_pCirrus) {
delete _pCirrus;
_pCirrus = NULL;
}
}
-
转载请注明来自柳大的CSDN博客:Blog.CSDN.net/Poechant
-
分享到:
相关推荐
OpenRTMFP Cumulus Primer()入门介绍与部署CumulusServer.pdf
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
这本食谱在 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中给...
积云Cumulus 是的免费、开源替代品,它利用您自己的 S3 进行存储。下载您可以在下载最新版本更改默认截图目录这是可选的。 默认情况下,OS X 会将屏幕截图放在您的桌面上。 但是,如果您希望他们去其他地方,您可以...
积云框架 :open_book: 文献资料 最新文档。 文档。 更多信息 有关此项目的更多信息,以及有关NASA的地球观测系统数据和信息系统(EOSDIS)及其云工作的更多信息,请联系或访问 。...这是用于Cumulus开
用Lua编写HelloWorld应用扩展CumulusServer
不错的标签云,喜欢立体效果的博客主或者网站主可以试试看哦!强力推荐
大名鼎鼎的WP-CUMULUS 3D标签云,已经改成支持中文标签,可在.htm自行添加标签链接,可以单机玩耍测试,不需要安装WordPress然后装插件~~ 主要是有些童鞋只是想要3D标签云动画,所以就提取重要文件出来稍作修改下.
包括swfobject.js和tagcolud.swf中文支持文件。
NULL 博文链接:https://lullabyus.iteye.com/blog/790150
#资源达人分享计划#
Mellanox Cumulus学习,基本使用,培训资源
Flex P2P 音视频流客户端(Cumulus支持)
Cumulus集成测试项目[已弃用] 注意:此存储库不再维护。 该存储库的内容已移至。 什么是积云? Cumulus是NASA未来地球科学数据流的基于云的数据提取,存档,分发和管理原型。 阅读 安装 nvm use npm install 在...
以下是如何在IRIS Scientific OpenStack云上使用Magnum创建的Kubernetes集群的一些示例,例如: ://cumulus.openstack.hpc.cam.ac.uk 这是由STFC IRIS云提供资金的数字资产: : 贡献 如果您有任何问题,请提出一...
用于为 Cumulus API 生成和部署仪表板的代码。 文档 其他页面: 配置 仪表板由从 Cumulus API 检索到的数据填充。 在构建和部署仪表板之前,必须预先确定和设置 Cumulus API 的环境。 配置仪表板所需的信息可在app/...
集合了从NASA网站上搬过来的最新数据下载链接,下载工具wget for windows,高老师的下载攻略。 如果想要现成下好的GLDAS数据可以看我发布的另外一个资源(GLDASNOAH2009-2011)都是免费滴~ 希望CSDN别自己给我涨价...