From fa8c2eb659a60bb27bf2c9cb2dfb7d767f346601 Mon Sep 17 00:00:00 2001
From: Wim Taymans <wim.taymans@gmail.com>
Date: Fri, 6 May 2005 16:18:24 +0000
Subject: [PATCH] Make the base audiosink return an error when there is no
 audiobuffer negotiated.

Original commit message from CVS:
Make the base audiosink return an error when there is no
audiobuffer negotiated.
---
 ChangeLog                             | 32 +++++++++++++++++++++++++++
 gst-libs/gst/audio/gstaudiosink.c     |  3 +++
 gst-libs/gst/audio/gstbaseaudiosink.c |  8 +++++++
 gst-libs/gst/audio/gstbaseaudiosink.h |  1 +
 gst-libs/gst/audio/gstringbuffer.c    | 25 +++++++++++++++++++++
 gst-libs/gst/audio/gstringbuffer.h    |  2 ++
 6 files changed, 71 insertions(+)

diff --git a/ChangeLog b/ChangeLog
index 37bdf3c101..47c5f0958f 100644
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,35 @@
+2005-05-06  Wim Taymans  <wim@fluendo.com>
+
+	* gst-libs/gst/audio/gstaudiosink.c:
+	(gst_audioringbuffer_get_type), (gst_audioringbuffer_class_init),
+	(audioringbuffer_thread_func), (gst_audioringbuffer_init),
+	(gst_audioringbuffer_acquire), (gst_audioringbuffer_release),
+	(gst_audioringbuffer_play), (gst_audioringbuffer_stop),
+	(gst_audioringbuffer_delay), (gst_audiosink_class_init),
+	(gst_audiosink_create_ringbuffer):
+	* gst-libs/gst/audio/gstbaseaudiosink.c:
+	(gst_baseaudiosink_class_init), (gst_baseaudiosink_init),
+	(gst_baseaudiosink_get_clock), (gst_baseaudiosink_get_time),
+	(gst_baseaudiosink_set_property), (build_linear_format),
+	(debug_spec_caps), (debug_spec_buffer),
+	(gst_baseaudiosink_setcaps), (gst_baseaudiosink_get_times),
+	(gst_baseaudiosink_event), (gst_baseaudiosink_preroll),
+	(gst_baseaudiosink_render), (gst_baseaudiosink_create_ringbuffer),
+	(gst_baseaudiosink_callback), (gst_baseaudiosink_change_state):
+	* gst-libs/gst/audio/gstbaseaudiosink.h:
+	* gst-libs/gst/audio/gstringbuffer.c: (gst_ringbuffer_get_type),
+	(gst_ringbuffer_set_callback), (gst_ringbuffer_acquire),
+	(gst_ringbuffer_release), (gst_ringbuffer_is_acquired),
+	(gst_ringbuffer_play), (gst_ringbuffer_pause),
+	(gst_ringbuffer_stop), (gst_ringbuffer_delay),
+	(gst_ringbuffer_played_samples), (gst_ringbuffer_set_sample),
+	(wait_segment), (gst_ringbuffer_commit),
+	(gst_ringbuffer_prepare_read), (gst_ringbuffer_advance),
+	(gst_ringbuffer_clear):
+	* gst-libs/gst/audio/gstringbuffer.h:
+	Make the base audiosink return an error when there is no
+	audiobuffer negotiated.
+
 2005-05-06  Zaheer Abbas Merali  <zaheerabbas at merali dot org>
 
 	* ext/Makefile.am:
diff --git a/gst-libs/gst/audio/gstaudiosink.c b/gst-libs/gst/audio/gstaudiosink.c
index a41486a08e..a3c2e23dbd 100644
--- a/gst-libs/gst/audio/gstaudiosink.c
+++ b/gst-libs/gst/audio/gstaudiosink.c
@@ -292,6 +292,9 @@ gst_audioringbuffer_release (GstRingBuffer * buf)
 
   GST_LOCK (buf);
 
