From 8cd6814bc53f3efaa781c98aed6149a680855616 Mon Sep 17 00:00:00 2001 From: Keukhan Date: Wed, 21 Aug 2024 03:45:18 +0900 Subject: [PATCH] Added Push state (Connecting) --- src/projects/base/info/push.cpp | 2 ++ src/projects/base/info/push.h | 1 + src/projects/publishers/push/push_session.cpp | 5 ++++- 3 files changed, 7 insertions(+), 1 deletion(-) diff --git a/src/projects/base/info/push.cpp b/src/projects/base/info/push.cpp index e254918e4..9f5ddc8bd 100755 --- a/src/projects/base/info/push.cpp +++ b/src/projects/base/info/push.cpp @@ -266,6 +266,8 @@ namespace info { case PushState::Ready: return "ready"; + case PushState::Connecting: + return "connecting"; case PushState::Pushing: return "pushing"; case PushState::Stopping: diff --git a/src/projects/base/info/push.h b/src/projects/base/info/push.h index 5d38606ae..0cc57c393 100755 --- a/src/projects/base/info/push.h +++ b/src/projects/base/info/push.h @@ -17,6 +17,7 @@ namespace info enum class PushState : int8_t { Ready, + Connecting, Pushing, Stopping, Stopped, diff --git a/src/projects/publishers/push/push_session.cpp b/src/projects/publishers/push/push_session.cpp index 1cec6d26f..acfc4c80d 100755 --- a/src/projects/publishers/push/push_session.cpp +++ b/src/projects/publishers/push/push_session.cpp @@ -45,7 +45,8 @@ namespace pub bool PushSession::Start() { GetPush()->UpdatePushStartTime(); - GetPush()->SetState(info::Push::PushState::Pushing); + GetPush()->SetState(info::Push::PushState::Connecting); + ov::String rtmp_url; if (GetPush()->GetStreamKey().IsEmpty()) @@ -120,6 +121,8 @@ namespace pub return false; } + GetPush()->SetState(info::Push::PushState::Pushing); + logtd("PushSession(%d) has started.", GetId()); return Session::Start();