确保断连续推功能开启后流能正常强制关闭 (#4287)

src/Common/MultiMediaSourceMuxer.cpp

@@ -513,6 +513,18 @@ EventPoller::Ptr MultiMediaSourceMuxer::getOwnerPoller(MediaSource &sender) {
     }
 }
 
+bool MultiMediaSourceMuxer::close(MediaSource &sender) {
+    _rtmp = nullptr;
+    _rtsp = nullptr;
+    _fmp4 = nullptr;
+    _ts = nullptr;
+    _mp4 = nullptr;
+    _hls = nullptr;
+    _hls_fmp4 = nullptr;
+    _rtp_sender.clear();
+    return true;
+}
+
 std::shared_ptr<MultiMediaSourceMuxer> MultiMediaSourceMuxer::getMuxer(MediaSource &sender) const {
     return const_cast<MultiMediaSourceMuxer*>(this)->shared_from_this();
 }

src/Common/MultiMediaSourceMuxer.h

@@ -182,6 +182,12 @@ public:
      */
     toolkit::EventPoller::Ptr getOwnerPoller(MediaSource &sender) override;
     
+    /**
+     * 关闭流
+     * @return 是否成功
+     */
+    bool close(MediaSource &sender) override;
+
     /**
      * 获取本对象
      * Get this object