weiai/ZLMediaKit
1
0
Fork 0
mirror of https://github.com/ZLMediaKit/ZLMediaKit.git synced 2026-03-21 21:40:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

修复getMediaList接口线程安全问题 (#4526)

Browse Source
This commit is contained in:
xia-chu
2025-10-30 11:20:04 +08:00
parent c9d3c5b516
commit 68cc757708
1 changed files with 16 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
server/WebApi.cpp
View File

@@ -913,21 +913,24 @@ void installWebApi() {
CHECK_SECRET();
// 获取所有MediaSource列表 [AUTO-TRANSLATED:7bf16dc2]
// Get all MediaSource lists
bool first = true;
std::shared_ptr<Json::Value> done(new Json::Value(val), [invoker, headerOut](Json::Value *val) {
invoker(200, headerOut, val->toStyledString());
delete val;
});
std::list<MediaSource::Ptr> lst;
MediaSource::for_each_media([&](const MediaSource::Ptr &media) {
if (first) {
first = false;
media->getOwnerPoller()->async([media, done]() mutable {
(*done)["data"].append(makeMediaSourceJson(*media));
});
} else {
(*done)["data"].append(makeMediaSourceJson(*media));
}
lst.emplace_back(media);
}, allArgs["schema"], allArgs["vhost"], allArgs["app"], allArgs["stream"]);
if (lst.size() == 1) {
// 如果是搜索单一流，那么在它的归属线程中执行，用于获取丢包率参数
auto front = std::move(lst.front());
front->getOwnerPoller()->async([=]() mutable {
val["data"].append(makeMediaSourceJson(*front));
invoker(200, headerOut, val.toStyledString());
});
} else {
for (auto &media : lst) {
val["data"].append(makeMediaSourceJson(*media));
}
invoker(200, headerOut, val.toStyledString());
}
});
// 测试url http://127.0.0.1/index/api/isMediaOnline?schema=rtsp&vhost=__defaultVhost__&app=live&stream=obs [AUTO-TRANSLATED:126a75e8]