mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-07-16 03:18:29 +00:00
ef16d7558f
This adds two properties: * scte-35-pid: If not 0, enables the SCTE-35 support for the current program. This will write the proper PMT and send SCTE-35 NULL commands (i.e. heartbeats) at a regular interval * scte-35-null-interval: This specifies the interval at which the NULL commands should be sent Sending SCTE-35 commands is done by creating the appropriate SCTE-35 GstMpegtsSection and then sending them on the muxer. See the associated example
102 lines
2.4 KiB
C
102 lines
2.4 KiB
C
#include <gst/gst.h>
|
|
#include <gst/mpegts/mpegts.h>
|
|
|
|
/* 45s stream
|
|
* Send scte-35 NULL packets every 5s
|
|
* Use PID 123 for SCTE-35 */
|
|
#define PIPELINE_STR "videotestsrc is-live=True num-buffers=1350 ! video/x-raw,framerate=30/1 ! x264enc tune=zerolatency ! queue ! mpegtsmux name=mux scte-35-pid=123 scte-35-null-interval=450000 ! filesink location=test-scte.ts"
|
|
|
|
static void
|
|
_on_bus_message (GstBus * bus, GstMessage * message, GMainLoop * mainloop)
|
|
{
|
|
switch (GST_MESSAGE_TYPE (message)) {
|
|
case GST_MESSAGE_ERROR:
|
|
case GST_MESSAGE_EOS:
|
|
g_main_loop_quit (mainloop);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
static void
|
|
send_splice (GstElement * mux, gboolean out)
|
|
{
|
|
GstMpegtsSCTESIT *sit;
|
|
GstMpegtsSection *section;
|
|
|
|
g_print ("Sending Splice %s event\n", out ? "Out" : "In");
|
|
|
|
/* Splice is at 5s for 30s */
|
|
if (out)
|
|
sit = gst_mpegts_scte_splice_out_new (1, 5 * 90000, 30 * 90000);
|
|
else
|
|
sit = gst_mpegts_scte_splice_in_new (2, 35 * 90000);
|
|
|
|
section = gst_mpegts_section_from_scte_sit (sit, 123);
|
|
gst_mpegts_section_send_event (section, mux);
|
|
gst_mpegts_section_unref (section);
|
|
}
|
|
|
|
static gboolean
|
|
send_splice_in (GstElement * mux)
|
|
{
|
|
send_splice (mux, FALSE);
|
|
|
|
return G_SOURCE_REMOVE;
|
|
}
|
|
|
|
static gboolean
|
|
send_splice_out (GstElement * mux)
|
|
{
|
|
send_splice (mux, TRUE);
|
|
|
|
/* In 30s send the splice-in one */
|
|
g_timeout_add_seconds (30, (GSourceFunc) send_splice_in, mux);
|
|
|
|
return G_SOURCE_REMOVE;
|
|
}
|
|
|
|
int
|
|
main (int argc, char **argv)
|
|
{
|
|
GstElement *pipeline = NULL;
|
|
GError *error = NULL;
|
|
GstBus *bus;
|
|
GMainLoop *mainloop;
|
|
GstElement *mux;
|
|
|
|
gst_init (&argc, &argv);
|
|
gst_mpegts_initialize ();
|
|
|
|
pipeline = gst_parse_launch (PIPELINE_STR, &error);
|
|
if (error) {
|
|
g_print ("pipeline could not be constructed: %s\n", error->message);
|
|
g_clear_error (&error);
|
|
return 1;
|
|
}
|
|
|
|
mainloop = g_main_loop_new (NULL, FALSE);
|
|
|
|
mux = gst_bin_get_by_name (GST_BIN (pipeline), "mux");
|
|
/* Send splice-out 1s in */
|
|
g_timeout_add_seconds (1, (GSourceFunc) send_splice_out, mux);
|
|
gst_object_unref (mux);
|
|
|
|
/* Put a bus handler */
|
|
bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
|
|
gst_bus_add_signal_watch (bus);
|
|
g_signal_connect (bus, "message", (GCallback) _on_bus_message, mainloop);
|
|
|
|
/* Start pipeline */
|
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
|
g_main_loop_run (mainloop);
|
|
|
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
|
|
|
gst_object_unref (pipeline);
|
|
gst_object_unref (bus);
|
|
|
|
return 0;
|
|
}
|