+2005-09-19 Wim Taymans <wim@fluendo.com>
+
+ * check/pipelines/simple_launch_lines.c: (run_pipeline):
+ Fix for bus API.
+
+ * gst-libs/gst/rtp/gstbasertpdepayload.c:
+ (gst_base_rtp_depayload_chain),
+ (gst_base_rtp_depayload_add_to_queue),
+ (gst_base_rtp_depayload_push),
+ (gst_base_rtp_depayload_set_gst_timestamp),
+ (gst_base_rtp_depayload_queue_release):
+ Some cleanups.
+
+ * gst-libs/gst/rtp/gstbasertppayload.c:
+ (gst_basertppayload_class_init), (gst_basertppayload_init),
+ (gst_basertppayload_setcaps), (gst_basertppayload_set_options),
+ (gst_basertppayload_set_outcaps), (gst_basertppayload_push),
+ (gst_basertppayload_get_property),
+ (gst_basertppayload_change_state):
+ Added debugging category.
+
2005-09-18 David Schleef <ds@schleef.org>
* gst/playback/gstdecodebin.c: free plugin list correctly
GstMessageType events, GstMessageType tevent)
{
GstBus *bus;
+ GstMessage *message;
GstMessageType revent;
g_assert (pipe);
}
while (1) {
- revent = gst_bus_poll (bus, GST_MESSAGE_ANY, GST_SECOND / 2);
+ message = gst_bus_poll (bus, GST_MESSAGE_ANY, GST_SECOND / 2);
+
/* always have to pop the message before getting back into poll */
- if (revent != GST_MESSAGE_UNKNOWN)
+ if (message) {
+ revent = GST_MESSAGE_TYPE (message);
gst_message_unref (gst_bus_pop (bus));
+ } else {
+ revent = GST_MESSAGE_UNKNOWN;
+ }
if (revent == tevent) {
break;
GST_MESSAGE_ANY & ~(GST_MESSAGE_ERROR | GST_MESSAGE_WARNING),
GST_MESSAGE_UNKNOWN);
}
-GST_END_TEST Suite * simple_launch_lines_suite (void)
+GST_END_TEST Suite *
+simple_launch_lines_suite (void)
{
Suite *s = suite_create ("Pipelines");
TCase *tc_chain = tcase_create ("linear");
gst_base_rtp_depayload_chain (GstPad * pad, GstBuffer * in)
{
GstBaseRTPDepayload *filter;
+ GstBaseRTPDepayloadClass *bclass;
GstFlowReturn ret = GST_FLOW_OK;
- g_return_val_if_fail (GST_IS_PAD (pad), GST_FLOW_ERROR);
- g_return_val_if_fail (GST_BUFFER (in) != NULL, GST_FLOW_ERROR);
-
filter = GST_BASE_RTP_DEPAYLOAD (GST_OBJECT_PARENT (pad));
- g_return_val_if_fail (GST_IS_BASE_RTP_DEPAYLOAD (filter), GST_FLOW_ERROR);
g_return_val_if_fail (filter->clock_rate > 0, GST_FLOW_ERROR);
- GstBaseRTPDepayloadClass *bclass = GST_BASE_RTP_DEPAYLOAD_GET_CLASS (filter);
+ bclass = GST_BASE_RTP_DEPAYLOAD_GET_CLASS (filter);
if (filter->process_only) {
GST_DEBUG ("Pushing directly!");
// if this is the first buf send a discont
if (first) {
// send discont
- GstEvent *event = gst_event_new_newsegment (1.0, GST_FORMAT_TIME,
+ GstEvent *event = gst_event_new_newsegment (FALSE, 1.0, GST_FORMAT_TIME,
ts, GST_CLOCK_TIME_NONE, 0);
gst_pad_push_event (filter->srcpad, event);
#include "gstbasertppayload.h"
+GST_DEBUG_CATEGORY (basertppayload_debug);
+#define GST_CAT_DEFAULT (basertppayload_debug)
+
/* BaseRTPPayload signals and args */
enum
{
0, G_MAXUINT, 0, G_PARAM_READABLE));
gstelement_class->change_state = gst_basertppayload_change_state;
+
+ GST_DEBUG_CATEGORY_INIT (basertppayload_debug, "basertppayload", 0,
+ "Base class for RTP Payloaders");
}
static void
GstMessageType events, GstMessageType tevent)
{
GstBus *bus;
+ GstMessage *message;
GstMessageType revent;
g_assert (pipe);
}
while (1) {
- revent = gst_bus_poll (bus, GST_MESSAGE_ANY, GST_SECOND / 2);
+ message = gst_bus_poll (bus, GST_MESSAGE_ANY, GST_SECOND / 2);
+
/* always have to pop the message before getting back into poll */
- if (revent != GST_MESSAGE_UNKNOWN)
+ if (message) {
+ revent = GST_MESSAGE_TYPE (message);
gst_message_unref (gst_bus_pop (bus));
+ } else {
+ revent = GST_MESSAGE_UNKNOWN;
+ }
if (revent == tevent) {
break;
GST_MESSAGE_ANY & ~(GST_MESSAGE_ERROR | GST_MESSAGE_WARNING),
GST_MESSAGE_UNKNOWN);
}
-GST_END_TEST Suite * simple_launch_lines_suite (void)
+GST_END_TEST Suite *
+simple_launch_lines_suite (void)
{
Suite *s = suite_create ("Pipelines");
TCase *tc_chain = tcase_create ("linear");