From 87dd1c7f7ffe9ed20b60811ef6d1964ebeeea59a Mon Sep 17 00:00:00 2001
From: xiongguangjie <xiong_panda@163.com>
Date: Sat, 2 Jul 2022 12:33:32 +0800
Subject: [PATCH] avoid loopback ffmpeg push stream exit receive deleteStream
 message after broken pipe

---
 src/Rtmp/RtmpSession.cpp | 6 +++++-
 src/Rtmp/RtmpSession.h   | 2 ++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/Rtmp/RtmpSession.cpp b/src/Rtmp/RtmpSession.cpp
index 81a71c11..88333fd8 100644
--- a/src/Rtmp/RtmpSession.cpp
+++ b/src/Rtmp/RtmpSession.cpp
@@ -50,7 +50,7 @@ void RtmpSession::onError(const SockException& err) {
         _push_src_ownership = nullptr;
         //延时10秒注销流
         auto push_src = std::move(_push_src);
-        getPoller()->doDelayTask(_continue_push_ms, [push_src]() { return 0; });
+        _delay_unregister_task = getPoller()->doDelayTask(_continue_push_ms, [push_src]() { return 0; });
     }
 }
 
@@ -223,6 +223,10 @@ void RtmpSession::onCmd_deleteStream(AMFDecoder &dec) {
                  "code", "NetStream.Unpublish.Success",
                  "description", "Stop publishing." });
     //_push_src = nullptr;
+    //TraceL<<" delete stream";
+    if(_delay_unregister_task){
+            _delay_unregister_task->cancel();
+    }
     throw std::runtime_error(StrPrinter << "Stop publishing" << endl);
 }
 
diff --git a/src/Rtmp/RtmpSession.h b/src/Rtmp/RtmpSession.h
index c6367d35..5289a43f 100644
--- a/src/Rtmp/RtmpSession.h
+++ b/src/Rtmp/RtmpSession.h
@@ -103,6 +103,8 @@ private:
     std::weak_ptr<RtmpMediaSource> _play_src;
     AMFValue _push_metadata;
     RtmpMediaSourceImp::Ptr _push_src;
+    //延迟注销任务
+    toolkit::EventPoller::DelayTask::Ptr _delay_unregister_task;
     std::shared_ptr<void> _push_src_ownership;
     RtmpMediaSource::RingType::RingReader::Ptr _ring_reader;
 };