blob: 0fbc11e1da3afaaa67cbe854e325ee4a8c94e33f [file] [log] [blame]
/* GStreamer
* Copyright (C) 2008-2009 Sebastian Dröge <sebastian.droege@collabora.co.uk>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Library General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Library General Public License for more details.
*
* You should have received a copy of the GNU Library General Public
* License along with this library; if not, write to the
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
* Boston, MA 02110-1301, USA.
*/
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include <gst/gst.h>
#include <string.h>
#include "mxftypes.h"
#include "mxfmetadata.h"
#include "mxfquark.h"
GST_DEBUG_CATEGORY_EXTERN (mxf_debug);
#define GST_CAT_DEFAULT mxf_debug
G_DEFINE_ABSTRACT_TYPE (MXFMetadataBase, mxf_metadata_base, G_TYPE_OBJECT);
static void
mxf_metadata_base_finalize (GObject * object)
{
MXFMetadataBase *self = MXF_METADATA_BASE (object);
if (self->other_tags) {
g_hash_table_destroy (self->other_tags);
self->other_tags = NULL;
}
G_OBJECT_CLASS (mxf_metadata_base_parent_class)->finalize (object);
}
static gboolean
mxf_metadata_base_handle_tag (MXFMetadataBase * self, MXFPrimerPack * primer,
guint16 tag, const guint8 * tag_data, guint tag_size)
{
return (mxf_local_tag_add_to_hash_table (primer, tag, tag_data, tag_size,
&self->other_tags));
}
static gboolean
mxf_metadata_base_resolve_default (MXFMetadataBase * self,
GHashTable * metadata)
{
return TRUE;
}
static GstStructure *
mxf_metadata_base_to_structure_default (MXFMetadataBase * self)
{
MXFMetadataBaseClass *klass = MXF_METADATA_BASE_GET_CLASS (self);
GstStructure *ret;
gchar str[48];
g_return_val_if_fail (klass->name_quark != 0, NULL);
ret = gst_structure_new_id_empty (klass->name_quark);
if (!mxf_uuid_is_zero (&self->instance_uid)) {
mxf_uuid_to_string (&self->instance_uid, str);
gst_structure_id_set (ret, MXF_QUARK (INSTANCE_UID), G_TYPE_STRING, str,
NULL);
}
if (!mxf_uuid_is_zero (&self->generation_uid)) {
mxf_uuid_to_string (&self->generation_uid, str);
gst_structure_id_set (ret, MXF_QUARK (GENERATION_UID), G_TYPE_STRING, str,
NULL);
}
if (self->other_tags) {
MXFLocalTag *tag;
GValue va = { 0, };
GValue v = { 0, };
GstStructure *s;
GstBuffer *buf;
GstMapInfo map;
GHashTableIter iter;
g_hash_table_iter_init (&iter, self->other_tags);
g_value_init (&va, GST_TYPE_ARRAY);
while (g_hash_table_iter_next (&iter, NULL, (gpointer) & tag)) {
g_value_init (&v, GST_TYPE_STRUCTURE);
s = gst_structure_new_id_empty (MXF_QUARK (TAG));
mxf_ul_to_string (&tag->ul, str);
buf = gst_buffer_new_and_alloc (tag->size);
gst_buffer_map (buf, &map, GST_MAP_WRITE);
memcpy (map.data, tag->data, tag->size);
gst_buffer_unmap (buf, &map);
gst_structure_id_set (s, MXF_QUARK (NAME), G_TYPE_STRING, str,
MXF_QUARK (DATA), GST_TYPE_BUFFER, buf, NULL);
gst_value_set_structure (&v, s);
gst_structure_free (s);
gst_buffer_unref (buf);
gst_value_array_append_value (&va, &v);
g_value_unset (&v);
}
gst_structure_id_set_value (ret, MXF_QUARK (OTHER_TAGS), &va);
g_value_unset (&va);
}
return ret;
}
static void
mxf_metadata_base_init (MXFMetadataBase * self)
{
}
static void
mxf_metadata_base_class_init (MXFMetadataBaseClass * klass)
{
GObjectClass *object_class = (GObjectClass *) klass;
object_class->finalize = mxf_metadata_base_finalize;
klass->handle_tag = mxf_metadata_base_handle_tag;
klass->resolve = mxf_metadata_base_resolve_default;
klass->to_structure = mxf_metadata_base_to_structure_default;
}
gboolean
mxf_metadata_base_parse (MXFMetadataBase * self, MXFPrimerPack * primer,
const guint8 * data, guint size)
{
guint16 tag, tag_size;
const guint8 *tag_data;
g_return_val_if_fail (MXF_IS_METADATA_BASE (self), FALSE);
g_return_val_if_fail (primer != NULL, FALSE);
if (size == 0)
return FALSE;
g_return_val_if_fail (data != NULL, FALSE);
while (mxf_local_tag_parse (data, size, &tag, &tag_size, &tag_data)) {
if (tag_size == 0 || tag == 0x0000)
goto next;
if (!MXF_METADATA_BASE_GET_CLASS (self)->handle_tag (self, primer, tag,
tag_data, tag_size))
return FALSE;
next:
data += 4 + tag_size;
size -= 4 + tag_size;
}
return TRUE;
}
gboolean
mxf_metadata_base_resolve (MXFMetadataBase * self, GHashTable * metadata)
{
MXFMetadataBaseClass *klass;
gboolean ret = TRUE;
g_return_val_if_fail (MXF_IS_METADATA_BASE (self), FALSE);
g_return_val_if_fail (metadata != NULL, FALSE);
if (self->resolved == MXF_METADATA_BASE_RESOLVE_STATE_SUCCESS)
return TRUE;
else if (self->resolved != MXF_METADATA_BASE_RESOLVE_STATE_NONE)
return FALSE;
self->resolved = MXF_METADATA_BASE_RESOLVE_STATE_RUNNING;
klass = MXF_METADATA_BASE_GET_CLASS (self);
if (klass->resolve)
ret = klass->resolve (self, metadata);
self->resolved =
(ret) ? MXF_METADATA_BASE_RESOLVE_STATE_SUCCESS :
MXF_METADATA_BASE_RESOLVE_STATE_FAILURE;
return ret;
}
GstStructure *
mxf_metadata_base_to_structure (MXFMetadataBase * self)
{
MXFMetadataBaseClass *klass;
g_return_val_if_fail (MXF_IS_METADATA_BASE (self), NULL);
g_return_val_if_fail (self->resolved ==
MXF_METADATA_BASE_RESOLVE_STATE_SUCCESS, NULL);
klass = MXF_METADATA_BASE_GET_CLASS (self);
if (klass->to_structure)
return klass->to_structure (self);
return NULL;
}
GstBuffer *
mxf_metadata_base_to_buffer (MXFMetadataBase * self, MXFPrimerPack * primer)
{
MXFMetadataBaseClass *klass;
GstBuffer *ret;
GstMapInfo map;
GList *tags, *l;
guint size = 0, slen;
guint8 ber[9];
MXFLocalTag *t, *last;
guint8 *data;
g_return_val_if_fail (MXF_IS_METADATA_BASE (self), NULL);
g_return_val_if_fail (primer != NULL, NULL);
klass = MXF_METADATA_BASE_GET_CLASS (self);
g_return_val_if_fail (klass->write_tags, NULL);
tags = klass->write_tags (self, primer);
g_return_val_if_fail (tags != NULL, NULL);
/* Add unknown tags */
if (self->other_tags) {
MXFLocalTag *tmp;
GHashTableIter iter;
g_hash_table_iter_init (&iter, self->other_tags);
while (g_hash_table_iter_next (&iter, NULL, (gpointer) & t)) {
tmp = g_slice_dup (MXFLocalTag, t);
if (t->g_slice) {
tmp->data = g_slice_alloc (t->size);
mxf_primer_pack_add_mapping (primer, 0x0000, &t->ul);
memcpy (tmp->data, t->data, t->size);
} else {
tmp->data = g_memdup (t->data, t->size);
}
tags = g_list_prepend (tags, tmp);
}
}
l = g_list_last (tags);
last = l->data;
tags = g_list_delete_link (tags, l);
/* Last element contains the metadata UL */
g_return_val_if_fail (last->size == 0, NULL);
for (l = tags; l; l = l->next) {
t = l->data;
g_assert (G_MAXUINT - t->size >= size);
size += 4 + t->size;
}
slen = mxf_ber_encode_size (size, ber);
size += 16 + slen;
ret = gst_buffer_new_and_alloc (size);
gst_buffer_map (ret, &map, GST_MAP_WRITE);
memcpy (map.data, &last->ul, 16);
mxf_local_tag_free (last);
last = NULL;
memcpy (map.data + 16, ber, slen);
data = map.data + 16 + slen;
size -= 16 + slen;
for (l = tags; l; l = l->next) {
guint16 local_tag;
g_assert (size >= 4);
t = l->data;
local_tag =
GPOINTER_TO_UINT (g_hash_table_lookup (primer->reverse_mappings,
&t->ul));
g_assert (local_tag != 0);
GST_WRITE_UINT16_BE (data, local_tag);
GST_WRITE_UINT16_BE (data + 2, t->size);
data += 4;
size -= 4;
g_assert (size >= t->size);
memcpy (data, t->data, t->size);
data += t->size;
size -= t->size;
mxf_local_tag_free (t);
}
g_list_free (tags);
gst_buffer_unmap (ret, &map);
return ret;
}
G_DEFINE_ABSTRACT_TYPE (MXFMetadata, mxf_metadata, MXF_TYPE_METADATA_BASE);
static gboolean
mxf_metadata_handle_tag (MXFMetadataBase * metadata, MXFPrimerPack * primer,
guint16 tag, const guint8 * tag_data, guint tag_size)
{
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
MXFMetadata *self = MXF_METADATA (metadata);
gboolean ret = TRUE;
switch (tag) {
case 0x3c0a:
if (tag_size != 16)
goto error;
memcpy (&self->parent.instance_uid, tag_data, 16);
GST_DEBUG (" instance uid = %s",
mxf_uuid_to_string (&self->parent.instance_uid, str));
break;
case 0x0102:
if (tag_size != 16)
goto error;
memcpy (&self->parent.generation_uid, tag_data, 16);
GST_DEBUG (" generation uid = %s",
mxf_uuid_to_string (&self->parent.generation_uid, str));
break;
default:
ret =
MXF_METADATA_BASE_CLASS (mxf_metadata_parent_class)->handle_tag
(metadata, primer, tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid metadata local tag 0x%04x of size %u", tag, tag_size);
return FALSE;
}
static GList *
mxf_metadata_write_tags (MXFMetadataBase * m, MXFPrimerPack * primer)
{
MXFMetadata *self = MXF_METADATA (m);
GList *ret = NULL;
MXFLocalTag *t;
MXFMetadataClass *klass;
g_return_val_if_fail (MXF_IS_METADATA (self), NULL);
klass = MXF_METADATA_GET_CLASS (self);
/* Last element contains the metadata key */
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (METADATA), 16);
GST_WRITE_UINT16_BE (&t->ul.u[13], klass->type);
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (INSTANCE_UID), 16);
t->size = 16;
t->data = g_slice_alloc (16);
t->g_slice = TRUE;
memcpy (t->data, &self->parent.instance_uid, 16);
mxf_primer_pack_add_mapping (primer, 0x3c0a, &t->ul);
ret = g_list_prepend (ret, t);
if (!mxf_uuid_is_zero (&self->parent.generation_uid)) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (GENERATION_UID), 16);
t->size = 16;
t->data = g_slice_alloc (16);
t->g_slice = TRUE;
memcpy (t->data, &self->parent.generation_uid, 16);
mxf_primer_pack_add_mapping (primer, 0x0102, &t->ul);
ret = g_list_prepend (ret, t);
}
return ret;
}
static void
mxf_metadata_class_init (MXFMetadataClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
metadata_base_class->handle_tag = mxf_metadata_handle_tag;
metadata_base_class->write_tags = mxf_metadata_write_tags;
}
static void
mxf_metadata_init (MXFMetadata * self)
{
}
static GArray *_mxf_metadata_registry = NULL;
#define _add_metadata_type(type) G_STMT_START { \
GType t = type; \
\
g_array_append_val (_mxf_metadata_registry, t); \
} G_STMT_END
void
mxf_metadata_init_types (void)
{
g_return_if_fail (_mxf_metadata_registry == NULL);
_mxf_metadata_registry = g_array_new (FALSE, TRUE, sizeof (GType));
_add_metadata_type (MXF_TYPE_METADATA_PREFACE);
_add_metadata_type (MXF_TYPE_METADATA_IDENTIFICATION);
_add_metadata_type (MXF_TYPE_METADATA_CONTENT_STORAGE);
_add_metadata_type (MXF_TYPE_METADATA_ESSENCE_CONTAINER_DATA);
_add_metadata_type (MXF_TYPE_METADATA_MATERIAL_PACKAGE);
_add_metadata_type (MXF_TYPE_METADATA_SOURCE_PACKAGE);
_add_metadata_type (MXF_TYPE_METADATA_TIMELINE_TRACK);
_add_metadata_type (MXF_TYPE_METADATA_EVENT_TRACK);
_add_metadata_type (MXF_TYPE_METADATA_STATIC_TRACK);
_add_metadata_type (MXF_TYPE_METADATA_SEQUENCE);
_add_metadata_type (MXF_TYPE_METADATA_SOURCE_CLIP);
_add_metadata_type (MXF_TYPE_METADATA_FILLER);
_add_metadata_type (MXF_TYPE_METADATA_TIMECODE_COMPONENT);
_add_metadata_type (MXF_TYPE_METADATA_DM_SEGMENT);
_add_metadata_type (MXF_TYPE_METADATA_DM_SOURCE_CLIP);
_add_metadata_type (MXF_TYPE_METADATA_FILE_DESCRIPTOR);
_add_metadata_type (MXF_TYPE_METADATA_GENERIC_PICTURE_ESSENCE_DESCRIPTOR);
_add_metadata_type (MXF_TYPE_METADATA_CDCI_PICTURE_ESSENCE_DESCRIPTOR);
_add_metadata_type (MXF_TYPE_METADATA_RGBA_PICTURE_ESSENCE_DESCRIPTOR);
_add_metadata_type (MXF_TYPE_METADATA_GENERIC_SOUND_ESSENCE_DESCRIPTOR);
_add_metadata_type (MXF_TYPE_METADATA_GENERIC_DATA_ESSENCE_DESCRIPTOR);
_add_metadata_type (MXF_TYPE_METADATA_MULTIPLE_DESCRIPTOR);
_add_metadata_type (MXF_TYPE_METADATA_NETWORK_LOCATOR);
_add_metadata_type (MXF_TYPE_METADATA_TEXT_LOCATOR);
}
#undef _add_metadata_type
void
mxf_metadata_register (GType type)
{
g_return_if_fail (g_type_is_a (type, MXF_TYPE_METADATA));
g_array_append_val (_mxf_metadata_registry, type);
}
MXFMetadata *
mxf_metadata_new (guint16 type, MXFPrimerPack * primer, guint64 offset,
const guint8 * data, guint size)
{
guint i;
GType t = G_TYPE_INVALID;
MXFMetadata *ret = NULL;
g_return_val_if_fail (type != 0, NULL);
g_return_val_if_fail (primer != NULL, NULL);
g_return_val_if_fail (_mxf_metadata_registry != NULL, NULL);
for (i = 0; i < _mxf_metadata_registry->len; i++) {
GType tmp = g_array_index (_mxf_metadata_registry, GType, i);
MXFMetadataClass *klass = MXF_METADATA_CLASS (g_type_class_ref (tmp));
if (klass->type == type) {
g_type_class_unref (klass);
t = tmp;
break;
}
g_type_class_unref (klass);
}
if (t == G_TYPE_INVALID) {
GST_WARNING
("No handler for type 0x%04x found -- using generic metadata parser",
type);
return NULL;
}
GST_DEBUG ("Metadata type 0x%04x is handled by type %s", type,
g_type_name (t));
ret = (MXFMetadata *) g_type_create_instance (t);
if (!mxf_metadata_base_parse (MXF_METADATA_BASE (ret), primer, data, size)) {
GST_ERROR ("Parsing metadata failed");
g_object_unref (ret);
return NULL;
}
ret->parent.offset = offset;
return ret;
}
G_DEFINE_TYPE (MXFMetadataPreface, mxf_metadata_preface, MXF_TYPE_METADATA);
static void
mxf_metadata_preface_finalize (GObject * object)
{
MXFMetadataPreface *self = MXF_METADATA_PREFACE (object);
g_free (self->identifications_uids);
self->identifications_uids = NULL;
g_free (self->identifications);
self->identifications = NULL;
g_free (self->essence_containers);
self->essence_containers = NULL;
g_free (self->dm_schemes);
self->dm_schemes = NULL;
G_OBJECT_CLASS (mxf_metadata_preface_parent_class)->finalize (object);
}
static gboolean
mxf_metadata_preface_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataPreface *self = MXF_METADATA_PREFACE (metadata);
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
gboolean ret = TRUE;
switch (tag) {
case 0x3b02:
if (!mxf_timestamp_parse (&self->last_modified_date, tag_data, tag_size))
goto error;
GST_DEBUG (" last modified date = %s",
mxf_timestamp_to_string (&self->last_modified_date, str));
break;
case 0x3b05:
if (tag_size != 2)
goto error;
self->version = GST_READ_UINT16_BE (tag_data);
GST_DEBUG (" version = %u.%u", (self->version >> 8),
(self->version & 0x0f));
break;
case 0x3b07:
if (tag_size != 4)
goto error;
self->object_model_version = GST_READ_UINT32_BE (tag_data);
GST_DEBUG (" object model version = %u", self->object_model_version);
break;
case 0x3b08:
if (tag_size != 16)
goto error;
memcpy (&self->primary_package_uid, tag_data, 16);
GST_DEBUG (" primary package = %s",
mxf_uuid_to_string (&self->primary_package_uid, str));
break;
case 0x3b06:
if (!mxf_uuid_array_parse (&self->identifications_uids,
&self->n_identifications, tag_data, tag_size))
goto error;
GST_DEBUG (" number of identifications = %u", self->n_identifications);
#ifndef GST_DISABLE_GST_DEBUG
{
guint i;
for (i = 0; i < self->n_identifications; i++) {
GST_DEBUG (" identification %u = %s", i,
mxf_uuid_to_string (&self->identifications_uids[i], str));
}
}
#endif
break;
case 0x3b03:
if (tag_size != 16)
goto error;
memcpy (&self->content_storage_uid, tag_data, 16);
GST_DEBUG (" content storage = %s",
mxf_uuid_to_string (&self->content_storage_uid, str));
break;
case 0x3b09:
if (tag_size != 16)
goto error;
memcpy (&self->operational_pattern, tag_data, 16);
GST_DEBUG (" operational pattern = %s",
mxf_ul_to_string (&self->operational_pattern, str));
break;
case 0x3b0a:
if (!mxf_ul_array_parse (&self->essence_containers,
&self->n_essence_containers, tag_data, tag_size))
goto error;
GST_DEBUG (" number of essence containers = %u",
self->n_essence_containers);
#ifndef GST_DISABLE_GST_DEBUG
{
guint i;
for (i = 0; i < self->n_essence_containers; i++) {
GST_DEBUG (" essence container %u = %s", i,
mxf_ul_to_string (&self->essence_containers[i], str));
}
}
#endif
break;
case 0x3b0b:
if (!mxf_ul_array_parse (&self->dm_schemes, &self->n_dm_schemes, tag_data,
tag_size))
goto error;
GST_DEBUG (" number of DM schemes = %u", self->n_dm_schemes);
#ifndef GST_DISABLE_GST_DEBUG
{
guint i;
for (i = 0; i < self->n_dm_schemes; i++) {
GST_DEBUG (" DM schemes %u = %s", i,
mxf_ul_to_string (&self->dm_schemes[i], str));
}
}
#endif
break;
default:
ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_preface_parent_class)->handle_tag (metadata, primer,
tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid preface local tag 0x%04x of size %u", tag, tag_size);
return FALSE;
}
static gboolean
mxf_metadata_preface_resolve (MXFMetadataBase * m, GHashTable * metadata)
{
MXFMetadataPreface *self = MXF_METADATA_PREFACE (m);
MXFMetadataBase *current = NULL;
guint i;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
if (!mxf_uuid_is_zero (&self->primary_package_uid)) {
current = g_hash_table_lookup (metadata, &self->primary_package_uid);
if (!current || !MXF_IS_METADATA_GENERIC_PACKAGE (current)) {
GST_ERROR ("Primary package %s not found",
mxf_uuid_to_string (&self->primary_package_uid, str));
} else {
if (mxf_metadata_base_resolve (current, metadata)) {
self->primary_package = MXF_METADATA_GENERIC_PACKAGE (current);
}
}
}
current = NULL;
current = g_hash_table_lookup (metadata, &self->content_storage_uid);
if (!current || !MXF_IS_METADATA_CONTENT_STORAGE (current)) {
GST_ERROR ("Content storage %s not found",
mxf_uuid_to_string (&self->content_storage_uid, str));
return FALSE;
} else {
if (mxf_metadata_base_resolve (current, metadata)) {
self->content_storage = MXF_METADATA_CONTENT_STORAGE (current);
} else {
GST_ERROR ("Couldn't resolve content storage %s",
mxf_uuid_to_string (&self->content_storage_uid, str));
return FALSE;
}
}
current = NULL;
if (self->identifications)
memset (self->identifications, 0,
sizeof (gpointer) * self->n_identifications);
else
self->identifications =
g_new0 (MXFMetadataIdentification *, self->n_identifications);
for (i = 0; i < self->n_identifications; i++) {
current = g_hash_table_lookup (metadata, &self->identifications_uids[i]);
if (current && MXF_IS_METADATA_IDENTIFICATION (current)) {
if (mxf_metadata_base_resolve (current, metadata))
self->identifications[i] = MXF_METADATA_IDENTIFICATION (current);
}
current = NULL;
}
return
MXF_METADATA_BASE_CLASS (mxf_metadata_preface_parent_class)->resolve (m,
metadata);
}
static GstStructure *
mxf_metadata_preface_to_structure (MXFMetadataBase * m)
{
GstStructure *ret =
MXF_METADATA_BASE_CLASS (mxf_metadata_preface_parent_class)->to_structure
(m);
MXFMetadataPreface *self = MXF_METADATA_PREFACE (m);
gchar str[48];
guint i;
if (!mxf_timestamp_is_unknown (&self->last_modified_date)) {
mxf_timestamp_to_string (&self->last_modified_date, str);
gst_structure_id_set (ret, MXF_QUARK (LAST_MODIFIED_DATE), G_TYPE_STRING,
str, NULL);
}
if (self->version != 0)
gst_structure_id_set (ret, MXF_QUARK (VERSION), G_TYPE_UINT, self->version,
NULL);
if (self->object_model_version != 0)
gst_structure_id_set (ret, MXF_QUARK (OBJECT_MODEL_VERSION), G_TYPE_UINT,
self->object_model_version, NULL);
if (!mxf_uuid_is_zero (&self->primary_package_uid)) {
mxf_uuid_to_string (&self->primary_package_uid, str);
gst_structure_id_set (ret, MXF_QUARK (PRIMARY_PACKAGE), G_TYPE_STRING, str,
NULL);
}
if (self->n_identifications > 0) {
GValue arr = { 0, }
, val = {
0,};
g_value_init (&arr, GST_TYPE_ARRAY);
for (i = 0; i < self->n_identifications; i++) {
GstStructure *s;
if (self->identifications[i] == NULL)
continue;
g_value_init (&val, GST_TYPE_STRUCTURE);
s = mxf_metadata_base_to_structure (MXF_METADATA_BASE
(self->identifications[i]));
gst_value_set_structure (&val, s);
gst_structure_free (s);
gst_value_array_append_value (&arr, &val);
g_value_unset (&val);
}
if (gst_value_array_get_size (&arr) > 0)
gst_structure_id_set_value (ret, MXF_QUARK (IDENTIFICATIONS), &arr);
g_value_unset (&arr);
}
if (self->content_storage) {
GstStructure *s =
mxf_metadata_base_to_structure (MXF_METADATA_BASE
(self->content_storage));
gst_structure_id_set (ret, MXF_QUARK (CONTENT_STORAGE), GST_TYPE_STRUCTURE,
s, NULL);
gst_structure_free (s);
}
if (!mxf_ul_is_zero (&self->operational_pattern)) {
mxf_ul_to_string (&self->operational_pattern, str);
gst_structure_id_set (ret, MXF_QUARK (OPERATIONAL_PATTERN), G_TYPE_STRING,
str, NULL);
}
if (self->n_essence_containers > 0) {
GValue arr = { 0, }
, val = {
0,};
g_value_init (&arr, GST_TYPE_ARRAY);
for (i = 0; i < self->n_essence_containers; i++) {
if (mxf_ul_is_zero (&self->essence_containers[i]))
continue;
g_value_init (&val, G_TYPE_STRING);
mxf_ul_to_string (&self->essence_containers[i], str);
g_value_set_string (&val, str);
gst_value_array_append_value (&arr, &val);
g_value_unset (&val);
}
if (gst_value_array_get_size (&arr) > 0)
gst_structure_id_set_value (ret, MXF_QUARK (ESSENCE_CONTAINERS), &arr);
g_value_unset (&arr);
}
if (self->n_dm_schemes > 0) {
GValue arr = { 0, }
, val = {
0,};
g_value_init (&arr, GST_TYPE_ARRAY);
for (i = 0; i < self->n_dm_schemes; i++) {
if (mxf_ul_is_zero (&self->dm_schemes[i]))
continue;
g_value_init (&val, G_TYPE_STRING);
mxf_ul_to_string (&self->dm_schemes[i], str);
g_value_set_string (&val, str);
gst_value_array_append_value (&arr, &val);
g_value_unset (&val);
}
if (gst_value_array_get_size (&arr) > 0)
gst_structure_id_set_value (ret, MXF_QUARK (DM_SCHEMES), &arr);
g_value_unset (&arr);
}
return ret;
}
static GList *
mxf_metadata_preface_write_tags (MXFMetadataBase * m, MXFPrimerPack * primer)
{
MXFMetadataPreface *self = MXF_METADATA_PREFACE (m);
GList *ret =
MXF_METADATA_BASE_CLASS (mxf_metadata_preface_parent_class)->write_tags
(m, primer);
MXFLocalTag *t;
guint i;
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (LAST_MODIFIED_DATE), 16);
t->size = 8;
t->data = g_slice_alloc (8);
t->g_slice = TRUE;
mxf_timestamp_write (&self->last_modified_date, t->data);
mxf_primer_pack_add_mapping (primer, 0x3b02, &t->ul);
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (VERSION), 16);
t->size = 2;
t->data = g_slice_alloc (2);
t->g_slice = TRUE;
GST_WRITE_UINT16_BE (t->data, self->version);
mxf_primer_pack_add_mapping (primer, 0x3b05, &t->ul);
ret = g_list_prepend (ret, t);
if (self->object_model_version) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (OBJECT_MODEL_VERSION), 16);
t->size = 4;
t->data = g_slice_alloc (4);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->object_model_version);
mxf_primer_pack_add_mapping (primer, 0x3b07, &t->ul);
ret = g_list_prepend (ret, t);
}
if (!mxf_uuid_is_zero (&self->primary_package_uid)) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PRIMARY_PACKAGE), 16);
t->size = 16;
t->data = g_slice_alloc (16);
t->g_slice = TRUE;
memcpy (t->data, &self->primary_package_uid, 16);
mxf_primer_pack_add_mapping (primer, 0x3b08, &t->ul);
ret = g_list_prepend (ret, t);
}
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (IDENTIFICATIONS), 16);
t->size = 8 + 16 * self->n_identifications;
t->data = g_slice_alloc0 (t->size);
t->g_slice = TRUE;
mxf_primer_pack_add_mapping (primer, 0x3b06, &t->ul);
GST_WRITE_UINT32_BE (t->data, self->n_identifications);
GST_WRITE_UINT32_BE (t->data + 4, 16);
for (i = 0; i < self->n_identifications; i++) {
if (!self->identifications[i])
continue;
memcpy (t->data + 8 + 16 * i,
&MXF_METADATA_BASE (self->identifications[i])->instance_uid, 16);
}
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (CONTENT_STORAGE), 16);
t->size = 16;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
mxf_primer_pack_add_mapping (primer, 0x3b03, &t->ul);
memcpy (t->data, &MXF_METADATA_BASE (self->content_storage)->instance_uid,
16);
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (OPERATIONAL_PATTERN), 16);
t->size = 16;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
mxf_primer_pack_add_mapping (primer, 0x3b09, &t->ul);
memcpy (t->data, &self->operational_pattern, 16);
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (ESSENCE_CONTAINERS), 16);
t->size = 8 + 16 * self->n_essence_containers;
t->data = g_slice_alloc0 (t->size);
t->g_slice = TRUE;
mxf_primer_pack_add_mapping (primer, 0x3b0a, &t->ul);
GST_WRITE_UINT32_BE (t->data, self->n_essence_containers);
GST_WRITE_UINT32_BE (t->data + 4, 16);
for (i = 0; i < self->n_essence_containers; i++) {
memcpy (t->data + 8 + 16 * i, &self->essence_containers[i], 16);
}
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (DM_SCHEMES), 16);
t->size = 8 + 16 * self->n_dm_schemes;
t->data = g_slice_alloc0 (t->size);
t->g_slice = TRUE;
mxf_primer_pack_add_mapping (primer, 0x3b0b, &t->ul);
GST_WRITE_UINT32_BE (t->data, self->n_dm_schemes);
GST_WRITE_UINT32_BE (t->data + 4, 16);
for (i = 0; i < self->n_dm_schemes; i++) {
memcpy (t->data + 8 + 16 * i, &self->dm_schemes[i], 16);
}
ret = g_list_prepend (ret, t);
return ret;
}
static void
mxf_metadata_preface_init (MXFMetadataPreface * self)
{
}
static void
mxf_metadata_preface_class_init (MXFMetadataPrefaceClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
GObjectClass *object_class = (GObjectClass *) klass;
MXFMetadataClass *metadata_class = (MXFMetadataClass *) klass;
object_class->finalize = mxf_metadata_preface_finalize;
metadata_base_class->handle_tag = mxf_metadata_preface_handle_tag;
metadata_base_class->resolve = mxf_metadata_preface_resolve;
metadata_base_class->to_structure = mxf_metadata_preface_to_structure;
metadata_base_class->write_tags = mxf_metadata_preface_write_tags;
metadata_base_class->name_quark = MXF_QUARK (PREFACE);
metadata_class->type = 0x012f;
}
G_DEFINE_TYPE (MXFMetadataIdentification, mxf_metadata_identification,
MXF_TYPE_METADATA);
static void
mxf_metadata_identification_finalize (GObject * object)
{
MXFMetadataIdentification *self = MXF_METADATA_IDENTIFICATION (object);
g_free (self->company_name);
self->company_name = NULL;
g_free (self->product_name);
self->product_name = NULL;
g_free (self->version_string);
self->version_string = NULL;
g_free (self->platform);
self->platform = NULL;
G_OBJECT_CLASS (mxf_metadata_identification_parent_class)->finalize (object);
}
static gboolean
mxf_metadata_identification_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataIdentification *self = MXF_METADATA_IDENTIFICATION (metadata);
gboolean ret = TRUE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
switch (tag) {
case 0x3c09:
if (tag_size != 16)
goto error;
memcpy (&self->this_generation_uid, tag_data, 16);
GST_DEBUG (" this generation uid = %s",
mxf_uuid_to_string (&self->this_generation_uid, str));
break;
case 0x3c01:
self->company_name = mxf_utf16_to_utf8 (tag_data, tag_size);
GST_DEBUG (" company name = %s", GST_STR_NULL (self->company_name));
break;
case 0x3c02:
self->product_name = mxf_utf16_to_utf8 (tag_data, tag_size);
GST_DEBUG (" product name = %s", GST_STR_NULL (self->product_name));
break;
case 0x3c03:
if (!mxf_product_version_parse (&self->product_version,
tag_data, tag_size))
goto error;
GST_DEBUG (" product version = %u.%u.%u.%u.%u",
self->product_version.major,
self->product_version.minor,
self->product_version.patch,
self->product_version.build, self->product_version.release);
break;
case 0x3c04:
self->version_string = mxf_utf16_to_utf8 (tag_data, tag_size);
GST_DEBUG (" version string = %s", GST_STR_NULL (self->version_string));
break;
case 0x3c05:
if (tag_size != 16)
goto error;
memcpy (&self->product_uid, tag_data, 16);
GST_DEBUG (" product uid = %s",
mxf_uuid_to_string (&self->product_uid, str));
break;
case 0x3c06:
if (!mxf_timestamp_parse (&self->modification_date, tag_data, tag_size))
goto error;
GST_DEBUG (" modification date = %s",
mxf_timestamp_to_string (&self->modification_date, str));
break;
case 0x3c07:
if (!mxf_product_version_parse (&self->toolkit_version,
tag_data, tag_size))
goto error;
GST_DEBUG (" toolkit version = %u.%u.%u.%u.%u",
self->toolkit_version.major,
self->toolkit_version.minor,
self->toolkit_version.patch,
self->toolkit_version.build, self->toolkit_version.release);
break;
case 0x3c08:
self->platform = mxf_utf16_to_utf8 (tag_data, tag_size);
GST_DEBUG (" platform = %s", GST_STR_NULL (self->platform));
break;
default:
ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_identification_parent_class)->handle_tag (metadata,
primer, tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid identification local tag 0x%04x of size %u", tag,
tag_size);
return FALSE;
}
static GstStructure *
mxf_metadata_identification_to_structure (MXFMetadataBase * m)
{
GstStructure *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_identification_parent_class)->to_structure (m);
MXFMetadataIdentification *self = MXF_METADATA_IDENTIFICATION (m);
gchar str[48];
if (!mxf_uuid_is_zero (&self->this_generation_uid)) {
mxf_uuid_to_string (&self->this_generation_uid, str);
gst_structure_id_set (ret, MXF_QUARK (THIS_GENERATION_UID), G_TYPE_STRING,
str, NULL);
}
if (self->company_name)
gst_structure_id_set (ret, MXF_QUARK (COMPANY_NAME), G_TYPE_STRING,
self->company_name, NULL);
if (self->product_name)
gst_structure_id_set (ret, MXF_QUARK (PRODUCT_NAME), G_TYPE_STRING,
self->product_name, NULL);
if (self->product_version.major ||
self->product_version.minor ||
self->product_version.patch ||
self->product_version.build || self->product_version.release) {
g_snprintf (str, 48, "%u.%u.%u.%u.%u", self->product_version.major,
self->product_version.minor,
self->product_version.patch,
self->product_version.build, self->product_version.release);
gst_structure_id_set (ret, MXF_QUARK (PRODUCT_VERSION), G_TYPE_STRING, str,
NULL);
}
if (self->version_string)
gst_structure_id_set (ret, MXF_QUARK (VERSION_STRING), G_TYPE_STRING,
self->version_string, NULL);
if (!mxf_uuid_is_zero (&self->product_uid)) {
mxf_uuid_to_string (&self->product_uid, str);
gst_structure_id_set (ret, MXF_QUARK (PRODUCT_UID), G_TYPE_STRING, str,
NULL);
}
if (!mxf_timestamp_is_unknown (&self->modification_date)) {
mxf_timestamp_to_string (&self->modification_date, str);
gst_structure_id_set (ret, MXF_QUARK (MODIFICATION_DATE), G_TYPE_STRING,
str, NULL);
}
if (self->toolkit_version.major ||
self->toolkit_version.minor ||
self->toolkit_version.patch ||
self->toolkit_version.build || self->toolkit_version.release) {
g_snprintf (str, 48, "%u.%u.%u.%u.%u", self->toolkit_version.major,
self->toolkit_version.minor,
self->toolkit_version.patch,
self->toolkit_version.build, self->toolkit_version.release);
gst_structure_id_set (ret, MXF_QUARK (TOOLKIT_VERSION), G_TYPE_STRING, str,
NULL);
}
if (self->platform)
gst_structure_id_set (ret, MXF_QUARK (PLATFORM), G_TYPE_STRING,
self->platform, NULL);
return ret;
}
static GList *
mxf_metadata_identification_write_tags (MXFMetadataBase * m,
MXFPrimerPack * primer)
{
MXFMetadataIdentification *self = MXF_METADATA_IDENTIFICATION (m);
GList *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_identification_parent_class)->write_tags (m, primer);
MXFLocalTag *t;
if (self->company_name) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (COMPANY_NAME), 16);
t->data = mxf_utf8_to_utf16 (self->company_name, &t->size);
mxf_primer_pack_add_mapping (primer, 0x3c01, &t->ul);
ret = g_list_prepend (ret, t);
}
if (self->product_name) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PRODUCT_NAME), 16);
t->data = mxf_utf8_to_utf16 (self->product_name, &t->size);
mxf_primer_pack_add_mapping (primer, 0x3c02, &t->ul);
ret = g_list_prepend (ret, t);
}
if (!mxf_product_version_is_valid (&self->product_version)) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PRODUCT_VERSION), 16);
t->size = 10;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
mxf_product_version_write (&self->product_version, t->data);
mxf_primer_pack_add_mapping (primer, 0x3c03, &t->ul);
ret = g_list_prepend (ret, t);
}
if (self->version_string) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (VERSION_STRING), 16);
t->data = mxf_utf8_to_utf16 (self->version_string, &t->size);
mxf_primer_pack_add_mapping (primer, 0x3c04, &t->ul);
ret = g_list_prepend (ret, t);
}
if (!mxf_uuid_is_zero (&self->product_uid)) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PRODUCT_UID), 16);
t->size = 16;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
memcpy (t->data, &self->product_uid, 16);
mxf_primer_pack_add_mapping (primer, 0x3c05, &t->ul);
ret = g_list_prepend (ret, t);
}
if (!mxf_timestamp_is_unknown (&self->modification_date)) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (MODIFICATION_DATE), 16);
t->size = 8;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
mxf_timestamp_write (&self->modification_date, t->data);
mxf_primer_pack_add_mapping (primer, 0x3c06, &t->ul);
ret = g_list_prepend (ret, t);
}
if (!mxf_product_version_is_valid (&self->toolkit_version)) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (TOOLKIT_VERSION), 16);
t->size = 10;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
mxf_product_version_write (&self->toolkit_version, t->data);
mxf_primer_pack_add_mapping (primer, 0x3c07, &t->ul);
ret = g_list_prepend (ret, t);
}
if (self->platform) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PLATFORM), 16);
t->data = mxf_utf8_to_utf16 (self->platform, &t->size);
mxf_primer_pack_add_mapping (primer, 0x3c08, &t->ul);
ret = g_list_prepend (ret, t);
}
if (!mxf_uuid_is_zero (&self->this_generation_uid)) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (THIS_GENERATION_UID), 16);
t->size = 16;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
memcpy (t->data, &self->this_generation_uid, 16);
mxf_primer_pack_add_mapping (primer, 0x3c09, &t->ul);
ret = g_list_prepend (ret, t);
}
return ret;
}
static void
mxf_metadata_identification_init (MXFMetadataIdentification * self)
{
}
static void
mxf_metadata_identification_class_init (MXFMetadataIdentificationClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
GObjectClass *object_class = (GObjectClass *) klass;
MXFMetadataClass *metadata_class = (MXFMetadataClass *) klass;
object_class->finalize = mxf_metadata_identification_finalize;
metadata_base_class->handle_tag = mxf_metadata_identification_handle_tag;
metadata_base_class->name_quark = MXF_QUARK (IDENTIFICATION);
metadata_base_class->to_structure = mxf_metadata_identification_to_structure;
metadata_base_class->write_tags = mxf_metadata_identification_write_tags;
metadata_class->type = 0x0130;
}
G_DEFINE_TYPE (MXFMetadataContentStorage, mxf_metadata_content_storage,
MXF_TYPE_METADATA);
static void
mxf_metadata_content_storage_finalize (GObject * object)
{
MXFMetadataContentStorage *self = MXF_METADATA_CONTENT_STORAGE (object);
g_free (self->packages);
self->packages = NULL;
g_free (self->packages_uids);
self->packages_uids = NULL;
g_free (self->essence_container_data);
self->essence_container_data = NULL;
g_free (self->essence_container_data_uids);
self->essence_container_data_uids = NULL;
G_OBJECT_CLASS (mxf_metadata_content_storage_parent_class)->finalize (object);
}
static gboolean
mxf_metadata_content_storage_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataContentStorage *self = MXF_METADATA_CONTENT_STORAGE (metadata);
gboolean ret = TRUE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
switch (tag) {
case 0x1901:
if (!mxf_uuid_array_parse (&self->packages_uids, &self->n_packages,
tag_data, tag_size))
goto error;
GST_DEBUG (" number of packages = %u", self->n_packages);
#ifndef GST_DISABLE_GST_DEBUG
{
guint i;
for (i = 0; i < self->n_packages; i++) {
GST_DEBUG (" package %u = %s", i,
mxf_uuid_to_string (&self->packages_uids[i], str));
}
}
#endif
break;
case 0x1902:
if (!mxf_uuid_array_parse (&self->essence_container_data_uids,
&self->n_essence_container_data, tag_data, tag_size))
goto error;
GST_DEBUG (" number of essence container data = %u",
self->n_essence_container_data);
#ifndef GST_DISABLE_GST_DEBUG
{
guint i;
for (i = 0; i < self->n_essence_container_data; i++) {
GST_DEBUG (" essence container data %u = %s", i,
mxf_uuid_to_string (&self->essence_container_data_uids[i], str));
}
}
#endif
break;
default:
ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_content_storage_parent_class)->handle_tag (metadata,
primer, tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid content storage local tag 0x%04x of size %u", tag,
tag_size);
return FALSE;
}
static gboolean
mxf_metadata_content_storage_resolve (MXFMetadataBase * m,
GHashTable * metadata)
{
MXFMetadataContentStorage *self = MXF_METADATA_CONTENT_STORAGE (m);
MXFMetadataBase *current = NULL;
guint i;
gboolean have_package = FALSE;
gboolean have_ecd = FALSE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
if (self->packages)
memset (self->packages, 0, sizeof (gpointer) * self->n_packages);
else
self->packages = g_new0 (MXFMetadataGenericPackage *, self->n_packages);
for (i = 0; i < self->n_packages; i++) {
current = g_hash_table_lookup (metadata, &self->packages_uids[i]);
if (current && MXF_IS_METADATA_GENERIC_PACKAGE (current)) {
if (mxf_metadata_base_resolve (current, metadata)) {
self->packages[i] = MXF_METADATA_GENERIC_PACKAGE (current);
have_package = TRUE;
} else {
GST_ERROR ("Couldn't resolve package %s",
mxf_uuid_to_string (&self->packages_uids[i], str));
}
} else {
GST_ERROR ("Package %s not found",
mxf_uuid_to_string (&self->packages_uids[i], str));
}
}
if (self->essence_container_data)
memset (self->essence_container_data, 0,
sizeof (gpointer) * self->n_essence_container_data);
else
self->essence_container_data =
g_new0 (MXFMetadataEssenceContainerData *,
self->n_essence_container_data);
for (i = 0; i < self->n_essence_container_data; i++) {
current =
g_hash_table_lookup (metadata, &self->essence_container_data_uids[i]);
if (current && MXF_IS_METADATA_ESSENCE_CONTAINER_DATA (current)) {
if (mxf_metadata_base_resolve (current, metadata)) {
self->essence_container_data[i] =
MXF_METADATA_ESSENCE_CONTAINER_DATA (current);
have_ecd = TRUE;
} else {
GST_ERROR ("Couldn't resolve essence container data %s",
mxf_uuid_to_string (&self->essence_container_data_uids[i], str));
}
} else {
GST_ERROR ("Essence container data %s not found",
mxf_uuid_to_string (&self->essence_container_data_uids[i], str));
}
}
if (!have_package) {
GST_ERROR ("Couldn't resolve any package");
return FALSE;
} else if (!have_ecd) {
GST_ERROR ("Couldn't resolve any essence container data");
return FALSE;
}
return
MXF_METADATA_BASE_CLASS
(mxf_metadata_content_storage_parent_class)->resolve (m, metadata);
}
static GstStructure *
mxf_metadata_content_storage_to_structure (MXFMetadataBase * m)
{
GstStructure *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_content_storage_parent_class)->to_structure (m);
MXFMetadataContentStorage *self = MXF_METADATA_CONTENT_STORAGE (m);
guint i;
if (self->n_packages > 0) {
GValue arr = { 0, }
, val = {
0,};
g_value_init (&arr, GST_TYPE_ARRAY);
for (i = 0; i < self->n_packages; i++) {
GstStructure *s;
if (self->packages[i] == NULL)
continue;
g_value_init (&val, GST_TYPE_STRUCTURE);
s = mxf_metadata_base_to_structure (MXF_METADATA_BASE (self->packages
[i]));
gst_value_set_structure (&val, s);
gst_structure_free (s);
gst_value_array_append_value (&arr, &val);
g_value_unset (&val);
}
if (gst_value_array_get_size (&arr) > 0)
gst_structure_id_set_value (ret, MXF_QUARK (PACKAGES), &arr);
g_value_unset (&arr);
}
if (self->n_essence_container_data > 0) {
GValue arr = { 0, }
, val = {
0,};
g_value_init (&arr, GST_TYPE_ARRAY);
for (i = 0; i < self->n_essence_container_data; i++) {
GstStructure *s;
if (self->essence_container_data[i] == NULL)
continue;
g_value_init (&val, GST_TYPE_STRUCTURE);
s = mxf_metadata_base_to_structure (MXF_METADATA_BASE
(self->essence_container_data[i]));
gst_value_set_structure (&val, s);
gst_structure_free (s);
gst_value_array_append_value (&arr, &val);
g_value_unset (&val);
}
if (gst_value_array_get_size (&arr) > 0)
gst_structure_id_set_value (ret, MXF_QUARK (ESSENCE_CONTAINER_DATA),
&arr);
g_value_unset (&arr);
}
return ret;
}
static GList *
mxf_metadata_content_storage_write_tags (MXFMetadataBase * m,
MXFPrimerPack * primer)
{
MXFMetadataContentStorage *self = MXF_METADATA_CONTENT_STORAGE (m);
GList *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_content_storage_parent_class)->write_tags (m, primer);
MXFLocalTag *t;
guint i;
if (self->packages) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PACKAGES), 16);
t->size = 8 + 16 * self->n_packages;
t->data = g_slice_alloc0 (t->size);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->n_packages);
GST_WRITE_UINT32_BE (t->data + 4, 16);
for (i = 0; i < self->n_packages; i++) {
if (!self->packages[i])
continue;
memcpy (t->data + 8 + i * 16,
&MXF_METADATA_BASE (self->packages[i])->instance_uid, 16);
}
mxf_primer_pack_add_mapping (primer, 0x1901, &t->ul);
ret = g_list_prepend (ret, t);
}
if (self->essence_container_data) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (ESSENCE_CONTAINER_DATA), 16);
t->size = 8 + 16 * self->n_essence_container_data;
t->data = g_slice_alloc0 (t->size);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->n_essence_container_data);
GST_WRITE_UINT32_BE (t->data + 4, 16);
for (i = 0; i < self->n_essence_container_data; i++) {
if (!self->essence_container_data[i])
continue;
memcpy (t->data + 8 + i * 16,
&MXF_METADATA_BASE (self->essence_container_data[i])->instance_uid,
16);
}
mxf_primer_pack_add_mapping (primer, 0x1902, &t->ul);
ret = g_list_prepend (ret, t);
}
return ret;
}
static void
mxf_metadata_content_storage_init (MXFMetadataContentStorage * self)
{
}
static void
mxf_metadata_content_storage_class_init (MXFMetadataContentStorageClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
GObjectClass *object_class = (GObjectClass *) klass;
MXFMetadataClass *metadata_class = (MXFMetadataClass *) klass;
object_class->finalize = mxf_metadata_content_storage_finalize;
metadata_base_class->handle_tag = mxf_metadata_content_storage_handle_tag;
metadata_base_class->resolve = mxf_metadata_content_storage_resolve;
metadata_base_class->name_quark = MXF_QUARK (CONTENT_STORAGE);
metadata_base_class->to_structure = mxf_metadata_content_storage_to_structure;
metadata_base_class->write_tags = mxf_metadata_content_storage_write_tags;
metadata_class->type = 0x0118;
}
G_DEFINE_TYPE (MXFMetadataEssenceContainerData,
mxf_metadata_essence_container_data, MXF_TYPE_METADATA);
static gboolean
mxf_metadata_essence_container_data_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataEssenceContainerData *self =
MXF_METADATA_ESSENCE_CONTAINER_DATA (metadata);
gboolean ret = TRUE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[96];
#endif
switch (tag) {
case 0x2701:
if (tag_size != 32)
goto error;
memcpy (&self->linked_package_uid, tag_data, 32);
GST_DEBUG (" linked package = %s",
mxf_umid_to_string (&self->linked_package_uid, str));
break;
case 0x3f06:
if (tag_size != 4)
goto error;
self->index_sid = GST_READ_UINT32_BE (tag_data);
GST_DEBUG (" index sid = %u", self->index_sid);
break;
case 0x3f07:
if (tag_size != 4)
goto error;
self->body_sid = GST_READ_UINT32_BE (tag_data);
GST_DEBUG (" body sid = %u", self->body_sid);
break;
default:
ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_essence_container_data_parent_class)->handle_tag
(metadata, primer, tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid essence container data local tag 0x%04x of size %u", tag,
tag_size);
return FALSE;
}
static gboolean
mxf_metadata_essence_container_data_resolve (MXFMetadataBase * m,
GHashTable * metadata)
{
MXFMetadataEssenceContainerData *self =
MXF_METADATA_ESSENCE_CONTAINER_DATA (m);
MXFMetadataBase *current = NULL;
GHashTableIter iter;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[96];
#endif
g_hash_table_iter_init (&iter, metadata);
while (g_hash_table_iter_next (&iter, NULL, (gpointer) & current)) {
if (MXF_IS_METADATA_SOURCE_PACKAGE (current)) {
MXFMetadataSourcePackage *package = MXF_METADATA_SOURCE_PACKAGE (current);
if (mxf_umid_is_equal (&package->parent.package_uid,
&self->linked_package_uid)) {
if (mxf_metadata_base_resolve (current, metadata)) {
self->linked_package = package;
} else {
GST_ERROR ("Couldn't resolve linked package %s",
mxf_umid_to_string (&self->linked_package_uid, str));
}
break;
}
}
}
if (!self->linked_package) {
GST_ERROR ("Couldn't resolve or find linked package %s",
mxf_umid_to_string (&self->linked_package_uid, str));
return FALSE;
}
return
MXF_METADATA_BASE_CLASS
(mxf_metadata_essence_container_data_parent_class)->resolve (m, metadata);
}
static GstStructure *
mxf_metadata_essence_container_data_to_structure (MXFMetadataBase * m)
{
GstStructure *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_essence_container_data_parent_class)->to_structure (m);
MXFMetadataEssenceContainerData *self =
MXF_METADATA_ESSENCE_CONTAINER_DATA (m);
gchar str[96];
if (!mxf_umid_is_zero (&self->linked_package_uid)) {
mxf_umid_to_string (&self->linked_package_uid, str);
gst_structure_id_set (ret, MXF_QUARK (LINKED_PACKAGE), G_TYPE_STRING, str,
NULL);
}
gst_structure_id_set (ret, MXF_QUARK (INDEX_SID), G_TYPE_UINT,
self->index_sid, MXF_QUARK (BODY_SID), G_TYPE_UINT, self->body_sid, NULL);
return ret;
}
static GList *
mxf_metadata_essence_container_data_write_tags (MXFMetadataBase * m,
MXFPrimerPack * primer)
{
MXFMetadataEssenceContainerData *self =
MXF_METADATA_ESSENCE_CONTAINER_DATA (m);
GList *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_essence_container_data_parent_class)->write_tags (m,
primer);
MXFLocalTag *t;
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (LINKED_PACKAGE_UID), 16);
t->size = 32;
t->data = g_slice_alloc0 (32);
t->g_slice = TRUE;
if (self->linked_package)
memcpy (t->data, &self->linked_package->parent.package_uid, 32);
mxf_primer_pack_add_mapping (primer, 0x2701, &t->ul);
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (BODY_SID), 16);
t->size = 4;
t->data = g_slice_alloc (4);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->body_sid);
mxf_primer_pack_add_mapping (primer, 0x3f07, &t->ul);
ret = g_list_prepend (ret, t);
if (self->index_sid) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (INDEX_SID), 16);
t->size = 4;
t->data = g_slice_alloc (4);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->index_sid);
mxf_primer_pack_add_mapping (primer, 0x3f06, &t->ul);
ret = g_list_prepend (ret, t);
}
return ret;
}
static void
mxf_metadata_essence_container_data_init (MXFMetadataEssenceContainerData *
self)
{
}
static void
mxf_metadata_essence_container_data_class_init
(MXFMetadataEssenceContainerDataClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
MXFMetadataClass *metadata_class = (MXFMetadataClass *) klass;
metadata_base_class->handle_tag =
mxf_metadata_essence_container_data_handle_tag;
metadata_base_class->resolve = mxf_metadata_essence_container_data_resolve;
metadata_base_class->name_quark = MXF_QUARK (ESSENCE_CONTAINER_DATA);
metadata_base_class->to_structure =
mxf_metadata_essence_container_data_to_structure;
metadata_base_class->write_tags =
mxf_metadata_essence_container_data_write_tags;
metadata_class->type = 0x0123;
}
G_DEFINE_ABSTRACT_TYPE (MXFMetadataGenericPackage, mxf_metadata_generic_package,
MXF_TYPE_METADATA);
static void
mxf_metadata_generic_package_finalize (GObject * object)
{
MXFMetadataGenericPackage *self = MXF_METADATA_GENERIC_PACKAGE (object);
g_free (self->name);
self->name = NULL;
g_free (self->tracks_uids);
self->tracks_uids = NULL;
g_free (self->tracks);
self->tracks = NULL;
G_OBJECT_CLASS (mxf_metadata_generic_package_parent_class)->finalize (object);
}
static gboolean
mxf_metadata_generic_package_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataGenericPackage *self = MXF_METADATA_GENERIC_PACKAGE (metadata);
gboolean ret = TRUE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[96];
#endif
switch (tag) {
case 0x4401:
if (tag_size != 32)
goto error;
memcpy (&self->package_uid, tag_data, 32);
GST_DEBUG (" UMID = %s", mxf_umid_to_string (&self->package_uid, str));
break;
case 0x4402:
self->name = mxf_utf16_to_utf8 (tag_data, tag_size);
GST_DEBUG (" name = %s", GST_STR_NULL (self->name));
break;
case 0x4405:
if (!mxf_timestamp_parse (&self->package_creation_date,
tag_data, tag_size))
goto error;
GST_DEBUG (" creation date = %s",
mxf_timestamp_to_string (&self->package_creation_date, str));
break;
case 0x4404:
if (!mxf_timestamp_parse (&self->package_modified_date,
tag_data, tag_size))
goto error;
GST_DEBUG (" modification date = %s",
mxf_timestamp_to_string (&self->package_modified_date, str));
break;
case 0x4403:
if (!mxf_uuid_array_parse (&self->tracks_uids, &self->n_tracks, tag_data,
tag_size))
goto error;
GST_DEBUG (" number of tracks = %u", self->n_tracks);
#ifndef GST_DISABLE_GST_DEBUG
{
guint i;
for (i = 0; i < self->n_tracks; i++) {
GST_DEBUG (" track %u = %s", i,
mxf_uuid_to_string (&self->tracks_uids[i], str));
}
}
#endif
break;
default:
ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_generic_package_parent_class)->handle_tag (metadata,
primer, tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid generic package local tag 0x%04x of size %u", tag,
tag_size);
return FALSE;
}
static gboolean
mxf_metadata_generic_package_resolve (MXFMetadataBase * m,
GHashTable * metadata)
{
MXFMetadataGenericPackage *self = MXF_METADATA_GENERIC_PACKAGE (m);
MXFMetadataBase *current = NULL;
guint i;
gboolean have_track = FALSE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
if (self->tracks)
memset (self->tracks, 0, sizeof (gpointer) * self->n_tracks);
else
self->tracks = g_new0 (MXFMetadataTrack *, self->n_tracks);
for (i = 0; i < self->n_tracks; i++) {
current = g_hash_table_lookup (metadata, &self->tracks_uids[i]);
if (current && MXF_IS_METADATA_TRACK (current)) {
if (mxf_metadata_base_resolve (current, metadata)) {
MXFMetadataTrack *track = MXF_METADATA_TRACK (current);
self->tracks[i] = track;
have_track = TRUE;
if ((track->type & 0xf0) == 0x10)
self->n_timecode_tracks++;
else if ((track->type & 0xf0) == 0x20)
self->n_metadata_tracks++;
else if ((track->type & 0xf0) == 0x30)
self->n_essence_tracks++;
else if ((track->type & 0xf0) == 0x40)
self->n_other_tracks++;
} else {
GST_ERROR ("Track %s couldn't be resolved",
mxf_uuid_to_string (&self->tracks_uids[i], str));
}
} else {
GST_ERROR ("Track %s not found",
mxf_uuid_to_string (&self->tracks_uids[i], str));
}
}
if (!have_track) {
GST_ERROR ("Couldn't resolve a track");
return FALSE;
}
return
MXF_METADATA_BASE_CLASS
(mxf_metadata_generic_package_parent_class)->resolve (m, metadata);
}
static GstStructure *
mxf_metadata_generic_package_to_structure (MXFMetadataBase * m)
{
GstStructure *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_generic_package_parent_class)->to_structure (m);
MXFMetadataGenericPackage *self = MXF_METADATA_GENERIC_PACKAGE (m);
guint i;
gchar str[96];
mxf_umid_to_string (&self->package_uid, str);
gst_structure_id_set (ret, MXF_QUARK (PACKAGE_UID), G_TYPE_STRING, str, NULL);
if (self->name)
gst_structure_id_set (ret, MXF_QUARK (NAME), G_TYPE_STRING, self->name,
NULL);
if (!mxf_timestamp_is_unknown (&self->package_creation_date)) {
mxf_timestamp_to_string (&self->package_creation_date, str);
gst_structure_id_set (ret, MXF_QUARK (PACKAGE_CREATION_DATE), G_TYPE_STRING,
str, NULL);
}
if (!mxf_timestamp_is_unknown (&self->package_modified_date)) {
mxf_timestamp_to_string (&self->package_modified_date, str);
gst_structure_id_set (ret, MXF_QUARK (PACKAGE_MODIFIED_DATE), G_TYPE_STRING,
str, NULL);
}
if (self->n_tracks > 0) {
GValue arr = { 0, }
, val = {
0,};
g_value_init (&arr, GST_TYPE_ARRAY);
for (i = 0; i < self->n_tracks; i++) {
GstStructure *s;
if (self->tracks[i] == NULL)
continue;
g_value_init (&val, GST_TYPE_STRUCTURE);
s = mxf_metadata_base_to_structure (MXF_METADATA_BASE (self->tracks[i]));
gst_value_set_structure (&val, s);
gst_structure_free (s);
gst_value_array_append_value (&arr, &val);
g_value_unset (&val);
}
if (gst_value_array_get_size (&arr) > 0)
gst_structure_id_set_value (ret, MXF_QUARK (TRACKS), &arr);
g_value_unset (&arr);
}
return ret;
}
static GList *
mxf_metadata_generic_package_write_tags (MXFMetadataBase * m,
MXFPrimerPack * primer)
{
MXFMetadataGenericPackage *self = MXF_METADATA_GENERIC_PACKAGE (m);
GList *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_generic_package_parent_class)->write_tags (m, primer);
MXFLocalTag *t;
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PACKAGE_UID), 16);
t->size = 32;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
memcpy (t->data, &self->package_uid, 32);
mxf_primer_pack_add_mapping (primer, 0x4401, &t->ul);
ret = g_list_prepend (ret, t);
if (self->name) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PACKAGE_NAME), 16);
t->data = mxf_utf8_to_utf16 (self->name, &t->size);
mxf_primer_pack_add_mapping (primer, 0x4402, &t->ul);
ret = g_list_prepend (ret, t);
}
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PACKAGE_CREATION_DATE), 16);
t->size = 8;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
mxf_timestamp_write (&self->package_creation_date, t->data);
mxf_primer_pack_add_mapping (primer, 0x4405, &t->ul);
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (PACKAGE_MODIFIED_DATE), 16);
t->size = 8;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
mxf_timestamp_write (&self->package_modified_date, t->data);
mxf_primer_pack_add_mapping (primer, 0x4404, &t->ul);
ret = g_list_prepend (ret, t);
if (self->tracks) {
guint i;
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (TRACKS), 16);
t->size = 8 + 16 * self->n_tracks;
t->data = g_slice_alloc0 (t->size);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->n_tracks);
GST_WRITE_UINT32_BE (t->data + 4, 16);
for (i = 0; i < self->n_tracks; i++) {
if (!self->tracks[i])
continue;
memcpy (t->data + 8 + 16 * i,
&MXF_METADATA_BASE (self->tracks[i])->instance_uid, 16);
}
mxf_primer_pack_add_mapping (primer, 0x4403, &t->ul);
ret = g_list_prepend (ret, t);
}
return ret;
}
static void
mxf_metadata_generic_package_init (MXFMetadataGenericPackage * self)
{
}
static void
mxf_metadata_generic_package_class_init (MXFMetadataGenericPackageClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
GObjectClass *object_class = (GObjectClass *) klass;
object_class->finalize = mxf_metadata_generic_package_finalize;
metadata_base_class->handle_tag = mxf_metadata_generic_package_handle_tag;
metadata_base_class->resolve = mxf_metadata_generic_package_resolve;
metadata_base_class->to_structure = mxf_metadata_generic_package_to_structure;
metadata_base_class->write_tags = mxf_metadata_generic_package_write_tags;
}
G_DEFINE_TYPE (MXFMetadataMaterialPackage, mxf_metadata_material_package,
MXF_TYPE_METADATA_GENERIC_PACKAGE);
static gboolean
mxf_metadata_material_package_resolve (MXFMetadataBase * m,
GHashTable * metadata)
{
gboolean ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_material_package_parent_class)->resolve (m, metadata);
MXFMetadataGenericPackage *self = MXF_METADATA_GENERIC_PACKAGE (m);
guint i;
guint ntracks = 0;
if (!ret)
return ret;
for (i = 0; i < self->n_tracks; i++) {
MXFMetadataTrack *track = self->tracks[i];
MXFMetadataSequence *sequence;
guint j;
if (!track)
continue;
sequence = track->sequence;
if (!sequence || !sequence->structural_components)
continue;
for (j = 0; j < sequence->n_structural_components; j++) {
MXFMetadataSourceClip *sc;
MXFMetadataTimelineTrack *st = NULL;
guint k;
if (!sequence->structural_components[j]
|| !MXF_IS_METADATA_SOURCE_CLIP (sequence->structural_components[j]))
continue;
sc = MXF_METADATA_SOURCE_CLIP (sequence->structural_components[j]);
if (!sc->source_package) {
GST_ERROR ("Material package track %u without resolved source package",
i);
track = NULL;
break;
}
if (!mxf_metadata_base_resolve (MXF_METADATA_BASE (sc->source_package),
metadata)) {
GST_ERROR ("Couldn't resolve source package for track %u", i);
track = NULL;
break;
}
sc->source_package->top_level = TRUE;
for (k = 0; k < sc->source_package->parent.n_tracks; k++) {
MXFMetadataTimelineTrack *tmp;
if (!sc->source_package->parent.tracks[k] ||
!MXF_IS_METADATA_TIMELINE_TRACK (sc->source_package->parent.
tracks[k]))
continue;
tmp =
MXF_METADATA_TIMELINE_TRACK (sc->source_package->parent.tracks[k]);
if (tmp->parent.track_id == sc->source_track_id) {
st = tmp;
break;
}
}
if (!st) {
GST_ERROR ("Material package track %u without resolved source track",
i);
track = NULL;
}
}
if (track)
ntracks++;
else
self->tracks[i] = NULL;
}
if (ntracks == 0) {
GST_ERROR ("No tracks could be resolved");
return FALSE;
} else if (ntracks != self->n_tracks) {
GST_WARNING ("Not all tracks could be resolved");
}
return TRUE;
}
static void
mxf_metadata_material_package_init (MXFMetadataMaterialPackage * self)
{
}
static void
mxf_metadata_material_package_class_init (MXFMetadataMaterialPackageClass *
klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
MXFMetadataClass *metadata_class = (MXFMetadataClass *) klass;
metadata_base_class->resolve = mxf_metadata_material_package_resolve;
metadata_base_class->name_quark = MXF_QUARK (MATERIAL_PACKAGE);
metadata_class->type = 0x0136;
}
G_DEFINE_TYPE (MXFMetadataSourcePackage, mxf_metadata_source_package,
MXF_TYPE_METADATA_GENERIC_PACKAGE);
static gboolean
mxf_metadata_source_package_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataSourcePackage *self = MXF_METADATA_SOURCE_PACKAGE (metadata);
gboolean ret = TRUE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
switch (tag) {
case 0x4701:
if (tag_size != 16)
goto error;
memcpy (&self->descriptor_uid, tag_data, 16);
GST_DEBUG (" descriptor = %s",
mxf_uuid_to_string (&self->descriptor_uid, str));
break;
default:
ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_source_package_parent_class)->handle_tag (metadata,
primer, tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid source package local tag 0x%04x of size %u", tag,
tag_size);
return FALSE;
}
static gboolean
mxf_metadata_source_package_resolve (MXFMetadataBase * m, GHashTable * metadata)
{
MXFMetadataSourcePackage *self = MXF_METADATA_SOURCE_PACKAGE (m);
MXFMetadataGenericPackage *package = MXF_METADATA_GENERIC_PACKAGE (m);
MXFMetadataBase *current = NULL;
guint i;
gboolean ret;
MXFMetadataFileDescriptor *d;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
if (mxf_uuid_is_zero (&self->descriptor_uid))
return
MXF_METADATA_BASE_CLASS
(mxf_metadata_source_package_parent_class)->resolve (m, metadata);
current = g_hash_table_lookup (metadata, &self->descriptor_uid);
if (!current) {
GST_ERROR ("Descriptor %s not found",
mxf_uuid_to_string (&self->descriptor_uid, str));
return FALSE;
}
if (!mxf_metadata_base_resolve (MXF_METADATA_BASE (current), metadata)) {
GST_ERROR ("Couldn't resolve descriptor %s",
mxf_uuid_to_string (&self->descriptor_uid, str));
return FALSE;
}
self->descriptor = MXF_METADATA_GENERIC_DESCRIPTOR (current);
ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_source_package_parent_class)->resolve (m, metadata);
if (!MXF_IS_METADATA_FILE_DESCRIPTOR (self->descriptor))
return ret;
d = MXF_METADATA_FILE_DESCRIPTOR (current);
for (i = 0; i < package->n_tracks; i++) {
if (!package->tracks[i])
continue;
if (!MXF_IS_METADATA_MULTIPLE_DESCRIPTOR (d)) {
if (d->linked_track_id == package->tracks[i]->track_id ||
(d->linked_track_id == 0 && package->n_essence_tracks == 1 &&
(package->tracks[i]->type & 0xf0) == 0x30)) {
g_free (package->tracks[i]->descriptor);
package->tracks[i]->descriptor =
g_new0 (MXFMetadataFileDescriptor *, 1);
package->tracks[i]->descriptor[0] = d;
package->tracks[i]->n_descriptor = 1;
break;
}
} else {
guint n_descriptor = 0, j, k = 0;
MXFMetadataMultipleDescriptor *md = MXF_METADATA_MULTIPLE_DESCRIPTOR (d);
for (j = 0; j < md->n_sub_descriptors; j++) {
MXFMetadataFileDescriptor *fd;
if (!md->sub_descriptors[j] ||
!MXF_METADATA_FILE_DESCRIPTOR (md->sub_descriptors[j]))
continue;
fd = MXF_METADATA_FILE_DESCRIPTOR (md->sub_descriptors[j]);
if (fd->linked_track_id == package->tracks[i]->track_id ||
(fd->linked_track_id == 0 && package->n_essence_tracks == 1 &&
(package->tracks[i]->type & 0xf0) == 0x30))
n_descriptor++;
}
g_free (package->tracks[i]->descriptor);
package->tracks[i]->descriptor =
g_new0 (MXFMetadataFileDescriptor *, n_descriptor);
package->tracks[i]->n_descriptor = n_descriptor;
for (j = 0; j < md->n_sub_descriptors; j++) {
MXFMetadataFileDescriptor *fd;
if (!md->sub_descriptors[j] ||
!MXF_METADATA_FILE_DESCRIPTOR (md->sub_descriptors[j]))
continue;
fd = MXF_METADATA_FILE_DESCRIPTOR (md->sub_descriptors[j]);
if (fd->linked_track_id == package->tracks[i]->track_id ||
(fd->linked_track_id == 0 && package->n_essence_tracks == 1 &&
(package->tracks[i]->type & 0xf0) == 0x30)) {
package->tracks[i]->descriptor[k] = fd;
k++;
}
}
}
}
return ret;
}
static GstStructure *
mxf_metadata_source_package_to_structure (MXFMetadataBase * m)
{
GstStructure *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_source_package_parent_class)->to_structure (m);
MXFMetadataSourcePackage *self = MXF_METADATA_SOURCE_PACKAGE (m);
GstStructure *s;
if (!self->descriptor)
return ret;
s = mxf_metadata_base_to_structure (MXF_METADATA_BASE (self->descriptor));
gst_structure_id_set (ret, MXF_QUARK (DESCRIPTOR), GST_TYPE_STRUCTURE, s,
NULL);
gst_structure_free (s);
return ret;
}
static GList *
mxf_metadata_source_package_write_tags (MXFMetadataBase * m,
MXFPrimerPack * primer)
{
MXFMetadataSourcePackage *self = MXF_METADATA_SOURCE_PACKAGE (m);
GList *ret =
MXF_METADATA_BASE_CLASS
(mxf_metadata_source_package_parent_class)->write_tags (m, primer);
MXFLocalTag *t;
if (self->descriptor) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (DESCRIPTOR), 16);
t->size = 16;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
memcpy (t->data, &MXF_METADATA_BASE (self->descriptor)->instance_uid, 16);
mxf_primer_pack_add_mapping (primer, 0x4701, &t->ul);
ret = g_list_prepend (ret, t);
}
return ret;
}
static void
mxf_metadata_source_package_init (MXFMetadataSourcePackage * self)
{
}
static void
mxf_metadata_source_package_class_init (MXFMetadataSourcePackageClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
MXFMetadataClass *metadata_class = (MXFMetadataClass *) klass;
metadata_base_class->handle_tag = mxf_metadata_source_package_handle_tag;
metadata_base_class->resolve = mxf_metadata_source_package_resolve;
metadata_base_class->name_quark = MXF_QUARK (SOURCE_PACKAGE);
metadata_base_class->to_structure = mxf_metadata_source_package_to_structure;
metadata_base_class->write_tags = mxf_metadata_source_package_write_tags;
metadata_class->type = 0x0137;
}
G_DEFINE_ABSTRACT_TYPE (MXFMetadataTrack, mxf_metadata_track,
MXF_TYPE_METADATA);
static void
mxf_metadata_track_finalize (GObject * object)
{
MXFMetadataTrack *self = MXF_METADATA_TRACK (object);
g_free (self->track_name);
self->track_name = NULL;
g_free (self->descriptor);
self->descriptor = NULL;
G_OBJECT_CLASS (mxf_metadata_track_parent_class)->finalize (object);
}
static gboolean
mxf_metadata_track_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataTrack *self = MXF_METADATA_TRACK (metadata);
gboolean ret = TRUE;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
switch (tag) {
case 0x4801:
if (tag_size != 4)
goto error;
self->track_id = GST_READ_UINT32_BE (tag_data);
GST_DEBUG (" track id = %u", self->track_id);
break;
case 0x4804:
if (tag_size != 4)
goto error;
self->track_number = GST_READ_UINT32_BE (tag_data);
GST_DEBUG (" track number = %u", self->track_number);
break;
case 0x4802:
self->track_name = mxf_utf16_to_utf8 (tag_data, tag_size);
GST_DEBUG (" track name = %s", GST_STR_NULL (self->track_name));
break;
case 0x4803:
if (tag_size != 16)
goto error;
memcpy (&self->sequence_uid, tag_data, 16);
GST_DEBUG (" sequence uid = %s",
mxf_uuid_to_string (&self->sequence_uid, str));
break;
default:
ret =
MXF_METADATA_BASE_CLASS (mxf_metadata_track_parent_class)->handle_tag
(metadata, primer, tag, tag_data, tag_size);
break;
}
return ret;
error:
GST_ERROR ("Invalid track local tag 0x%04x of size %u", tag, tag_size);
return FALSE;
}
static gboolean
mxf_metadata_track_resolve (MXFMetadataBase * m, GHashTable * metadata)
{
MXFMetadataTrack *self = MXF_METADATA_TRACK (m);
MXFMetadataBase *current = NULL;
guint i;
#ifndef GST_DISABLE_GST_DEBUG
gchar str[48];
#endif
current = g_hash_table_lookup (metadata, &self->sequence_uid);
if (current && MXF_IS_METADATA_SEQUENCE (current)) {
if (mxf_metadata_base_resolve (current, metadata)) {
self->sequence = MXF_METADATA_SEQUENCE (current);
} else {
GST_ERROR ("Couldn't resolve sequence %s",
mxf_uuid_to_string (&self->sequence_uid, str));
return FALSE;
}
} else {
GST_ERROR ("Couldn't find sequence %s",
mxf_uuid_to_string (&self->sequence_uid, str));
return FALSE;
}
self->type =
mxf_metadata_track_identifier_parse (&self->sequence->data_definition);
if (self->type == MXF_METADATA_TRACK_UNKNOWN) {
MXFMetadataSequence *sequence = self->sequence;
for (i = 0; i < sequence->n_structural_components; i++) {
MXFMetadataStructuralComponent *component =
sequence->structural_components[i];
if (!component)
continue;
self->type =
mxf_metadata_track_identifier_parse (&component->data_definition);
if (self->type != MXF_METADATA_TRACK_UNKNOWN)
break;
}
}
return MXF_METADATA_BASE_CLASS (mxf_metadata_track_parent_class)->resolve (m,
metadata);
}
static GstStructure *
mxf_metadata_track_to_structure (MXFMetadataBase * m)
{
GstStructure *ret =
MXF_METADATA_BASE_CLASS (mxf_metadata_track_parent_class)->to_structure
(m);
MXFMetadataTrack *self = MXF_METADATA_TRACK (m);
gst_structure_id_set (ret, MXF_QUARK (TRACK_ID), G_TYPE_UINT, self->track_id,
MXF_QUARK (TRACK_NUMBER), G_TYPE_UINT, self->track_number, NULL);
if (self->track_name)
gst_structure_id_set (ret, MXF_QUARK (TRACK_NAME), G_TYPE_STRING,
self->track_name, NULL);
if (self->sequence) {
GstStructure *s =
mxf_metadata_base_to_structure (MXF_METADATA_BASE (self->sequence));
gst_structure_id_set (ret, MXF_QUARK (SEQUENCE), GST_TYPE_STRUCTURE, s,
NULL);
gst_structure_free (s);
}
return ret;
}
static GList *
mxf_metadata_track_write_tags (MXFMetadataBase * m, MXFPrimerPack * primer)
{
MXFMetadataTrack *self = MXF_METADATA_TRACK (m);
GList *ret =
MXF_METADATA_BASE_CLASS (mxf_metadata_track_parent_class)->write_tags (m,
primer);
MXFLocalTag *t;
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (TRACK_ID), 16);
t->size = 4;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->track_id);
mxf_primer_pack_add_mapping (primer, 0x4801, &t->ul);
ret = g_list_prepend (ret, t);
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (TRACK_NUMBER), 16);
t->size = 4;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
GST_WRITE_UINT32_BE (t->data, self->track_number);
mxf_primer_pack_add_mapping (primer, 0x4804, &t->ul);
ret = g_list_prepend (ret, t);
if (self->track_name) {
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (TRACK_NAME), 16);
t->data = mxf_utf8_to_utf16 (self->track_name, &t->size);
mxf_primer_pack_add_mapping (primer, 0x4802, &t->ul);
ret = g_list_prepend (ret, t);
}
t = g_slice_new0 (MXFLocalTag);
memcpy (&t->ul, MXF_UL (SEQUENCE), 16);
t->size = 16;
t->data = g_slice_alloc (t->size);
t->g_slice = TRUE;
memcpy (t->data, &MXF_METADATA_BASE (self->sequence)->instance_uid, 16);
mxf_primer_pack_add_mapping (primer, 0x4803, &t->ul);
ret = g_list_prepend (ret, t);
return ret;
}
static void
mxf_metadata_track_init (MXFMetadataTrack * self)
{
}
static void
mxf_metadata_track_class_init (MXFMetadataTrackClass * klass)
{
MXFMetadataBaseClass *metadata_base_class = (MXFMetadataBaseClass *) klass;
GObjectClass *object_class = (GObjectClass *) klass;
object_class->finalize = mxf_metadata_track_finalize;
metadata_base_class->handle_tag = mxf_metadata_track_handle_tag;
metadata_base_class->resolve = mxf_metadata_track_resolve;
metadata_base_class->to_structure = mxf_metadata_track_to_structure;
metadata_base_class->write_tags = mxf_metadata_track_write_tags;
}
/* SMPTE RP224 */
static const struct
{
const MXFUL *ul;
const MXFMetadataTrackType type;
} mxf_metadata_track_identifier[] = {
{
MXF_UL (TRACK_TIMECODE_12M_INACTIVE),
MXF_METADATA_TRACK_TIMECODE_12M_INACTIVE}, {
MXF_UL (TRACK_TIMECODE_12M_ACTIVE), MXF_METADATA_TRACK_TIMECODE_12M_ACTIVE}, {
MXF_UL (TRACK_TIMECODE_309M), MXF_METADATA_TRACK_TIMECODE_309M}, {
MXF_UL (TRACK_METADATA), MXF_METADATA_TRACK_METADATA}, {
MXF_UL (TRACK_PICTURE_ESSENCE), MXF_METADATA_TRACK_PICTURE_ESSENCE}, {
MXF_UL (TRACK_SOUND_ESSENCE), MXF_METADATA_TRACK_SOUND_ESSENCE}, {
MXF_UL (TRACK_DATA_ESSENCE), MXF_METADATA_TRACK_DATA_ESSENCE}, {
MXF_UL (TRACK_AUXILIARY_DATA), MXF_METADATA_TRACK_AUXILIARY_DATA}, {
MXF_UL (TRACK_PARSED_TEXT), MXF_METADATA_TRACK_PARSED_TEXT},
/* Avid video? */
{
MXF_UL (TRACK_AVID_PICTURE_ESSENCE), MXF_METADATA_TRACK_PICTURE_ESSENCE}
};
MXFMetadataTrackType
mxf_metadata_track_identifier_parse (const MXFUL * track_identifier)
{
guint i;
for (i = 0; i < G_N_ELEMENTS (mxf_metadata_track_identifier); i++)
if (mxf_ul_is_equal (mxf_metadata_track_identifier[i].ul, track_identifier))
return mxf_metadata_track_identifier[i].type;
return MXF_METADATA_TRACK_UNKNOWN;
}
const MXFUL *
mxf_metadata_track_identifier_get (MXFMetadataTrackType type)
{
guint i;
for (i = 0; i < G_N_ELEMENTS (mxf_metadata_track_identifier); i++)
if (mxf_metadata_track_identifier[i].type == type)
return mxf_metadata_track_identifier[i].ul;
return NULL;
}
G_DEFINE_TYPE (MXFMetadataTimelineTrack, mxf_metadata_timeline_track,
MXF_TYPE_METADATA_TRACK);
static gboolean
mxf_metadata_timeline_track_handle_tag (MXFMetadataBase * metadata,
MXFPrimerPack * primer, guint16 tag, const guint8 * tag_data,
guint tag_size)
{
MXFMetadataTimelineTrack *self = MXF_METADATA_TIMELINE_TRACK (metadata);
gboolean ret = TRUE;
switch (tag) {
case 0x4b01:
if (!mxf_fraction_parse (&self->edit_rate, tag_data, tag_size))
goto error;
GST_DEBUG (" edit rate = %d/%d", self->edit_rate.n, self->edit_rate.d);
break;
case 0x4b02:
if (tag_size != 8)
goto error;
self->origin = GST_READ_UINT64_BE (tag_data);
GST_DEBUG (" origin = %" G_GINT64_FORMAT, self->origin);
break;