+  /* free the buffer */
+  gst_buffer_unref (buf->data);
+
   if (csink->close)
     result = csink->close (sink);
 
diff --git a/gst-libs/gst/audio/gstbaseaudiosink.c b/gst-libs/gst/audio/gstbaseaudiosink.c
index 7b331ed320..9af769a004 100644
--- a/gst-libs/gst/audio/gstbaseaudiosink.c
+++ b/gst-libs/gst/audio/gstbaseaudiosink.c
@@ -484,11 +484,19 @@ gst_baseaudiosink_render (GstBaseSink * bsink, GstBuffer * buf)
   offset = GST_BUFFER_OFFSET (buf);
 
   GST_DEBUG ("in offset %llu, time %lld", offset, GST_BUFFER_TIMESTAMP (buf));
+  if (!gst_ringbuffer_is_acquired (sink->ringbuffer))
+    goto wrong_state;
 
   gst_ringbuffer_commit (sink->ringbuffer, offset,
       GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf));
 
   return GST_FLOW_OK;
+
+wrong_state:
+  {
+    GST_DEBUG ("ringbuffer in wrong state");
+    return GST_FLOW_ERROR;
+  }
 }
 
 GstRingBuffer *
diff --git a/gst-libs/gst/audio/gstbaseaudiosink.h b/gst-libs/gst/audio/gstbaseaudiosink.h
index eb37cde475..aa3ccd79e2 100644
--- a/gst-libs/gst/audio/gstbaseaudiosink.h
+++ b/gst-libs/gst/audio/gstbaseaudiosink.h
@@ -72,6 +72,7 @@ typedef struct _GstBaseAudioSinkClass GstBaseAudioSinkClass;
 struct _GstBaseAudioSink {
   GstBaseSink 	 element;
 
+  /*< protected >*/ /* with LOCK */
   /* our ringbuffer */
   GstRingBuffer *ringbuffer;
 
diff --git a/gst-libs/gst/audio/gstringbuffer.c b/gst-libs/gst/audio/gstringbuffer.c
index 339b9e5b53..e39167940a 100644
--- a/gst-libs/gst/audio/gstringbuffer.c
+++ b/gst-libs/gst/audio/gstringbuffer.c
@@ -238,6 +238,31 @@ done:
   return res;
 }
 
+/**
+ * gst_ringbuffer_is_acquired:
+ * @buf: the #GstRingBuffer to check
+ *
+ * Check if the ringbuffer is acquired and ready to use.
+ *
+ * Returns: TRUE if the ringbuffer is acquired, FALSE on error.
+ *
+ * MT safe.
+ */
+gboolean
+gst_ringbuffer_is_acquired (GstRingBuffer * buf)
+{
+  gboolean res;
+
+  g_return_val_if_fail (buf != NULL, FALSE);
+
+  GST_LOCK (buf);
+  res = buf->acquired;
+  GST_UNLOCK (buf);
+
+  return res;
+}
+
+
 /**
  * gst_ringbuffer_play:
  * @buf: the #GstRingBuffer to play
diff --git a/gst-libs/gst/audio/gstringbuffer.h b/gst-libs/gst/audio/gstringbuffer.h
index 3ff630afad..38079c5dbd 100644
--- a/gst-libs/gst/audio/gstringbuffer.h
+++ b/gst-libs/gst/audio/gstringbuffer.h
@@ -198,6 +198,8 @@ void     	gst_ringbuffer_set_callback   	(GstRingBuffer *buf, GstRingBufferCallb
 gboolean 	gst_ringbuffer_acquire 		(GstRingBuffer *buf, GstRingBufferSpec *spec);
 gboolean 	gst_ringbuffer_release 		(GstRingBuffer *buf);
 
+gboolean 	gst_ringbuffer_is_acquired	(GstRingBuffer *buf);
+
 /* playback/pause */
 gboolean 	gst_ringbuffer_play 		(GstRingBuffer *buf);
 gboolean 	gst_ringbuffer_pause 		(GstRingBuffer *buf);