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

rtsp: Write as much as possible in gst_rtsp_source_dispatch().

Browse source 
Try to write as much as possible if there are multiple messages queued.
This commit is contained in:
Peter Kjellerstedt 2009-06-16 19:04:54 +02:00
parent e5ec74c7a9
commit 01d98fdb5d
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
gst-libs/gst/rtsp/gstrtspconnection.c
View file

@ -3060,7 +3060,7 @@ gst_rtsp_source_dispatch (GSource * source, GSourceFunc callback G_GNUC_UNUSED,
res = write_bytes (watch->writefd.fd, watch->write_data, res = write_bytes (watch->writefd.fd, watch->write_data,
&watch->write_off, watch->write_size); &watch->write_off, watch->write_size);
if (res == GST_RTSP_EINTR) if (res == GST_RTSP_EINTR)
break; goto write_blocked;
else if (G_LIKELY (res == GST_RTSP_OK)) { else if (G_LIKELY (res == GST_RTSP_OK)) {
if (watch->funcs.message_sent) if (watch->funcs.message_sent)
watch->funcs.message_sent (watch, watch->write_id, watch->user_data); watch->funcs.message_sent (watch, watch->write_id, watch->user_data);
@ -3072,17 +3072,19 @@ gst_rtsp_source_dispatch (GSource * source, GSourceFunc callback G_GNUC_UNUSED,
goto error; goto error;
} }
done:
if (g_async_queue_length (watch->messages) == 0 && watch->write_added) {
g_source_remove_poll ((GSource *) watch, &watch->writefd);
watch->write_added = FALSE;
watch->writefd.revents = 0;
}
g_free (watch->write_data); g_free (watch->write_data);
watch->write_data = NULL; watch->write_data = NULL;
} while (FALSE); } while (TRUE);
done:
if (watch->write_added) {
g_source_remove_poll ((GSource *) watch, &watch->writefd);
watch->write_added = FALSE;
watch->writefd.revents = 0;
}
} }
write_blocked:
return TRUE; return TRUE;
/* ERRORS */ /* ERRORS */