Skip to content

Commit

Permalink
Update pipeline to increase gstreamer performance
Browse files Browse the repository at this point in the history
  • Loading branch information
@joaofigueiredobisect
joaofigueiredobisect committed Sep 19, 2024
1 parent 5e41bc9 commit 4e9a9a7
Show file tree
Hide file tree
Showing 2 changed files with 28 additions and 10 deletions.
30 changes: 23 additions & 7 deletions cpp/libs/ossrf_gstreamer_api/lib/src/receiver/st2110_20_receiver_plugin.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -41,45 +41,61 @@ struct gst_st2110_20_receiver_impl : gst_receiver_plugin_t
auto* source = gst_element_factory_make("udpsrc", NULL);
BST_ENFORCE(source != nullptr, "Failed creating GStreamer element udpsrc");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), source), "Failed adding udpsrc to the pipeline");

// Set udp source params
g_object_set(G_OBJECT(source), "address", s_.primary.source_ip_address.c_str(), NULL);
g_object_set(G_OBJECT(source), "auto-multicast", TRUE, NULL);
g_object_set(G_OBJECT(source), "port", s_.primary.source_port, NULL);
g_object_set(G_OBJECT(source), "multicast-iface", s_.primary.interface_name.c_str(), NULL);

// Create and set caps for udp source
GstCaps* caps = gst_caps_from_string(
"application/x-rtp, media=(string)video, clock-rate=(int)90000, encoding-name=(string)RAW, "
"sampling=(string)RGB, width=(string)640, height=(string)480");
g_object_set(G_OBJECT(source), "caps", caps, NULL);

// Add pipeline rtpjitterbuffer
// Add pipeline rtp jitter buffer
auto* jitter_buffer = gst_element_factory_make("rtpjitterbuffer", NULL);
BST_ENFORCE(jitter_buffer != nullptr, "Failed creating GStreamer element jitter_buffer");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), jitter_buffer), "Failed adding jitter_buffer to the pipeline");

// Add pipeline queue1
// Add pipeline queue
auto* queue1 = gst_element_factory_make("queue", NULL);
BST_ENFORCE(queue1 != nullptr, "Failed creating GStreamer element queue");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), queue1), "Failed adding queue to the pipeline");
g_object_set(queue1, "max-size-buffers", 3, NULL);

// Add pipeline rtp depay
// Add pipeline rtp depayloader
auto* depay = gst_element_factory_make("rtpvrawdepay", NULL);
BST_ENFORCE(depay != nullptr, "Failed creating GStreamer element depay");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), depay), "Failed adding depay to the pipeline");

// Add pipeline queue
auto* queue2 = gst_element_factory_make("queue", NULL);
BST_ENFORCE(queue2 != nullptr, "Failed creating GStreamer element queue");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), queue2), "Failed adding queue to the pipeline");
g_object_set(queue2, "max-size-buffers", 3, NULL);

// Add pipeline videoconvert
auto* videoconvert = gst_element_factory_make("videoconvert", NULL);
BST_ENFORCE(videoconvert != nullptr, "Failed creating GStreamer element converter");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), videoconvert), "Failed adding converter to the pipeline");

// Add pipeline queue
auto* queue3 = gst_element_factory_make("queue", NULL);
BST_ENFORCE(queue3 != nullptr, "Failed creating GStreamer element queue");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), queue3), "Failed adding queue to the pipeline");
g_object_set(queue3, "max-size-buffers", 3, NULL);

// Add pipeline video sink
auto* sink = gst_element_factory_make("autovideosink", NULL);
BST_ENFORCE(sink != nullptr, "Failed creating GStreamer element sink");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), sink), "Failed adding sink to the pipeline");

// Link elements
BST_ENFORCE(gst_element_link_many(source, jitter_buffer, queue1, depay, videoconvert, sink, NULL),
"Failed linking GStreamer video pipeline");
// Link all elements together
BST_ENFORCE(
gst_element_link_many(source, jitter_buffer, queue1, depay, queue2, videoconvert, queue3, sink, NULL),
"Failed linking GStreamer video pipeline");

// Setup runner
pipeline_.run_loop();
Expand All @@ -103,4 +119,4 @@ expected<gst_receiver_plugin_uptr> ossrf::gst::plugins::create_gst_st2110_20_plu
BST_CHECK(i->create_gstreamer_pipeline());

return i;
}
}
8 changes: 5 additions & 3 deletions cpp/libs/ossrf_gstreamer_api/lib/src/sender/st2110_20_sender_plugin.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -55,22 +55,24 @@ struct gst_st2110_20_sender_impl : gst_sender_plugin_t
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), capsfilter), "Failed adding capsfilter to the pipeline");
gst_caps_unref(caps);

// Add pipeline queue1
// Add pipeline queue1 with optimized buffer size
auto* queue1 = gst_element_factory_make("queue", NULL);
BST_ENFORCE(queue1 != nullptr, "Failed creating GStreamer element queue");
g_object_set(G_OBJECT(queue1), "max-size-buffers", 3, NULL);
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), queue1), "Failed adding queue to the pipeline");

// Add pipeline rtpvrawpay
auto* rtpvrawpay = gst_element_factory_make("rtpvrawpay", NULL);
BST_ENFORCE(rtpvrawpay != nullptr, "Failed creating GStreamer element rtpvrawpay");
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), rtpvrawpay), "Failed adding rtpvrawpay to the pipeline");

// Add pipeline queue2
// Add pipeline queue2 with optimized buffer size
auto* queue2 = gst_element_factory_make("queue", NULL);
BST_ENFORCE(queue2 != nullptr, "Failed creating GStreamer element queue");
g_object_set(G_OBJECT(queue2), "max-size-buffers", 3, NULL);
BST_ENFORCE(gst_bin_add(GST_BIN(pipeline), queue2), "Failed adding queue to the pipeline");

// Add pipeline udpsink
// Add pipeline udpsink with increased buffer size
auto* udpsink = gst_element_factory_make("udpsink", NULL);
BST_ENFORCE(udpsink != nullptr, "Failed creating GStreamer element udpsink");
// Set properties
Expand Down

0 comments on commit 4e9a9a7

Please sign in to comment.