修复流注销时,hls无法播完最后一个切片的问题: #1955

This commit is contained in:
ziyue 2022-10-18 19:23:20 +08:00
parent eac5a5b1dc
commit ff6e9f4fc7
4 changed files with 14 additions and 6 deletions

View File

@ -110,7 +110,7 @@ segRetain=5
#是否广播 ts 切片完成通知
broadcastRecordTs=0
#直播hls文件删除延时单位秒issue: #913
deleteDelaySec=0
deleteDelaySec=10
#是否保留hls文件此功能部分等效于segNum=0的情况
#不同的是这个保留不会在m3u8文件中体现
#0为不保留不起作用

View File

@ -274,7 +274,7 @@ static onceToken token([]() {
mINI::Instance()[kFileBufSize] = 64 * 1024;
mINI::Instance()[kFilePath] = "./www";
mINI::Instance()[kBroadcastRecordTs] = false;
mINI::Instance()[kDeleteDelaySec] = 0;
mINI::Instance()[kDeleteDelaySec] = 10;
});
} // namespace Hls

View File

@ -91,8 +91,8 @@ public:
*
*/
template <class T>
const T& getAttach() const {
return *static_cast<const T *>(_attach.get());
T& getAttach() {
return *static_cast<T *>(_attach.get());
}
private:

View File

@ -33,8 +33,9 @@ static int kHlsCookieSecond = 60;
static const string kCookieName = "ZL_COOKIE";
static const string kHlsSuffix = "/hls.m3u8";
class HttpCookieAttachment {
public:
struct HttpCookieAttachment {
//是否已经查找到过MediaSource
bool _find_src = false;
//cookie生效作用域本cookie只对该目录下的文件生效
string _path;
//上次鉴权失败信息,为空则上次鉴权成功
@ -425,6 +426,11 @@ static void accessFile(TcpSession &sender, const Parser &parser, const MediaInfo
response_file(cookie, cb, file_path, parser, src->getIndexFile());
return;
}
if (cookie->getAttach<HttpCookieAttachment>()._find_src) {
//查找过MediaSource但是流已经注销了不用再查找
response_file(cookie, cb, file_path, parser);
return;
}
//hls流可能未注册MediaSource::findAsync可以触发not_found事件然后再按需推拉流
MediaSource::findAsync(media_info, strongSession, [response_file, cookie, cb, file_path, parser](const MediaSource::Ptr &src) {
@ -439,6 +445,8 @@ static void accessFile(TcpSession &sender, const Parser &parser, const MediaInfo
attach._hls_data->setMediaSource(hls);
//添加HlsMediaSource的观看人数(HLS是按需生成的这样可以触发HLS文件的生成)
attach._hls_data->addByteUsage(0);
//标记找到MediaSource
attach._find_src = true;
// m3u8文件可能不存在, 等待m3u8索引文件按需生成
hls->getIndexFile([response_file, file_path, cookie, cb, parser](const string &file) {