完成HLS按需生成流

src/Record/HlsMediaSource.cpp

@@ -30,20 +30,31 @@ namespace mediakit{
 
 
 HlsCookieData::HlsCookieData(const MediaInfo &info) {
 HlsCookieData::HlsCookieData(const MediaInfo &info) {
     _info = info;
     _info = info;
-    auto src = dynamic_pointer_cast<HlsMediaSource>(MediaSource::find(HLS_SCHEMA,_info._vhost,_info._app,_info._streamid));
-    if(src){
-        src->modifyCount(true);
+    addReaderCount();
+}
+
+void HlsCookieData::addReaderCount(){
+    if(!_added){
+        auto src = dynamic_pointer_cast<HlsMediaSource>(MediaSource::find(HLS_SCHEMA,_info._vhost,_info._app,_info._streamid));
+        if(src){
+            src->modifyReaderCount(true);
+            _added = true;
+        }
     }
     }
+
 }
 }
 
 
 HlsCookieData::~HlsCookieData() {
 HlsCookieData::~HlsCookieData() {
-    auto src = dynamic_pointer_cast<HlsMediaSource>(MediaSource::find(HLS_SCHEMA,_info._vhost,_info._app,_info._streamid));
-    if(src){
-        src->modifyCount(false);
+    if(_added){
+        auto src = dynamic_pointer_cast<HlsMediaSource>(MediaSource::find(HLS_SCHEMA,_info._vhost,_info._app,_info._streamid));
+        if(src){
+            src->modifyReaderCount(false);
+        }
     }
     }
 }
 }
 
 
 void HlsCookieData::addByteUsage(uint64_t bytes) {
 void HlsCookieData::addByteUsage(uint64_t bytes) {
+    addReaderCount();
     _bytes += bytes;
     _bytes += bytes;
 }
 }
 
 

src/Record/HlsMediaSource.h

@@ -36,8 +36,11 @@ public:
     ~HlsCookieData();
     ~HlsCookieData();
     void addByteUsage(uint64_t bytes);
     void addByteUsage(uint64_t bytes);
 private:
 private:
+    void addReaderCount();
+private:
     uint64_t _bytes = 0;
     uint64_t _bytes = 0;
     MediaInfo _info;
     MediaInfo _info;
+    bool _added = false;
 };
 };
 
 
 class HlsMediaSource : public MediaSource {
 class HlsMediaSource : public MediaSource {
@@ -73,7 +76,7 @@ private:
      * 修改观看者个数
      * 修改观看者个数
      * @param add 添加海思删除
      * @param add 添加海思删除
      */
      */
-    void modifyCount(bool add) {
+    void modifyReaderCount(bool add) {
         if (add) {
         if (add) {
             ++_readerCount;
             ++_readerCount;
             return;
             return;