mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst/gstmessage.c: Use GstQuark for messages.

Browse source 
Original commit message from CVS:
* gst/gstmessage.c: (gst_message_new_error),
(gst_message_new_warning), (gst_message_new_info),
(gst_message_new_buffering), (gst_message_new_state_changed),
(gst_message_new_clock_provide), (gst_message_new_clock_lost),
(gst_message_new_new_clock), (gst_message_new_segment_start),
(gst_message_new_segment_done), (gst_message_new_duration),
(gst_message_new_async_start), (gst_message_parse_buffering),
(gst_message_parse_state_changed),
(gst_message_parse_clock_provide), (gst_message_parse_clock_lost),
(gst_message_parse_new_clock), (gst_message_parse_error),
(gst_message_parse_warning), (gst_message_parse_info),
(gst_message_parse_segment_start),
(gst_message_parse_segment_done), (gst_message_parse_duration),
(gst_message_parse_async_start):
Use GstQuark for messages.
This commit is contained in:
Wim Taymans 2008-04-08 19:52:22 +00:00
parent 9c5a343605
commit 6215f509c8
2 changed files with 143 additions and 79 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
ChangeLog
View file

@ -1,3 +1,21 @@
2008-04-08 Wim Taymans <wim.taymans@collabora.co.uk>
* gst/gstmessage.c: (gst_message_new_error),
(gst_message_new_warning), (gst_message_new_info),
(gst_message_new_buffering), (gst_message_new_state_changed),
(gst_message_new_clock_provide), (gst_message_new_clock_lost),
(gst_message_new_new_clock), (gst_message_new_segment_start),
(gst_message_new_segment_done), (gst_message_new_duration),
(gst_message_new_async_start), (gst_message_parse_buffering),
(gst_message_parse_state_changed),
(gst_message_parse_clock_provide), (gst_message_parse_clock_lost),
(gst_message_parse_new_clock), (gst_message_parse_error),
(gst_message_parse_warning), (gst_message_parse_info),
(gst_message_parse_segment_start),
(gst_message_parse_segment_done), (gst_message_parse_duration),
(gst_message_parse_async_start):
Use GstQuark for messages.
2008-04-08 Wim Taymans <wim.taymans@collabora.co.uk> 2008-04-08 Wim Taymans <wim.taymans@collabora.co.uk>
* gst/gstquark.c: (_priv_gst_quarks_initialize): * gst/gstquark.c: (_priv_gst_quarks_initialize):

204
gst/gstmessage.c
View file

