amass/ZLMediaKit
1
0
Fork 0
mirror of https://github.com/ZLMediaKit/ZLMediaKit.git synced 2024-11-29 14:45:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

解决死锁问题

Browse Source
This commit is contained in:
xiongziliang 2020-03-04 21:57:31 +08:00
parent 6cc56a758a
commit f384f5e025
2 changed files with 45 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
src/Common/MediaSource.cpp
View File

@ -253,22 +253,25 @@ MediaSource::Ptr MediaSource::find(const string &schema, const string &vhost_tmp
vhost = DEFAULT_VHOST; vhost = DEFAULT_VHOST;
} }
lock_guard<recursive_mutex> lock(g_mtxMediaSrc);
MediaSource::Ptr ret; MediaSource::Ptr ret;
//查找某一媒体源，找到后返回 {
searchMedia(g_mapMediaSrc, schema, vhost, app, id, [&](SchemaVhostAppStreamMap::iterator &it0, lock_guard<recursive_mutex> lock(g_mtxMediaSrc);
VhostAppStreamMap::iterator &it1, //查找某一媒体源，找到后返回
AppStreamMap::iterator &it2, searchMedia(g_mapMediaSrc, schema, vhost, app, id, [&](SchemaVhostAppStreamMap::iterator &it0,
StreamMap::iterator &it3) { VhostAppStreamMap::iterator &it1,
ret = it3->second.lock(); AppStreamMap::iterator &it2,
if (!ret) { StreamMap::iterator &it3) {
//该对象已经销毁 ret = it3->second.lock();
it2->second.erase(it3); if (!ret) {
eraseIfEmpty(g_mapMediaSrc,it0, it1, it2); //该对象已经销毁
return false; it2->second.erase(it3);
} eraseIfEmpty(g_mapMediaSrc, it0, it1, it2);
return true; return false;
}); }
return true;
});
}
if(!ret && bMake){ if(!ret && bMake){
//未查找媒体源，则创建一个 //未查找媒体源，则创建一个
ret = MP4Reader::onMakeMediaSource(schema, vhost,app,id); ret = MP4Reader::onMakeMediaSource(schema, vhost,app,id);
@ -288,29 +291,34 @@ void MediaSource::regist() {
InfoL << _strSchema << " " << _strVhost << " " << _strApp << " " << _strId; InfoL << _strSchema << " " << _strVhost << " " << _strApp << " " << _strId;
NoticeCenter::Instance().emitEvent(Broadcast::kBroadcastMediaChanged, true, *this); NoticeCenter::Instance().emitEvent(Broadcast::kBroadcastMediaChanged, true, *this);
} }
bool MediaSource::unregist() {
//反注册该源
lock_guard<recursive_mutex> lock(g_mtxMediaSrc);
return searchMedia(g_mapMediaSrc, _strSchema, _strVhost, _strApp, _strId,[&](SchemaVhostAppStreamMap::iterator &it0,
VhostAppStreamMap::iterator &it1,
AppStreamMap::iterator &it2,
StreamMap::iterator &it3) {
auto strongMedia = it3->second.lock();
if (strongMedia && this != strongMedia.get()) {
//不是自己,不允许反注册
return false;
}
it2->second.erase(it3);
eraseIfEmpty(g_mapMediaSrc, it0, it1, it2);
unregisted();
return true;
});
}
void MediaSource::unregisted(){
InfoL << "" << _strSchema << " " << _strVhost << " " << _strApp << " " << _strId;
NoticeCenter::Instance().emitEvent(Broadcast::kBroadcastMediaChanged, false, *this);
}
//反注册该源
bool MediaSource::unregist() {
bool ret;
{
lock_guard<recursive_mutex> lock(g_mtxMediaSrc);
ret = searchMedia(g_mapMediaSrc, _strSchema, _strVhost, _strApp, _strId,
[&](SchemaVhostAppStreamMap::iterator &it0,
VhostAppStreamMap::iterator &it1,
AppStreamMap::iterator &it2,
StreamMap::iterator &it3) {
auto strongMedia = it3->second.lock();
if (strongMedia && this != strongMedia.get()) {
//不是自己,不允许反注册
return false;
}
it2->second.erase(it3);
eraseIfEmpty(g_mapMediaSrc, it0, it1, it2);
return true;
});
}
if(ret){
InfoL << "" << _strSchema << " " << _strVhost << " " << _strApp << " " << _strId;
NoticeCenter::Instance().emitEvent(Broadcast::kBroadcastMediaChanged, false, *this);
}
return ret;
}
/////////////////////////////////////MediaInfo////////////////////////////////////// /////////////////////////////////////MediaInfo//////////////////////////////////////

1
src/Common/MediaSource.h
View File

@ -151,7 +151,6 @@ public:
protected: protected:
void regist() ; void regist() ;
bool unregist() ; bool unregist() ;
void unregisted();
private: private:
string _strSchema; string _strSchema;
string _strVhost; string _strVhost;