Dispose source when no publishers.

winlinvip · Jun 13, 2024 · 05dbbbe · 05dbbbe
1 parent e1aeccb
commit 05dbbbe
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/trunk/src/app/srs_app_srt_source.cpp b/trunk/src/app/srs_app_srt_source.cpp
@@ -970,8 +970,8 @@ void SrsSrtSource::on_consumer_destroy(SrsSrtConsumer* consumer)
         it = consumers.erase(it);
     }
 
-    // Destroy and cleanup source when no consumers.
-    if (consumers.empty()) {
+    // Destroy and cleanup source when no publishers and consumers.
+    if (can_publish_ && consumers.empty()) {
         _srs_srt_sources->eliminate(req);
     }
 }
@@ -1027,6 +1027,11 @@ void SrsSrtSource::on_unpublish()
         bridge_->on_unpublish();
         srs_freep(bridge_);
     }
+
+    // Destroy and cleanup source when no publishers and consumers.
+    if (can_publish_ && consumers.empty()) {
+        _srs_srt_sources->eliminate(req);
+    }
 }
 
 srs_error_t SrsSrtSource::on_packet(SrsSrtPacket* packet)