TrackPrivateBaseGStreamer.cpp [plain text]
#include "config.h"
#if ENABLE(VIDEO) && USE(GSTREAMER) && ENABLE(VIDEO_TRACK)
#include "TrackPrivateBaseGStreamer.h"
#include "GStreamerUtilities.h"
#include "Logging.h"
#include "TrackPrivateBase.h"
#include <glib-object.h>
#include <gst/gst.h>
#include <gst/tag/tag.h>
#include <wtf/glib/GUniquePtr.h>
#include <wtf/text/CString.h>
GST_DEBUG_CATEGORY_EXTERN(webkit_media_player_debug);
#define GST_CAT_DEFAULT webkit_media_player_debug
namespace WebCore {
TrackPrivateBaseGStreamer::TrackPrivateBaseGStreamer(TrackPrivateBase* owner, gint index, GRefPtr<GstPad> pad)
: m_notifier(MainThreadNotifier<MainThreadNotification>::create())
, m_index(index)
, m_pad(pad)
, m_owner(owner)
{
ASSERT(m_pad);
g_signal_connect_swapped(m_pad.get(), "notify::active", G_CALLBACK(activeChangedCallback), this);
g_signal_connect_swapped(m_pad.get(), "notify::tags", G_CALLBACK(tagsChangedCallback), this);
tagsChanged();
}
TrackPrivateBaseGStreamer::~TrackPrivateBaseGStreamer()
{
disconnect();
m_notifier->invalidate();
}
void TrackPrivateBaseGStreamer::disconnect()
{
if (!m_pad)
return;
m_notifier->cancelPendingNotifications();
g_signal_handlers_disconnect_matched(m_pad.get(), G_SIGNAL_MATCH_DATA, 0, 0, nullptr, nullptr, this);
m_pad.clear();
m_tags.clear();
}
void TrackPrivateBaseGStreamer::activeChangedCallback(TrackPrivateBaseGStreamer* track)
{
track->m_notifier->notify(MainThreadNotification::ActiveChanged, [track] { track->notifyTrackOfActiveChanged(); });
}
void TrackPrivateBaseGStreamer::tagsChangedCallback(TrackPrivateBaseGStreamer* track)
{
track->tagsChanged();
}
void TrackPrivateBaseGStreamer::tagsChanged()
{
GRefPtr<GstTagList> tags;
if (g_object_class_find_property(G_OBJECT_GET_CLASS(m_pad.get()), "tags"))
g_object_get(m_pad.get(), "tags", &tags.outPtr(), nullptr);
else
tags = adoptGRef(gst_tag_list_new_empty());
{
LockHolder lock(m_tagMutex);
m_tags.swap(tags);
}
m_notifier->notify(MainThreadNotification::TagsChanged, [this] { notifyTrackOfTagsChanged(); });
}
void TrackPrivateBaseGStreamer::notifyTrackOfActiveChanged()
{
if (!m_pad)
return;
gboolean active = false;
if (m_pad && g_object_class_find_property(G_OBJECT_GET_CLASS(m_pad.get()), "active"))
g_object_get(m_pad.get(), "active", &active, nullptr);
setActive(active);
}
bool TrackPrivateBaseGStreamer::getLanguageCode(GstTagList* tags, AtomicString& value)
{
String language;
if (getTag(tags, GST_TAG_LANGUAGE_CODE, language)) {
language = gst_tag_get_language_code_iso_639_1(language.utf8().data());
GST_INFO("Converted track %d's language code to %s.", m_index, language.utf8().data());
if (language != value) {
value = language;
return true;
}
}
return false;
}
template<class StringType>
bool TrackPrivateBaseGStreamer::getTag(GstTagList* tags, const gchar* tagName, StringType& value)
{
GUniqueOutPtr<gchar> tagValue;
if (gst_tag_list_get_string(tags, tagName, &tagValue.outPtr())) {
GST_INFO("Track %d got %s %s.", m_index, tagName, tagValue.get());
value = tagValue.get();
return true;
}
return false;
}
void TrackPrivateBaseGStreamer::notifyTrackOfTagsChanged()
{
if (!m_pad)
return;
TrackPrivateBaseClient* client = m_owner->client();
if (!client)
return;
GRefPtr<GstTagList> tags;
{
LockHolder lock(m_tagMutex);
tags.swap(m_tags);
}
if (!tags)
return;
if (getTag(tags.get(), GST_TAG_TITLE, m_label))
client->labelChanged(m_label);
AtomicString language;
if (!getLanguageCode(tags.get(), language))
return;
if (language == m_language)
return;
m_language = language;
client->languageChanged(m_language);
}
}
#endif // ENABLE(VIDEO) && USE(GSTREAMER) && ENABLE(VIDEO_TRACK)