+2007-04-25 Wim Taymans <wim@fluendo.com>
+
+ * gst/rtsp/gstrtpdec.c: (gst_rtp_dec_class_init),
+ (gst_rtp_dec_init), (gst_rtp_dec_set_property),
+ (gst_rtp_dec_get_property):
+ * gst/rtsp/gstrtpdec.h:
+ Add dummy latency property to be backwards compat with rtpbin.
+
+ * gst/rtsp/gstrtspsrc.c: (gst_rtspsrc_class_init),
+ (gst_rtspsrc_set_property), (gst_rtspsrc_get_property),
+ (gst_rtspsrc_stream_configure_transport),
+ (gst_rtspsrc_parse_rtpinfo):
+ * gst/rtsp/gstrtspsrc.h:
+ Add latency property and configure in the session manager.
+ Don't set invalid clock-base and seqnum-base on caps, some servers
+ sometimes don't send them.
+
2007-04-25 Tim-Philipp Müller <tim at centricular dot net>
* gst/alpha/gstalphacolor.c: (gst_alpha_color_base_init),
LAST_SIGNAL
};
+#define DEFAULT_LATENCY_MS 200
+
enum
{
PROP_0,
+ PROP_LATENCY
};
static GstStaticPadTemplate gst_rtp_dec_recv_rtp_sink_template =
gobject_class->set_property = gst_rtp_dec_set_property;
gobject_class->get_property = gst_rtp_dec_get_property;
+ g_object_class_install_property (gobject_class, PROP_LATENCY,
+ g_param_spec_uint ("latency", "Buffer latency in ms",
+ "Amount of ms to buffer", 0, G_MAXUINT, DEFAULT_LATENCY_MS,
+ G_PARAM_READWRITE));
+
/**
* GstRTPDec::request-pt-map:
* @rtpdec: the object which received the signal
gst_rtp_dec_init (GstRTPDec * rtpdec, GstRTPDecClass * klass)
{
rtpdec->provided_clock = gst_system_clock_obtain ();
+ rtpdec->latency = DEFAULT_LATENCY_MS;
}
static void
src = GST_RTP_DEC (object);
switch (prop_id) {
+ case PROP_LATENCY:
+ src->latency = g_value_get_uint (value);
+ break;
default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
src = GST_RTP_DEC (object);
switch (prop_id) {
+ case PROP_LATENCY:
+ g_value_set_uint (value, src->latency);
+ break;
default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
}
}
#define DEFAULT_DEBUG FALSE
#define DEFAULT_RETRY 20
#define DEFAULT_TIMEOUT 5000000
+#define DEFAULT_LATENCY_MS 3000
enum
{
PROP_DEBUG,
PROP_RETRY,
PROP_TIMEOUT,
+ PROP_LATENCY,
};
#define GST_TYPE_RTSP_LOWER_TRANS (gst_rtsp_lower_trans_get_type())
0, G_MAXUINT64, DEFAULT_TIMEOUT,
G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+ g_object_class_install_property (gobject_class, PROP_LATENCY,
+ g_param_spec_uint ("latency", "Buffer latency in ms",
+ "Amount of ms to buffer", 0, G_MAXUINT, DEFAULT_LATENCY_MS,
+ G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+
gstelement_class->change_state = gst_rtspsrc_change_state;
gstbin_class->handle_message = gst_rtspsrc_handle_message;
case PROP_TIMEOUT:
rtspsrc->timeout = g_value_get_uint64 (value);
break;
+ case PROP_LATENCY:
+ rtspsrc->latency = g_value_get_uint (value);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
case PROP_TIMEOUT:
g_value_set_uint64 (value, rtspsrc->timeout);
break;
+ case PROP_LATENCY:
+ g_value_set_uint (value, rtspsrc->latency);
+ break;
default:
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
break;
ret = gst_element_set_state (src->session, GST_STATE_PAUSED);
if (ret == GST_STATE_CHANGE_FAILURE)
goto start_session_failure;
+
+ g_object_set (src->session, "latency", src->latency, NULL);
}
/* we stream directly to the manager, get some pads. Each RTSP stream goes
stream->timebase = timebase;
if ((caps = stream->caps)) {
/* update caps */
- gst_caps_set_simple (caps, "clock-base", G_TYPE_UINT, timebase,
- "seqnum-base", G_TYPE_UINT, seqbase, NULL);
+ if (timebase != -1)
+ gst_caps_set_simple (caps, "clock-base", G_TYPE_UINT, timebase, NULL);
+ if (seqbase != -1)
+ gst_caps_set_simple (caps, "seqnum-base", G_TYPE_UINT, seqbase, NULL);
}
}
}