/* check for flushing, we need to discard the event and return FALSE when
* we are flushing */
ret = priv->srcresult == GST_FLOW_OK;
- if (ret) {
+ if (ret && !priv->eos) {
GST_DEBUG_OBJECT (jitterbuffer, "queuing EOS");
priv->eos = TRUE;
JBUF_SIGNAL (priv);
+ } else if (priv->eos) {
+ GST_DEBUG_OBJECT (jitterbuffer, "dropping EOS, we are already EOS");
} else {
GST_DEBUG_OBJECT (jitterbuffer, "dropping EOS, reason %s",
gst_flow_get_name (priv->srcresult));
- gst_event_unref (event);
}
JBUF_UNLOCK (priv);
+ gst_event_unref (event);
break;
}
default:
}
not_negotiated:
{
- GST_DEBUG_OBJECT (jitterbuffer, "No clock-rate in caps!");
+ GST_WARNING_OBJECT (jitterbuffer, "No clock-rate in caps!");
gst_buffer_unref (buffer);
gst_object_unref (jitterbuffer);
return GST_FLOW_NOT_NEGOTIATED;
have_eos:
{
ret = GST_FLOW_UNEXPECTED;
- GST_DEBUG_OBJECT (jitterbuffer, "we are EOS, refusing buffer");
+ GST_WARNING_OBJECT (jitterbuffer, "we are EOS, refusing buffer");
gst_buffer_unref (buffer);
goto finished;
}
too_late:
{
- GST_DEBUG_OBJECT (jitterbuffer, "Packet #%d too late as #%d was already"
+ GST_WARNING_OBJECT (jitterbuffer, "Packet #%d too late as #%d was already"
" popped, dropping", seqnum, priv->last_popped_seqnum);
priv->num_late++;
gst_buffer_unref (buffer);
}
duplicate:
{
- GST_DEBUG_OBJECT (jitterbuffer, "Duplicate packet #%d detected, dropping",
+ GST_WARNING_OBJECT (jitterbuffer, "Duplicate packet #%d detected, dropping",
seqnum);
priv->num_duplicates++;
gst_buffer_unref (buffer);
JBUF_LOCK_CHECK (priv, flushing);
again:
GST_DEBUG_OBJECT (jitterbuffer, "Popping item");
- /* wait if we are blocked or don't have a packet and eos */
- while (priv->blocked || !(rtp_jitter_buffer_num_packets (priv->jbuf)
- || priv->eos)) {
+ while (TRUE) {
+
+ /* always wait if we are blocked */
+ if (!priv->blocked) {
+ /* if we have a packet, we can grab it */
+ if (rtp_jitter_buffer_num_packets (priv->jbuf) > 0)
+ break;
+ /* no packets but we are EOS, do eos logic */
+ if (priv->eos)
+ goto do_eos;
+ }
JBUF_WAIT_CHECK (priv, flushing);
}
- if (priv->eos)
- goto do_eos;
/* pop a buffer, we must have a buffer now */
outbuf = rtp_jitter_buffer_pop (priv->jbuf);
if (priv->next_seqnum != -1) {
/* we expected next_seqnum but received something else, that's a gap */
- GST_DEBUG_OBJECT (jitterbuffer,
+ GST_WARNING_OBJECT (jitterbuffer,
"Sequence number GAP detected -> %d instead of %d", priv->next_seqnum,
seqnum);
} else {
flushing:
{
GST_DEBUG_OBJECT (jitterbuffer, "we are flushing");
+ gst_pad_pause_task (priv->srcpad);
if (outbuf)
gst_buffer_unref (outbuf);
JBUF_UNLOCK (priv);
GstClockTime current_time;
GstClockTime next_timeout;
- clock = gst_element_get_clock (GST_ELEMENT_CAST (rtpsession));
+ /* RTCP timeouts we use the system clock */
+ clock = gst_system_clock_obtain ();
if (clock == NULL)
- return;
+ goto no_clock;
current_time = gst_clock_get_time (clock);
gst_object_unref (clock);
GST_DEBUG_OBJECT (rtpsession, "leaving RTCP thread");
+ return;
+
+ /* ERRORS */
+no_clock:
+ {
+ GST_ELEMENT_ERROR (rtpsession, CORE, CLOCK, (NULL),
+ ("Could not get system clock"));
+ return;
+ }
}
static gboolean
switch (GST_EVENT_TYPE (event)) {
default:
+ if (rtpsession->send_rtcp_src) {
+ gst_event_ref (event);
+ ret = gst_pad_push_event (rtpsession->send_rtcp_src, event);
+ }
ret = gst_pad_push_event (rtpsession->sync_src, event);
break;
}
static void
on_new_ssrc (RTPSession * sess, RTPSource * source)
{
+ RTP_SESSION_UNLOCK (sess);
g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_NEW_SSRC], 0, source);
+ RTP_SESSION_LOCK (sess);
}
static void
on_ssrc_collision (RTPSession * sess, RTPSource * source)
{
+ RTP_SESSION_UNLOCK (sess);
g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_SSRC_COLLISION], 0,
source);
+ RTP_SESSION_LOCK (sess);
}
static void
on_ssrc_validated (RTPSession * sess, RTPSource * source)
{
+ RTP_SESSION_UNLOCK (sess);
g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_SSRC_VALIDATED], 0,
source);
+ RTP_SESSION_LOCK (sess);
}
static void
on_bye_ssrc (RTPSession * sess, RTPSource * source)
{
+ RTP_SESSION_UNLOCK (sess);
g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_BYE_SSRC], 0, source);
+ RTP_SESSION_LOCK (sess);
}
static void
on_bye_timeout (RTPSession * sess, RTPSource * source)
{
+ RTP_SESSION_UNLOCK (sess);
g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_BYE_TIMEOUT], 0, source);
+ RTP_SESSION_LOCK (sess);
}
static void
on_timeout (RTPSession * sess, RTPSource * source)
{
+ RTP_SESSION_UNLOCK (sess);
g_signal_emit (sess, rtp_session_signals[SIGNAL_ON_TIMEOUT], 0, source);
+ RTP_SESSION_LOCK (sess);
}
/**