提交 7e876632 authored 作者: blu's avatar blu

big refacting of communitation architect

上级 ca129051
......@@ -167,9 +167,9 @@ class EvDaemon{
this->peerData["status"].erase(k);
}
if(this->peerData["config"].count(k) != 0){
this->peerData["config"].erase(k);
}
// if(this->peerData["config"].count(k) != 0){
// this->peerData["config"].erase(k);
// }
if(this->peerData["pids"].count(k) != 0) {
this->peerData["pids"].erase(k);
}
......@@ -280,9 +280,9 @@ class EvDaemon{
if(peerData["pids"].count(selfId) != 0) {
peerData["pids"].erase(selfId);
}
if(peerData["config"].count(selfId) != 0) {
peerData["config"].erase(selfId);
}
// if(peerData["config"].count(selfId) != 0) {
// peerData["config"].erase(selfId);
// }
spdlog::warn("evdaemon {} peer disconnected: {}", devSn, selfId);
// restart this module
......
......@@ -246,14 +246,14 @@ protected:
void run()
{
int ret = 0;
// AVDictionary * optsIn;
// av_dict_set(&optsIn, "timeout", "7", 0);
AVDictionary * optsIn;
av_dict_set(&optsIn, "rtsp_transport", "tcp", 0);
spdlog::info("evpuller {} openning stream: {}", selfId, urlIn);
if ((ret = avformat_open_input(&pAVFormatInput, urlIn.c_str(), NULL, NULL)) < 0) {
if ((ret = avformat_open_input(&pAVFormatInput, urlIn.c_str(), NULL, &optsIn)) < 0) {
spdlog::error("Could not open input stream {}", urlIn);
}
spdlog::info("evpuller {} finding sgtream info: {}", selfId, urlIn);
spdlog::info("evpuller {} finding stream info: {}", selfId, urlIn);
if ((ret = avformat_find_stream_info(pAVFormatInput, NULL)) < 0) {
spdlog::error("Failed to retrieve input stream information");
}
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论