Skip to content

RDKEMW-6776 Encrypted Pipeline Changes with SVPPAY on AAMP #196

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
suryaiyappan2k wants to merge 1 commit into
base: develop
Choose a base branch
from
Open

RDKEMW-6776 Encrypted Pipeline Changes with SVPPAY on AAMP #196

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
113 changes: 113 additions & 0 deletions InterfacePlayerRDK.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2080,6 +2080,7 @@ static void element_setup_cb(void *playbin, void *element, void *instance)
g_free(elemName);
}


/**
* @brief Initialize properties/callback of appsrc
* @param[in] _this pointer to InterfacePlayerRDK instance associated with the playback
Expand Down Expand Up @@ -2235,6 +2236,113 @@ GstFlowReturn InterfacePlayerRDK_OnVideoSample(GstElement* object, void *_this)
return GST_FLOW_OK;
}

// Pad probe callback
static GstPadProbeReturn
on_decryptor_src_pad_event(GstPad *pad, GstPadProbeInfo *info, gpointer user_data)
{
g_print("patch 0005 applied: surya - on_decryptor_src_pad_event\n");
GstEvent *event = GST_PAD_PROBE_INFO_EVENT(info);

if (!(GST_PAD_PROBE_INFO_TYPE(info) & GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM))
return GST_PAD_PROBE_OK;

if (GST_EVENT_TYPE(event) != GST_EVENT_CAPS)
{
return GST_PAD_PROBE_OK;
}

GstElement *decryptor = GST_ELEMENT(user_data);
GstPad *srcpad = gst_element_get_static_pad(decryptor, "src");
if (!srcpad)
{
MW_LOG_ERR("Failed to retrieve 'src' pad from decryptor '%s'.", GST_ELEMENT_NAME(decryptor));
g_print("patch 0005 applied: surya - failed to retrieve src pad from decryptor %s\n", GST_ELEMENT_NAME(decryptor));
return GST_PAD_PROBE_REMOVE;
}

GstPad *peer = gst_pad_get_peer(srcpad);
if (!peer)
{
MW_LOG_ERR("No downstream peer connected to decryptor '%s'.", GST_ELEMENT_NAME(decryptor));
gst_object_unref(srcpad);
return GST_PAD_PROBE_REMOVE;
}

GstElement *parent = GST_ELEMENT(gst_element_get_parent(decryptor));
if (!parent)
{
MW_LOG_ERR("Failed to get parent bin of decryptor '%s'.", GST_ELEMENT_NAME(decryptor));
g_print("patch 0005 applied: surya - failed to get parent bin of decryptor %s\n", GST_ELEMENT_NAME(decryptor));
gst_object_unref(srcpad);
gst_object_unref(peer);
return GST_PAD_PROBE_REMOVE;
}

GstElement *svppay = gst_element_factory_make("svppay", NULL);
if (!svppay)
{
MW_LOG_ERR("Failed to create 'svppay' element.");
g_print("patch 0005 applied: surya - failed to create svppay element\n");
gst_object_unref(srcpad);
gst_object_unref(peer);
return GST_PAD_PROBE_REMOVE;
}
g_print("patch 0005 applied: surya - successfully created svppay element\n");

gst_bin_add(GST_BIN(parent), svppay);
gst_element_sync_state_with_parent(svppay);

GstPad *svppay_sink = gst_element_get_static_pad(svppay, "sink");
GstPad *svppay_src = gst_element_get_static_pad(svppay, "src");

if (!gst_pad_unlink(srcpad, peer))
{
MW_LOG_ERR("Failed to unlink decryptor '%s' from its peer.", GST_ELEMENT_NAME(decryptor));
}

if (gst_pad_link(srcpad, svppay_sink) != GST_PAD_LINK_OK)
{
MW_LOG_ERR("Failed to link decryptor '%s' to svppay.", GST_ELEMENT_NAME(decryptor));
}
else if (gst_pad_link(svppay_src, peer) != GST_PAD_LINK_OK)
{
MW_LOG_ERR("Failed to link svppay to downstream peer.");
}
else
{
MW_LOG_INFO("'svppay' inserted after decryptor '%s'.", GST_ELEMENT_NAME(decryptor));
g_print("patch 0005 applied: surya - svppay inserted after decryptor %s\n", GST_ELEMENT_NAME(decryptor));
}

gst_object_unref(srcpad);
gst_object_unref(peer);
gst_object_unref(svppay_sink);
gst_object_unref(svppay_src);

return GST_PAD_PROBE_REMOVE; // done with the probe
}

static void element_setup_cb_svppay(GstElement *playbin, GstElement *element, gpointer user_data)
{
const gchar *name = gst_element_get_name(element);
g_print("Patch applied: surya - element_setup_cb_svppay\n");
MW_LOG_INFO("surya - Received element: %s", name);

if (name && strstr(name, "decryptor"))
{
GstPad *srcpad = gst_element_get_static_pad(element, "src");
if (!srcpad)
{
MW_LOG_ERR("Unable to retrieve 'src' pad from element: %s\n", GST_ELEMENT_NAME(element));
g_print("patch 0005 surya: unable to retrieve src pad from element %s\n", GST_ELEMENT_NAME(element));
return;
}
gst_pad_add_probe(srcpad, GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM,
on_decryptor_src_pad_event, element, NULL);
gst_object_unref(srcpad);
}
}

/**
* @fn SetupClosedCaptionControlStream
*/
Expand Down Expand Up @@ -2524,6 +2632,11 @@ int InterfacePlayerRDK::SetupStream(int streamId, void *playerInstance, std::st
// Send the media_stream object so that qtdemux can be instantly mapped to media type without caps/parent check
g_signal_connect(stream->sinkbin, "element_setup", G_CALLBACK(element_setup_cb), pInterfacePlayerRDK);
}
if (eGST_MEDIATYPE_VIDEO == streamId)
{
g_print("surya - patch applied: SVPPAY callback started\n");
g_signal_connect(stream->sinkbin, "element_setup", G_CALLBACK(element_setup_cb_svppay), pInterfacePlayerRDK);
}
Comment on lines +2635 to +2639
if (eGST_MEDIATYPE_VIDEO == streamId && (mediaFormat==eGST_MEDIAFORMAT_DASH || mediaFormat==eGST_MEDIAFORMAT_HLS_MP4))
{
// enable multiqueue
Expand Down
Loading
Loading