mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-05 06:58:56 +00:00
Code Issues 1 Projects Releases Wiki Activity

ext/gnomevfs/gstgnomevfssrc.c: Aggregate short reads and add some comments and debug logging.

Browse source 
Original commit message from CVS:
* ext/gnomevfs/gstgnomevfssrc.c:
Aggregate short reads and add some comments and debug logging.
Fixes #537380
This commit is contained in:
Stefan Kost 2008-07-29 12:35:54 +00:00
parent feea3e0b1c
commit 48e7814631
2 changed files with 39 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
ChangeLog
View file

@ -1,3 +1,9 @@
2008-07-29 Stefan Kost <ensonic@users.sf.net>
* ext/gnomevfs/gstgnomevfssrc.c:
Aggregate short reads and add some comments and debug logging.
Fixes #537380
2008-07-29 Stefan Kost <ensonic@users.sf.net> 2008-07-29 Stefan Kost <ensonic@users.sf.net>
* gst/playback/gstplaybasebin.c: * gst/playback/gstplaybasebin.c:

47
ext/gnomevfs/gstgnomevfssrc.c
View file

@ -497,6 +497,13 @@ gst_gnome_vfs_src_received_headers_callback (gconstpointer in,
if (!src->iradio_mode) if (!src->iradio_mode)
return; return;
GST_DEBUG_OBJECT (src, "receiving internet radio metadata\n");
/* FIXME: Could we use "Accept-Ranges: bytes"
* http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.5
* to enable pull-mode?
*/
for (i = in_args->headers; i; i = i->next) { for (i = in_args->headers; i; i = i->next) {
char *data = (char *) i->data; char *data = (char *) i->data;
char *key = data; char *key = data;
@ -510,6 +517,8 @@ gst_gnome_vfs_src_received_headers_callback (gconstpointer in,
if (!strlen (value)) if (!strlen (value))
continue; continue;
GST_LOG_OBJECT (src, "data %s", data);
/* Icecast stuff */ /* Icecast stuff */
if (strncmp (data, "icy-metaint:", 12) == 0) { /* ugh */ if (strncmp (data, "icy-metaint:", 12) == 0) { /* ugh */
if (sscanf (data + 12, "%d", &icy_metaint) == 1) { if (sscanf (data + 12, "%d", &icy_metaint) == 1) {
@ -594,6 +603,7 @@ gst_gnome_vfs_src_create (GstBaseSrc * basesrc, guint64 offset, guint size,
GstBuffer *buf; GstBuffer *buf;
GnomeVFSFileSize readbytes; GnomeVFSFileSize readbytes;
guint8 *data; guint8 *data;
guint todo;
GstGnomeVFSSrc *src; GstGnomeVFSSrc *src;
src = GST_GNOME_VFS_SRC (basesrc); src = GST_GNOME_VFS_SRC (basesrc);
@ -605,7 +615,7 @@ gst_gnome_vfs_src_create (GstBaseSrc * basesrc, guint64 offset, guint size,
if (G_UNLIKELY (src->curoffset != offset)) { if (G_UNLIKELY (src->curoffset != offset)) {
GST_DEBUG ("need to seek"); GST_DEBUG ("need to seek");
if (src->seekable) { if (src->seekable) {
GST_DEBUG ("seeking to %lld", offset); GST_DEBUG ("seeking to %" G_GUINT64_FORMAT, offset);
res = gnome_vfs_seek (src->handle, GNOME_VFS_SEEK_START, offset); res = gnome_vfs_seek (src->handle, GNOME_VFS_SEEK_START, offset);
if (res != GNOME_VFS_OK) if (res != GNOME_VFS_OK)
goto seek_failed; goto seek_failed;
@ -618,20 +628,29 @@ gst_gnome_vfs_src_create (GstBaseSrc * basesrc, guint64 offset, guint size,
buf = gst_buffer_new_and_alloc (size); buf = gst_buffer_new_and_alloc (size);
data = GST_BUFFER_DATA (buf); data = GST_BUFFER_DATA (buf);
todo = size;
while (todo > 0) {
/* this can return less that we ask for */
res = gnome_vfs_read (src->handle, data, todo, &readbytes);
if (G_UNLIKELY (res == GNOME_VFS_ERROR_EOF || (res == GNOME_VFS_OK
&& readbytes == 0)))
goto eos;
if (G_UNLIKELY (res != GNOME_VFS_OK))
goto read_failed;
if (readbytes < todo) {
data = &data[readbytes];
todo -= readbytes;
} else {
todo = 0;
}
GST_LOG (" got size %" G_GUINT64_FORMAT, readbytes);
}
GST_BUFFER_OFFSET (buf) = src->curoffset; GST_BUFFER_OFFSET (buf) = src->curoffset;
src->curoffset += size;
res = gnome_vfs_read (src->handle, data, size, &readbytes);
if (G_UNLIKELY (res == GNOME_VFS_ERROR_EOF || (res == GNOME_VFS_OK
&& readbytes == 0)))
goto eos;
GST_BUFFER_SIZE (buf) = readbytes;
if (G_UNLIKELY (res != GNOME_VFS_OK))
goto read_failed;
src->curoffset += readbytes;
/* we're done, return the buffer */ /* we're done, return the buffer */
*buffer = buf; *buffer = buf;