haiati/FaceRecognition
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Check playing pipeline method2

Browse Source
This commit is contained in:
Barzan Hayati 2025-07-05 17:53:26 +00:00
parent 3f50111715
commit 0969be1226
2 changed files with 23 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/pipeline_manager.cpp
View File

@ -155,7 +155,7 @@ void PipelineManager::get_fps_buffer_probe() {
gst_object_unref(sink_pad); gst_object_unref(sink_pad);
} }
void PipelineManager::playing_pipeline(int num_sources, char** url_camera) { bool PipelineManager::playing_pipeline(int num_sources, char** url_camera) {
/* Set the pipeline to "playing" state */ /* Set the pipeline to "playing" state */
g_print("Now playing... \n"); g_print("Now playing... \n");
@ -167,18 +167,28 @@ void PipelineManager::playing_pipeline(int num_sources, char** url_camera) {
GST_DEBUG_GRAPH_SHOW_ALL, GST_DEBUG_GRAPH_SHOW_ALL,
sink_manager->output_sink.c_str()); sink_manager->output_sink.c_str());
gst_element_set_state(pipeline, GST_STATE_PLAYING); gst_element_set_state(pipeline, GST_STATE_PLAYING);
GstStateChangeReturn ret =
gst_element_set_state(pipeline, GST_STATE_PLAYING);
if(ret == GST_STATE_CHANGE_FAILURE) {
g_printerr("Unable to set pipeline to playing.\n");
gst_object_unref(pipeline);
return false;
}
return true;
} }
void PipelineManager::check_playing_pipeline() { bool PipelineManager::check_playing_pipeline() {
// Verify pipeline state (add this immediately after starting) // Verify pipeline state (add this immediately after starting)
GstState state; GstState state;
GstStateChangeReturn ret = GstStateChangeReturn ret =
gst_element_get_state(pipeline, &state, NULL, GST_CLOCK_TIME_NONE); gst_element_get_state(pipeline, &state, NULL, GST_CLOCK_TIME_NONE);
if (ret == GST_STATE_CHANGE_FAILURE) { if (ret == GST_STATE_CHANGE_FAILURE) {
g_printerr("Failed to start pipeline!\n"); g_printerr("Failed to start pipeline!\n");
return false;
} else { } else {
g_print("Pipeline state: %d (1=NULL, 2=READY, 3=PAUSED, 4=PLAYING)\n", g_print("Pipeline state: %d (1=NULL, 2=READY, 3=PAUSED, 4=PLAYING)\n",
state); state);
return true;
} }
} }
@ -312,9 +322,15 @@ bool PipelineManager::create_pipeline_elements(int num_sources,
get_fps_buffer_probe(); get_fps_buffer_probe();
get_fps_probe(); get_fps_probe();
get_fps_osd(); get_fps_osd();
playing_pipeline(num_sources, url_camera); status_playing = playing_pipeline(num_sources, url_camera);
if (status_playing == false) {
return -1;
}
check_playing_pipeline(); status_playing = check_playing_pipeline();
if (status_playing == false) {
return -1;
}
rtsp_streaming_manager->start_rtsp_streaming(); rtsp_streaming_manager->start_rtsp_streaming();

5
src/pipeline_manager.hpp
View File

@ -47,7 +47,8 @@ class PipelineManager {
int create_pipeline(); int create_pipeline();
bool create_pipeline_elements(int, char **); bool create_pipeline_elements(int, char **);
bool setup_pipeline(); bool setup_pipeline();
void playing_pipeline(int, char **); bool playing_pipeline(int, char **);
bool status_playing;
void set_cuda_device(); void set_cuda_device();
static guint64 frame_count_osd_sink; static guint64 frame_count_osd_sink;
static guint64 frame_count_fps_probe; static guint64 frame_count_fps_probe;
@ -69,6 +70,6 @@ class PipelineManager {
void get_fps_buffer_probe(); void get_fps_buffer_probe();
void get_fps_probe(); void get_fps_probe();
void get_fps_osd(); void get_fps_osd();
void check_playing_pipeline(); bool check_playing_pipeline();
~PipelineManager(); ~PipelineManager();
}; };