mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2025-01-18 05:16:05 +00:00
ext/gnomevfs/: add/clean up debugging
Original commit message from CVS: * ext/gnomevfs/gstgnomevfs.c: (plugin_init): * ext/gnomevfs/gstgnomevfssrc.c: (audiocast_init), (audiocast_register_listener), (audiocast_thread_run), (gst_gnomevfssrc_send_additional_headers_callback), (gst_gnomevfssrc_received_headers_callback), (gst_gnomevfssrc_push_callbacks), (gst_gnomevfssrc_pop_callbacks), (gst_gnomevfssrc_get_icy_metadata), (gst_gnomevfssrc_create), (gst_gnomevfssrc_get_size): add/clean up debugging * gst/audiorate/gstaudiorate.c: (gst_audiorate_init): cleanups
This commit is contained in:
parent
c3c4260ea8
commit
c1b14f407b
4 changed files with 56 additions and 30 deletions
14
ChangeLog
14
ChangeLog
|
@ -1,3 +1,17 @@
|
||||||
|
2005-07-08 Thomas Vander Stichele <thomas at apestaart dot org>
|
||||||
|
|
||||||
|
* ext/gnomevfs/gstgnomevfs.c: (plugin_init):
|
||||||
|
* ext/gnomevfs/gstgnomevfssrc.c: (audiocast_init),
|
||||||
|
(audiocast_register_listener), (audiocast_thread_run),
|
||||||
|
(gst_gnomevfssrc_send_additional_headers_callback),
|
||||||
|
(gst_gnomevfssrc_received_headers_callback),
|
||||||
|
(gst_gnomevfssrc_push_callbacks), (gst_gnomevfssrc_pop_callbacks),
|
||||||
|
(gst_gnomevfssrc_get_icy_metadata), (gst_gnomevfssrc_create),
|
||||||
|
(gst_gnomevfssrc_get_size):
|
||||||
|
add/clean up debugging
|
||||||
|
* gst/audiorate/gstaudiorate.c: (gst_audiorate_init):
|
||||||
|
cleanups
|
||||||
|
|
||||||
2005-07-07 Andy Wingo <wingo@pobox.com>
|
2005-07-07 Andy Wingo <wingo@pobox.com>
|
||||||
|
|
||||||
* sys/v4l/gstv4lsrc.c (gst_v4lsrc_fixate): Also fixate the
|
* sys/v4l/gstv4lsrc.c (gst_v4lsrc_fixate): Also fixate the
|
||||||
|
|
|
@ -29,16 +29,25 @@
|
||||||
#include <libgnomevfs/gnome-vfs.h>
|
#include <libgnomevfs/gnome-vfs.h>
|
||||||
#include <gst/gst.h>
|
#include <gst/gst.h>
|
||||||
|
|
||||||
|
GST_DEBUG_CATEGORY_EXTERN (gnomevfssrc_debug);
|
||||||
static gboolean
|
static gboolean
|
||||||
plugin_init (GstPlugin * plugin)
|
plugin_init (GstPlugin * plugin)
|
||||||
{
|
{
|
||||||
gnome_vfs_init ();
|
gnome_vfs_init ();
|
||||||
|
|
||||||
if (!gst_element_register (plugin, "gnomevfssrc", GST_RANK_SECONDARY, gst_gnomevfssrc_get_type ()) /*||
|
GST_DEBUG_CATEGORY_INIT (gnomevfssrc_debug, "gnomevfssrc", 0,
|
||||||
!gst_element_register (plugin, "gnomevfssink",
|
"Gnome-VFS Source");
|
||||||
GST_RANK_SECONDARY, gst_gnomevfssink_get_type ()) */ ) {
|
|
||||||
|
|
||||||
|
if (!gst_element_register (plugin, "gnomevfssrc", GST_RANK_SECONDARY,
|
||||||
|
gst_gnomevfssrc_get_type ()))
|
||||||
return FALSE;
|
return FALSE;
|
||||||
}
|
/*
|
||||||
|
if (!gst_element_register (plugin, "gnomevfssink", GST_RANK_SECONDARY,
|
||||||
|
gst_gnomevfssink_get_type ()))
|
||||||
|
return FALSE;
|
||||||
|
*/
|
||||||
|
|
||||||
#ifdef ENABLE_NLS
|
#ifdef ENABLE_NLS
|
||||||
setlocale (LC_ALL, "");
|
setlocale (LC_ALL, "");
|
||||||
bindtextdomain (GETTEXT_PACKAGE, LOCALEDIR);
|
bindtextdomain (GETTEXT_PACKAGE, LOCALEDIR);
|
||||||
|
@ -50,5 +59,5 @@ plugin_init (GstPlugin * plugin)
|
||||||
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
|
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
|
||||||
GST_VERSION_MINOR,
|
GST_VERSION_MINOR,
|
||||||
"gnomevfs",
|
"gnomevfs",
|
||||||
"elements to access the Gnome vfs",
|
"elements to read from and write to Gnome-VFS uri's",
|
||||||
plugin_init, VERSION, GST_LICENSE, GST_PACKAGE, GST_ORIGIN)
|
plugin_init, VERSION, GST_LICENSE, GST_PACKAGE, GST_ORIGIN)
|
||||||
|
|
|
@ -55,6 +55,9 @@
|
||||||
/* gnome-vfs.h doesn't include the following header, which we need: */
|
/* gnome-vfs.h doesn't include the following header, which we need: */
|
||||||
#include <libgnomevfs/gnome-vfs-standard-callbacks.h>
|
#include <libgnomevfs/gnome-vfs-standard-callbacks.h>
|
||||||
|
|
||||||
|
GST_DEBUG_CATEGORY (gnomevfssrc_debug);
|
||||||
|
#define GST_CAT_DEFAULT gnomevfssrc_debug
|
||||||
|
|
||||||
#define GST_TYPE_GNOMEVFSSRC \
|
#define GST_TYPE_GNOMEVFSSRC \
|
||||||
(gst_gnomevfssrc_get_type())
|
(gst_gnomevfssrc_get_type())
|
||||||
#define GST_GNOMEVFSSRC(obj) \
|
#define GST_GNOMEVFSSRC(obj) \
|
||||||
|
@ -529,7 +532,7 @@ audiocast_init (GstGnomeVFSSrc * src)
|
||||||
|
|
||||||
if (!src->iradio_mode)
|
if (!src->iradio_mode)
|
||||||
return TRUE;
|
return TRUE;
|
||||||
GST_DEBUG ("audiocast: registering listener");
|
GST_DEBUG_OBJECT (src, "audiocast: registering listener");
|
||||||
if (audiocast_register_listener (&src->audiocast_port,
|
if (audiocast_register_listener (&src->audiocast_port,
|
||||||
&src->audiocast_fd) < 0) {
|
&src->audiocast_fd) < 0) {
|
||||||
GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ, (NULL),
|
GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ, (NULL),
|
||||||
|
@ -537,7 +540,7 @@ audiocast_init (GstGnomeVFSSrc * src)
|
||||||
close (src->audiocast_fd);
|
close (src->audiocast_fd);
|
||||||
return FALSE;
|
return FALSE;
|
||||||
}
|
}
|
||||||
GST_DEBUG ("audiocast: creating pipe");
|
GST_DEBUG_OBJECT (src, "audiocast: creating pipe");
|
||||||
src->audiocast_notify_queue = NULL;
|
src->audiocast_notify_queue = NULL;
|
||||||
if (pipe (pipefds) < 0) {
|
if (pipe (pipefds) < 0) {
|
||||||
close (src->audiocast_fd);
|
close (src->audiocast_fd);
|
||||||
|
@ -545,7 +548,7 @@ audiocast_init (GstGnomeVFSSrc * src)
|
||||||
}
|
}
|
||||||
src->audiocast_thread_die_infd = pipefds[0];
|
src->audiocast_thread_die_infd = pipefds[0];
|
||||||
src->audiocast_thread_die_outfd = pipefds[1];
|
src->audiocast_thread_die_outfd = pipefds[1];
|
||||||
GST_DEBUG ("audiocast: creating audiocast thread");
|
GST_DEBUG_OBJECT (src, "audiocast: creating audiocast thread");
|
||||||
src->audiocast_thread =
|
src->audiocast_thread =
|
||||||
g_thread_create ((GThreadFunc) audiocast_thread_run, src, TRUE, &error);
|
g_thread_create ((GThreadFunc) audiocast_thread_run, src, TRUE, &error);
|
||||||
if (error != NULL) {
|
if (error != NULL) {
|
||||||
|
@ -564,7 +567,7 @@ audiocast_register_listener (gint * port, gint * fd)
|
||||||
int sock;
|
int sock;
|
||||||
socklen_t sinlen = sizeof (struct sockaddr_in);
|
socklen_t sinlen = sizeof (struct sockaddr_in);
|
||||||
|
|
||||||
GST_DEBUG ("audiocast: estabilishing UDP listener");
|
GST_DEBUG ("audiocast: establishing UDP listener");
|
||||||
|
|
||||||
if ((sock = socket (AF_INET, SOCK_DGRAM, 0)) < 0)
|
if ((sock = socket (AF_INET, SOCK_DGRAM, 0)) < 0)
|
||||||
goto lose;
|
goto lose;
|
||||||
|
@ -686,7 +689,7 @@ audiocast_thread_run (GstGnomeVFSSrc * src)
|
||||||
g_mutex_lock (src->audiocast_queue_mutex);
|
g_mutex_lock (src->audiocast_queue_mutex);
|
||||||
src->audiocast_notify_queue =
|
src->audiocast_notify_queue =
|
||||||
g_list_append (src->audiocast_notify_queue, "iradio-title");
|
g_list_append (src->audiocast_notify_queue, "iradio-title");
|
||||||
GST_DEBUG ("audiocast title: %s\n", src->iradio_title);
|
GST_DEBUG_OBJECT (src, "audiocast title: %s\n", src->iradio_title);
|
||||||
g_mutex_unlock (src->audiocast_queue_mutex);
|
g_mutex_unlock (src->audiocast_queue_mutex);
|
||||||
} else if (!strncmp (lines[i], "x-audiocast-streamurl", 21)) {
|
} else if (!strncmp (lines[i], "x-audiocast-streamurl", 21)) {
|
||||||
g_mutex_lock (src->audiocast_udpdata_mutex);
|
g_mutex_lock (src->audiocast_udpdata_mutex);
|
||||||
|
@ -697,7 +700,7 @@ audiocast_thread_run (GstGnomeVFSSrc * src)
|
||||||
g_mutex_lock (src->audiocast_queue_mutex);
|
g_mutex_lock (src->audiocast_queue_mutex);
|
||||||
src->audiocast_notify_queue =
|
src->audiocast_notify_queue =
|
||||||
g_list_append (src->audiocast_notify_queue, "iradio-url");
|
g_list_append (src->audiocast_notify_queue, "iradio-url");
|
||||||
GST_DEBUG ("audiocast url: %s\n", src->iradio_title);
|
GST_DEBUG_OBJECT (src, "audiocast url: %s\n", src->iradio_title);
|
||||||
g_mutex_unlock (src->audiocast_queue_mutex);
|
g_mutex_unlock (src->audiocast_queue_mutex);
|
||||||
} else if (!strncmp (lines[i], "x-audiocast-udpseqnr", 20)) {
|
} else if (!strncmp (lines[i], "x-audiocast-udpseqnr", 20)) {
|
||||||
gchar outbuf[120];
|
gchar outbuf[120];
|
||||||
|
@ -711,7 +714,7 @@ audiocast_thread_run (GstGnomeVFSSrc * src)
|
||||||
strerror (errno));
|
strerror (errno));
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
GST_DEBUG ("sent audiocast ack: %s\n", outbuf);
|
GST_DEBUG_OBJECT (src, "sent audiocast ack: %s\n", outbuf);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
g_strfreev (lines);
|
g_strfreev (lines);
|
||||||
|
@ -751,7 +754,7 @@ gst_gnomevfssrc_send_additional_headers_callback (gconstpointer in,
|
||||||
|
|
||||||
if (!src->iradio_mode)
|
if (!src->iradio_mode)
|
||||||
return;
|
return;
|
||||||
GST_DEBUG ("sending headers\n");
|
GST_DEBUG_OBJECT (src, "sending headers\n");
|
||||||
|
|
||||||
out_args->headers = g_list_append (out_args->headers,
|
out_args->headers = g_list_append (out_args->headers,
|
||||||
g_strdup ("icy-metadata:1\r\n"));
|
g_strdup ("icy-metadata:1\r\n"));
|
||||||
|
@ -790,7 +793,7 @@ gst_gnomevfssrc_received_headers_callback (gconstpointer in,
|
||||||
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) {
|
||||||
src->icy_metaint = icy_metaint;
|
src->icy_metaint = icy_metaint;
|
||||||
GST_DEBUG ("got icy-metaint %d, killing audiocast thread",
|
GST_DEBUG_OBJECT (src, "got icy-metaint %d, killing audiocast thread",
|
||||||
src->icy_metaint);
|
src->icy_metaint);
|
||||||
audiocast_thread_kill (src);
|
audiocast_thread_kill (src);
|
||||||
continue;
|
continue;
|
||||||
|
@ -804,7 +807,7 @@ gst_gnomevfssrc_received_headers_callback (gconstpointer in,
|
||||||
else
|
else
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
GST_DEBUG ("key: %s", key);
|
GST_DEBUG_OBJECT (src, "key: %s", key);
|
||||||
if (!strncmp (key, "name", 4)) {
|
if (!strncmp (key, "name", 4)) {
|
||||||
g_free (src->iradio_name);
|
g_free (src->iradio_name);
|
||||||
src->iradio_name = gst_gnomevfssrc_unicodify (value);
|
src->iradio_name = gst_gnomevfssrc_unicodify (value);
|
||||||
|
@ -825,29 +828,29 @@ gst_gnomevfssrc_received_headers_callback (gconstpointer in,
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
gst_gnomevfssrc_push_callbacks (GstGnomeVFSSrc * gnomevfssrc)
|
gst_gnomevfssrc_push_callbacks (GstGnomeVFSSrc * src)
|
||||||
{
|
{
|
||||||
if (gnomevfssrc->http_callbacks_pushed)
|
if (src->http_callbacks_pushed)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
GST_DEBUG ("pushing callbacks");
|
GST_DEBUG_OBJECT (src, "pushing callbacks");
|
||||||
gnome_vfs_module_callback_push
|
gnome_vfs_module_callback_push
|
||||||
(GNOME_VFS_MODULE_CALLBACK_HTTP_SEND_ADDITIONAL_HEADERS,
|
(GNOME_VFS_MODULE_CALLBACK_HTTP_SEND_ADDITIONAL_HEADERS,
|
||||||
gst_gnomevfssrc_send_additional_headers_callback, gnomevfssrc, NULL);
|
gst_gnomevfssrc_send_additional_headers_callback, src, NULL);
|
||||||
gnome_vfs_module_callback_push
|
gnome_vfs_module_callback_push
|
||||||
(GNOME_VFS_MODULE_CALLBACK_HTTP_RECEIVED_HEADERS,
|
(GNOME_VFS_MODULE_CALLBACK_HTTP_RECEIVED_HEADERS,
|
||||||
gst_gnomevfssrc_received_headers_callback, gnomevfssrc, NULL);
|
gst_gnomevfssrc_received_headers_callback, src, NULL);
|
||||||
|
|
||||||
gnomevfssrc->http_callbacks_pushed = TRUE;
|
src->http_callbacks_pushed = TRUE;
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
gst_gnomevfssrc_pop_callbacks (GstGnomeVFSSrc * gnomevfssrc)
|
gst_gnomevfssrc_pop_callbacks (GstGnomeVFSSrc * src)
|
||||||
{
|
{
|
||||||
if (!gnomevfssrc->http_callbacks_pushed)
|
if (!src->http_callbacks_pushed)
|
||||||
return;
|
return;
|
||||||
|
|
||||||
GST_DEBUG ("popping callbacks");
|
GST_DEBUG_OBJECT (src, "popping callbacks");
|
||||||
gnome_vfs_module_callback_pop
|
gnome_vfs_module_callback_pop
|
||||||
(GNOME_VFS_MODULE_CALLBACK_HTTP_SEND_ADDITIONAL_HEADERS);
|
(GNOME_VFS_MODULE_CALLBACK_HTTP_SEND_ADDITIONAL_HEADERS);
|
||||||
gnome_vfs_module_callback_pop
|
gnome_vfs_module_callback_pop
|
||||||
|
@ -866,7 +869,7 @@ gst_gnomevfssrc_get_icy_metadata (GstGnomeVFSSrc * src)
|
||||||
gchar **tags;
|
gchar **tags;
|
||||||
int i;
|
int i;
|
||||||
|
|
||||||
GST_DEBUG ("reading icecast metadata");
|
GST_DEBUG_OBJECT (src, "reading icecast metadata");
|
||||||
|
|
||||||
while (length == 0) {
|
while (length == 0) {
|
||||||
res = gnome_vfs_read (src->handle, &foobyte, 1, &length);
|
res = gnome_vfs_read (src->handle, &foobyte, 1, &length);
|
||||||
|
@ -902,7 +905,7 @@ gst_gnomevfssrc_get_icy_metadata (GstGnomeVFSSrc * src)
|
||||||
g_free (src->iradio_title);
|
g_free (src->iradio_title);
|
||||||
src->iradio_title = gst_gnomevfssrc_unicodify (tags[i] + 13);
|
src->iradio_title = gst_gnomevfssrc_unicodify (tags[i] + 13);
|
||||||
if (src->iradio_title) {
|
if (src->iradio_title) {
|
||||||
GST_DEBUG ("sending notification on icecast title");
|
GST_DEBUG_OBJECT (src, "sending notification on icecast title");
|
||||||
g_object_notify (G_OBJECT (src), "iradio-title");
|
g_object_notify (G_OBJECT (src), "iradio-title");
|
||||||
} else
|
} else
|
||||||
g_print ("Unable to convert icecast title \"%s\" to UTF-8!\n",
|
g_print ("Unable to convert icecast title \"%s\" to UTF-8!\n",
|
||||||
|
@ -913,7 +916,7 @@ gst_gnomevfssrc_get_icy_metadata (GstGnomeVFSSrc * src)
|
||||||
g_free (src->iradio_url);
|
g_free (src->iradio_url);
|
||||||
src->iradio_url = gst_gnomevfssrc_unicodify (tags[i] + 11);
|
src->iradio_url = gst_gnomevfssrc_unicodify (tags[i] + 11);
|
||||||
if (src->iradio_url) {
|
if (src->iradio_url) {
|
||||||
GST_DEBUG ("sending notification on icecast url");
|
GST_DEBUG_OBJECT (src, "sending notification on icecast url");
|
||||||
g_object_notify (G_OBJECT (src), "iradio-url");
|
g_object_notify (G_OBJECT (src), "iradio-url");
|
||||||
} else
|
} else
|
||||||
g_print ("Unable to convert icecast url \"%s\" to UTF-8!\n",
|
g_print ("Unable to convert icecast url \"%s\" to UTF-8!\n",
|
||||||
|
@ -969,7 +972,8 @@ gst_gnomevfssrc_create (GstBaseSrc * basesrc, guint64 offset, guint size,
|
||||||
data = GST_BUFFER_DATA (buf);
|
data = GST_BUFFER_DATA (buf);
|
||||||
|
|
||||||
/* try to read */
|
/* try to read */
|
||||||
GST_DEBUG ("doing read: icy_count: %" G_GINT64_FORMAT, src->icy_count);
|
GST_DEBUG_OBJECT (src, "doing read: icy_count: %" G_GINT64_FORMAT,
|
||||||
|
src->icy_count);
|
||||||
|
|
||||||
res = gnome_vfs_read (src->handle, data,
|
res = gnome_vfs_read (src->handle, data,
|
||||||
src->icy_metaint - src->icy_count, &readbytes);
|
src->icy_metaint - src->icy_count, &readbytes);
|
||||||
|
@ -1045,7 +1049,7 @@ gst_gnomevfssrc_get_size (GstBaseSrc * basesrc, guint64 * size)
|
||||||
|
|
||||||
src = GST_GNOMEVFSSRC (basesrc);
|
src = GST_GNOMEVFSSRC (basesrc);
|
||||||
|
|
||||||
GST_DEBUG ("size %lld", src->size);
|
GST_DEBUG_OBJECT (src, "size %" G_GUINT64_FORMAT, src->size);
|
||||||
|
|
||||||
if (src->size == (GnomeVFSFileSize) - 1)
|
if (src->size == (GnomeVFSFileSize) - 1)
|
||||||
return FALSE;
|
return FALSE;
|
||||||
|
|
|
@ -218,7 +218,6 @@ gst_audiorate_setcaps (GstPad * pad, GstCaps * caps)
|
||||||
static void
|
static void
|
||||||
gst_audiorate_init (GstAudiorate * audiorate)
|
gst_audiorate_init (GstAudiorate * audiorate)
|
||||||
{
|
{
|
||||||
GST_DEBUG ("gst_audiorate_init");
|
|
||||||
audiorate->sinkpad =
|
audiorate->sinkpad =
|
||||||
gst_pad_new_from_template (gst_static_pad_template_get
|
gst_pad_new_from_template (gst_static_pad_template_get
|
||||||
(&gst_audiorate_sink_template), "sink");
|
(&gst_audiorate_sink_template), "sink");
|
||||||
|
|
Loading…
Reference in a new issue