Fixed a problem where Push sessions made by StreamMap didn't end auto…

…matically.
AirenSoft · Dec 23, 2024 · b2783ad · b2783ad
1 parent b071cb2
commit b2783ad
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/projects/publishers/push/push_application.cpp b/src/projects/publishers/push/push_application.cpp
@@ -85,7 +85,7 @@ namespace pub
 			auto pushes = GetPushesByStreamMap(stream_map.GetPath(), info);
 			for(auto &push : pushes)
 			{
-				StartPush(push);
+				StartPush(push, true);
 			}
 		}
 
@@ -129,7 +129,7 @@ namespace pub
 		return it->second;
 	}
 
-	std::shared_ptr<ov::Error> PushApplication::StartPush(const std::shared_ptr<info::Push> &push)
+	std::shared_ptr<ov::Error> PushApplication::StartPush(const std::shared_ptr<info::Push> &push, bool is_config)
 	{
 		ov::String error_message;
 
@@ -147,7 +147,7 @@ namespace pub
 
 		push->SetEnable(true);
 		push->SetRemove(false);
-		push->SetByConfig(false);
+		push->SetByConfig(is_config);
 
 		std::unique_lock<std::shared_mutex> lock(_push_map_mutex);
 		_pushes[push->GetId()] = push;

diff --git a/src/projects/publishers/push/push_application.h b/src/projects/publishers/push/push_application.h
@@ -43,7 +43,7 @@ namespace pub
 		bool DeleteStream(const std::shared_ptr<info::Stream> &info) override;
 
 	public:
-		std::shared_ptr<ov::Error> StartPush(const std::shared_ptr<info::Push> &push);
+		std::shared_ptr<ov::Error> StartPush(const std::shared_ptr<info::Push> &push, bool is_config = false);
 		std::shared_ptr<ov::Error> StopPush(const std::shared_ptr<info::Push> &push);
 		std::shared_ptr<ov::Error> GetPushes(const std::shared_ptr<info::Push> push, std::vector<std::shared_ptr<info::Push>> &results);