/* If the URI went away, drop all these buffers */
if (souphttpsink->location == NULL) {
+ GST_DEBUG_OBJECT (souphttpsink, "URI went away, dropping queued buffers");
free_buffer_list (souphttpsink->queued_buffers);
souphttpsink->queued_buffers = NULL;
return;
}
if (n == 0) {
+ GST_DEBUG_OBJECT (souphttpsink,
+ "total size of buffers queued is 0, freeing everything");
free_buffer_list (souphttpsink->queued_buffers);
souphttpsink->queued_buffers = NULL;
g_object_unref (souphttpsink->message);
g_list_append (souphttpsink->queued_buffers, gst_buffer_ref (buffer));
if (wake) {
+ GST_DEBUG_OBJECT (souphttpsink, "setting callback for new buffers");
source = g_idle_source_new ();
g_source_set_callback (source, (GSourceFunc) (send_message),
souphttpsink, NULL);