@ -57,6 +57,7 @@
#include "gstmessage.h" #include "gstmessage.h"
#include "gsttaglist.h" #include "gsttaglist.h"
#include "gstutils.h" #include "gstutils.h"
#include "gstquark.h"
static void gst_message_init (GTypeInstance * instance, gpointer g_class); static void gst_message_init (GTypeInstance * instance, gpointer g_class);
@ -343,10 +344,13 @@ GstMessage *
gst_message_new_error (GstObject * src, GError * error, gchar * debug) gst_message_new_error (GstObject * src, GError * error, gchar * debug)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_ERROR, src, structure = gst_structure_empty_new ("GstMessageError");
gst_structure_new ("GstMessageError", "gerror", GST_TYPE_G_ERROR, error, gst_structure_id_set (structure,
"debug", G_TYPE_STRING, debug, NULL)); GST_QUARK (GERROR), GST_TYPE_G_ERROR, error,
GST_QUARK (DEBUG), G_TYPE_STRING, debug, NULL);
message = gst_message_new_custom (GST_MESSAGE_ERROR, src, structure);
return message; return message;
} }
@ -368,10 +372,13 @@ GstMessage *
gst_message_new_warning (GstObject * src, GError * error, gchar * debug) gst_message_new_warning (GstObject * src, GError * error, gchar * debug)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_WARNING, src, structure = gst_structure_empty_new ("GstMessageWarning");
gst_structure_new ("GstMessageWarning", "gerror", GST_TYPE_G_ERROR, error, gst_structure_id_set (structure,
"debug", G_TYPE_STRING, debug, NULL)); GST_QUARK (GERROR), GST_TYPE_G_ERROR, error,
GST_QUARK (DEBUG), G_TYPE_STRING, debug, NULL);
message = gst_message_new_custom (GST_MESSAGE_WARNING, src, structure);
return message; return message;
} }
@ -395,10 +402,12 @@ GstMessage *
gst_message_new_info (GstObject * src, GError * error, gchar * debug) gst_message_new_info (GstObject * src, GError * error, gchar * debug)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_INFO, src, structure = gst_structure_empty_new ("GstMessageInfo");
gst_structure_new ("GstMessageInfo", "gerror", GST_TYPE_G_ERROR, error, gst_structure_id_set (structure, GST_QUARK (GERROR), GST_TYPE_G_ERROR,
"debug", G_TYPE_STRING, debug, NULL)); error, GST_QUARK (DEBUG), G_TYPE_STRING, debug, NULL);
message = gst_message_new_custom (GST_MESSAGE_INFO, src, structure);
return message; return message;
} }
@ -454,12 +463,19 @@ GstMessage *
gst_message_new_buffering (GstObject * src, gint percent) gst_message_new_buffering (GstObject * src, gint percent)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
g_return_val_if_fail (percent >= 0 && percent <= 100, NULL); g_return_val_if_fail (percent >= 0 && percent <= 100, NULL);
message = gst_message_new_custom (GST_MESSAGE_BUFFERING, src, structure = gst_structure_empty_new ("GstMessageBuffering");
gst_structure_new ("GstMessageBuffering", gst_structure_id_set (structure,
"buffer-percent", G_TYPE_INT, percent, NULL)); GST_QUARK (BUFFER_PERCENT), G_TYPE_INT, percent,
GST_QUARK (BUFFERING_MODE), GST_TYPE_BUFFERING_MODE, GST_BUFFERING_STREAM,
GST_QUARK (AVG_IN_RATE), G_TYPE_INT, -1,
GST_QUARK (AVG_OUT_RATE), G_TYPE_INT, -1,
GST_QUARK (BUFFERING_LEFT), G_TYPE_INT64, -1,
GST_QUARK (ESTIMATED_TOTAL), G_TYPE_INT64, -1, NULL);
message = gst_message_new_custom (GST_MESSAGE_BUFFERING, src, structure);
return message; return message;
} }
@ -483,12 +499,14 @@ gst_message_new_state_changed (GstObject * src,
GstState oldstate, GstState newstate, GstState pending) GstState oldstate, GstState newstate, GstState pending)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_STATE_CHANGED, src, structure = gst_structure_empty_new ("GstMessageState");
gst_structure_new ("GstMessageState", gst_structure_id_set (structure,
"old-state", GST_TYPE_STATE, (gint) oldstate, GST_QUARK (OLD_STATE), GST_TYPE_STATE, (gint) oldstate,
"new-state", GST_TYPE_STATE, (gint) newstate, GST_QUARK (NEW_STATE), GST_TYPE_STATE, (gint) newstate,
"pending-state", GST_TYPE_STATE, (gint) pending, NULL)); GST_QUARK (PENDING_STATE), GST_TYPE_STATE, (gint) pending, NULL);
message = gst_message_new_custom (GST_MESSAGE_STATE_CHANGED, src, structure);
return message; return message;
} }
@ -537,11 +555,13 @@ gst_message_new_clock_provide (GstObject * src, GstClock * clock,
gboolean ready) gboolean ready)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_CLOCK_PROVIDE, src, structure = gst_structure_empty_new ("GstMessageClockProvide");
gst_structure_new ("GstMessageClockProvide", gst_structure_id_set (structure,
"clock", GST_TYPE_CLOCK, clock, GST_QUARK (CLOCK), GST_TYPE_CLOCK, clock,
"ready", G_TYPE_BOOLEAN, ready, NULL)); GST_QUARK (READY), G_TYPE_BOOLEAN, ready, NULL);
message = gst_message_new_custom (GST_MESSAGE_CLOCK_PROVIDE, src, structure);
return message; return message;
} }
@ -566,10 +586,12 @@ GstMessage *
gst_message_new_clock_lost (GstObject * src, GstClock * clock) gst_message_new_clock_lost (GstObject * src, GstClock * clock)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_CLOCK_LOST, src, structure = gst_structure_empty_new ("GstMessageClockLost");
gst_structure_new ("GstMessageClockLost", gst_structure_id_set (structure,
"clock", GST_TYPE_CLOCK, clock, NULL)); GST_QUARK (CLOCK), GST_TYPE_CLOCK, clock, NULL);
message = gst_message_new_custom (GST_MESSAGE_CLOCK_LOST, src, structure);
return message; return message;
} }
@ -590,10 +612,12 @@ GstMessage *
gst_message_new_new_clock (GstObject * src, GstClock * clock) gst_message_new_new_clock (GstObject * src, GstClock * clock)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_NEW_CLOCK, src, structure = gst_structure_empty_new ("GstMessageNewClock");
gst_structure_new ("GstMessageNewClock", gst_structure_id_set (structure,
"clock", GST_TYPE_CLOCK, clock, NULL)); GST_QUARK (CLOCK), GST_TYPE_CLOCK, clock, NULL);
message = gst_message_new_custom (GST_MESSAGE_NEW_CLOCK, src, structure);
return message; return message;
} }
@ -618,11 +642,13 @@ gst_message_new_segment_start (GstObject * src, GstFormat format,
gint64 position) gint64 position)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_SEGMENT_START, src, structure = gst_structure_empty_new ("GstMessageSegmentStart");
gst_structure_new ("GstMessageSegmentStart", gst_structure_id_set (structure,
"format", GST_TYPE_FORMAT, format, GST_QUARK (FORMAT), GST_TYPE_FORMAT, format,
"position", G_TYPE_INT64, position, NULL)); GST_QUARK (POSITION), G_TYPE_INT64, position, NULL);
message = gst_message_new_custom (GST_MESSAGE_SEGMENT_START, src, structure);
return message; return message;
} }
@ -647,11 +673,13 @@ gst_message_new_segment_done (GstObject * src, GstFormat format,
gint64 position) gint64 position)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_SEGMENT_DONE, src, structure = gst_structure_empty_new ("GstMessageSegmentDone");
gst_structure_new ("GstMessageSegmentDone", gst_structure_id_set (structure,
"format", GST_TYPE_FORMAT, format, GST_QUARK (FORMAT), GST_TYPE_FORMAT, format,
"position", G_TYPE_INT64, position, NULL)); GST_QUARK (POSITION), G_TYPE_INT64, position, NULL);
message = gst_message_new_custom (GST_MESSAGE_SEGMENT_DONE, src, structure);
return message; return message;
} }
@ -718,11 +746,13 @@ GstMessage *
gst_message_new_duration (GstObject * src, GstFormat format, gint64 duration) gst_message_new_duration (GstObject * src, GstFormat format, gint64 duration)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_DURATION, src, structure = gst_structure_empty_new ("GstMessageDuration");
gst_structure_new ("GstMessageDuration", gst_structure_id_set (structure,
"format", GST_TYPE_FORMAT, format, GST_QUARK (FORMAT), GST_TYPE_FORMAT, format,
"duration", G_TYPE_INT64, duration, NULL)); GST_QUARK (DURATION), G_TYPE_INT64, duration, NULL);
message = gst_message_new_custom (GST_MESSAGE_DURATION, src, structure);
return message; return message;
} }
@ -746,10 +776,12 @@ GstMessage *
gst_message_new_async_start (GstObject * src, gboolean new_base_time) gst_message_new_async_start (GstObject * src, gboolean new_base_time)
{ {
GstMessage *message; GstMessage *message;
GstStructure *structure;
message = gst_message_new_custom (GST_MESSAGE_ASYNC_START, src, structure = gst_structure_empty_new ("GstMessageAsyncStart");
gst_structure_new ("GstMessageAsyncStart", gst_structure_id_set (structure,
"new-base-time", G_TYPE_BOOLEAN, new_base_time, NULL)); GST_QUARK (NEW_BASE_TIME), G_TYPE_BOOLEAN, new_base_time, NULL);
message = gst_message_new_custom (GST_MESSAGE_ASYNC_START, src, structure);
return message; return message;
} }
@ -858,7 +890,8 @@ gst_message_parse_buffering (GstMessage * message, gint * percent)
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_BUFFERING); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_BUFFERING);
if (percent) if (percent)
gst_structure_get_int (message->structure, "buffer-percent", percent); *percent = g_value_get_int (gst_structure_id_get_value (message->structure,
GST_QUARK (BUFFER_PERCENT)));
} }
/** /**
@ -880,14 +913,16 @@ gst_message_parse_state_changed (GstMessage * message,
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_STATE_CHANGED); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_STATE_CHANGED);
if (oldstate) if (oldstate)
gst_structure_get_enum (message->structure, "old-state", *oldstate =
GST_TYPE_STATE, (gint *) oldstate); g_value_get_enum (gst_structure_id_get_value (message->structure,
GST_QUARK (OLD_STATE)));
if (newstate) if (newstate)
gst_structure_get_enum (message->structure, "new-state", *newstate =
GST_TYPE_STATE, (gint *) newstate); g_value_get_enum (gst_structure_id_get_value (message->structure,
GST_QUARK (NEW_STATE)));
if (pending) if (pending)
gst_structure_get_enum (message->structure, "pending-state", *pending = g_value_get_enum (gst_structure_id_get_value (message->structure,
GST_TYPE_STATE, (gint *) pending); GST_QUARK (PENDING_STATE)));
} }
/** /**
@ -910,12 +945,15 @@ gst_message_parse_clock_provide (GstMessage * message, GstClock ** clock,
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_CLOCK_PROVIDE); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_CLOCK_PROVIDE);
clock_gvalue = gst_structure_get_value (message->structure, "clock"); clock_gvalue =
gst_structure_id_get_value (message->structure, GST_QUARK (CLOCK));
g_return_if_fail (clock_gvalue != NULL); g_return_if_fail (clock_gvalue != NULL);
g_return_if_fail (G_VALUE_TYPE (clock_gvalue) == GST_TYPE_CLOCK); g_return_if_fail (G_VALUE_TYPE (clock_gvalue) == GST_TYPE_CLOCK);
if (ready) if (ready)
gst_structure_get_boolean (message->structure, "ready", ready); *ready =
g_value_get_boolean (gst_structure_id_get_value (message->structure,
GST_QUARK (READY)));
if (clock) if (clock)
*clock = (GstClock *) g_value_get_object (clock_gvalue); *clock = (GstClock *) g_value_get_object (clock_gvalue);
} }
@ -938,7 +976,8 @@ gst_message_parse_clock_lost (GstMessage * message, GstClock ** clock)
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_CLOCK_LOST); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_CLOCK_LOST);
clock_gvalue = gst_structure_get_value (message->structure, "clock"); clock_gvalue =
gst_structure_id_get_value (message->structure, GST_QUARK (CLOCK));
g_return_if_fail (clock_gvalue != NULL); g_return_if_fail (clock_gvalue != NULL);
g_return_if_fail (G_VALUE_TYPE (clock_gvalue) == GST_TYPE_CLOCK); g_return_if_fail (G_VALUE_TYPE (clock_gvalue) == GST_TYPE_CLOCK);
@ -964,7 +1003,8 @@ gst_message_parse_new_clock (GstMessage * message, GstClock ** clock)
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_NEW_CLOCK); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_NEW_CLOCK);
clock_gvalue = gst_structure_get_value (message->structure, "clock"); clock_gvalue =
gst_structure_id_get_value (message->structure, GST_QUARK (CLOCK));
g_return_if_fail (clock_gvalue != NULL); g_return_if_fail (clock_gvalue != NULL);
g_return_if_fail (G_VALUE_TYPE (clock_gvalue) == GST_TYPE_CLOCK); g_return_if_fail (G_VALUE_TYPE (clock_gvalue) == GST_TYPE_CLOCK);
@ -992,7 +1032,8 @@ gst_message_parse_error (GstMessage * message, GError ** gerror, gchar ** debug)
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_ERROR); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_ERROR);
error_gvalue = gst_structure_get_value (message->structure, "gerror"); error_gvalue =
gst_structure_id_get_value (message->structure, GST_QUARK (GERROR));
g_return_if_fail (error_gvalue != NULL); g_return_if_fail (error_gvalue != NULL);
g_return_if_fail (G_VALUE_TYPE (error_gvalue) == GST_TYPE_G_ERROR); g_return_if_fail (G_VALUE_TYPE (error_gvalue) == GST_TYPE_G_ERROR);
@ -1003,7 +1044,9 @@ gst_message_parse_error (GstMessage * message, GError ** gerror, gchar ** debug)
*gerror = NULL; *gerror = NULL;
if (debug) if (debug)
*debug = g_strdup (gst_structure_get_string (message->structure, "debug")); *debug =
g_value_dup_string (gst_structure_id_get_value (message->structure,
GST_QUARK (DEBUG)));
} }
/** /**
@ -1027,7 +1070,8 @@ gst_message_parse_warning (GstMessage * message, GError ** gerror,
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_WARNING); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_WARNING);
error_gvalue = gst_structure_get_value (message->structure, "gerror"); error_gvalue =
gst_structure_id_get_value (message->structure, GST_QUARK (GERROR));
g_return_if_fail (error_gvalue != NULL); g_return_if_fail (error_gvalue != NULL);
g_return_if_fail (G_VALUE_TYPE (error_gvalue) == GST_TYPE_G_ERROR); g_return_if_fail (G_VALUE_TYPE (error_gvalue) == GST_TYPE_G_ERROR);
@ -1038,7 +1082,9 @@ gst_message_parse_warning (GstMessage * message, GError ** gerror,
*gerror = NULL; *gerror = NULL;
if (debug) if (debug)
*debug = g_strdup (gst_structure_get_string (message->structure, "debug")); *debug =
g_value_dup_string (gst_structure_id_get_value (message->structure,
GST_QUARK (DEBUG)));
} }
/** /**
@ -1063,7 +1109,8 @@ gst_message_parse_info (GstMessage * message, GError ** gerror, gchar ** debug)
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_INFO); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_INFO);
error_gvalue = gst_structure_get_value (message->structure, "gerror"); error_gvalue =
gst_structure_id_get_value (message->structure, GST_QUARK (GERROR));
g_return_if_fail (error_gvalue != NULL); g_return_if_fail (error_gvalue != NULL);
g_return_if_fail (G_VALUE_TYPE (error_gvalue) == GST_TYPE_G_ERROR); g_return_if_fail (G_VALUE_TYPE (error_gvalue) == GST_TYPE_G_ERROR);
@ -1074,7 +1121,9 @@ gst_message_parse_info (GstMessage * message, GError ** gerror, gchar ** debug)
*gerror = NULL; *gerror = NULL;
if (debug) if (debug)
*debug = g_strdup (gst_structure_get_string (message->structure, "debug")); *debug =
g_value_dup_string (gst_structure_id_get_value (message->structure,
GST_QUARK (DEBUG)));
} }
/** /**
@ -1091,17 +1140,17 @@ void
gst_message_parse_segment_start (GstMessage * message, GstFormat * format, gst_message_parse_segment_start (GstMessage * message, GstFormat * format,
gint64 * position) gint64 * position)
{ {
const GstStructure *structure;
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_SEGMENT_START); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_SEGMENT_START);
structure = gst_message_get_structure (message);
if (format) if (format)
*format = g_value_get_enum (gst_structure_get_value (structure, "format")); *format =
g_value_get_enum (gst_structure_id_get_value (message->structure,
GST_QUARK (FORMAT)));
if (position) if (position)
*position = *position =
g_value_get_int64 (gst_structure_get_value (structure, "position")); g_value_get_int64 (gst_structure_id_get_value (message->structure,
GST_QUARK (POSITION)));
} }
/** /**
@ -1118,17 +1167,17 @@ void
gst_message_parse_segment_done (GstMessage * message, GstFormat * format, gst_message_parse_segment_done (GstMessage * message, GstFormat * format,
gint64 * position) gint64 * position)
{ {
const GstStructure *structure;
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_SEGMENT_DONE); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_SEGMENT_DONE);
structure = gst_message_get_structure (message);
if (format) if (format)
*format = g_value_get_enum (gst_structure_get_value (structure, "format")); *format =
g_value_get_enum (gst_structure_id_get_value (message->structure,
GST_QUARK (FORMAT)));
if (position) if (position)
*position = *position =
g_value_get_int64 (gst_structure_get_value (structure, "position")); g_value_get_int64 (gst_structure_id_get_value (message->structure,
GST_QUARK (POSITION)));
} }
/** /**
@ -1148,17 +1197,17 @@ void
gst_message_parse_duration (GstMessage * message, GstFormat * format, gst_message_parse_duration (GstMessage * message, GstFormat * format,
gint64 * duration) gint64 * duration)
{ {
const GstStructure *structure;
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_DURATION); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_DURATION);
structure = gst_message_get_structure (message);
if (format) if (format)
*format = g_value_get_enum (gst_structure_get_value (structure, "format")); *format =
g_value_get_enum (gst_structure_id_get_value (message->structure,
GST_QUARK (FORMAT)));
if (duration) if (duration)
*duration = *duration =
g_value_get_int64 (gst_structure_get_value (structure, "duration")); g_value_get_int64 (gst_structure_id_get_value (message->structure,
GST_QUARK (DURATION)));
} }
/** /**
@ -1175,14 +1224,11 @@ gst_message_parse_duration (GstMessage * message, GstFormat * format,
void void
gst_message_parse_async_start (GstMessage * message, gboolean * new_base_time) gst_message_parse_async_start (GstMessage * message, gboolean * new_base_time)
{ {
const GstStructure *structure;
g_return_if_fail (GST_IS_MESSAGE (message)); g_return_if_fail (GST_IS_MESSAGE (message));
g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_ASYNC_START); g_return_if_fail (GST_MESSAGE_TYPE (message) == GST_MESSAGE_ASYNC_START);
structure = gst_message_get_structure (message);
if (new_base_time) if (new_base_time)
*new_base_time = *new_base_time =
g_value_get_boolean (gst_structure_get_value (structure, g_value_get_boolean (gst_structure_id_get_value (message->structure,
"new-base-time")); GST_QUARK (NEW_BASE_TIME)));
} }