diff -r 000000000000 -r 0e761a78d257 gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/gstreamer_core/tsrc/check/elements/gstqueue/src/gstqueue.c	Thu Dec 17 08:53:32 2009 +0200
@@ -0,0 +1,591 @@
+/* GStreamer
+ *
+ * unit test for queue
+ *
+ * Copyright (C) <2006> Stefan Kost <ensonic@users.sf.net>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Library General Public License for more details.
+ *
+ * You should have received a copy of the GNU Library General Public
+ * License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ * Boston, MA 02111-1307, USA.
+ */
+
+#include <unistd.h>
+#include <gst/gst_global.h>
+#include <gst/check/gstcheck.h>
+#include <glib_global.h>
+
+
+#define LOG_FILE "c:\\logs\\queue_log1.txt"
+#include "std_log_result.h"
+#define LOG_FILENAME_LINE __FILE__, __LINE__
+//char* xmlfile = "queue";
+
+void create_xml(int result)
+{
+    if(result)
+        assert_failed = 1;
+    
+    testResultXml(xmlfile);
+    close_log_file();
+}
+
+#include "libgstreamer_wsd_solution.h" 
+
+#if EMULATOR
+static GET_GLOBAL_VAR_FROM_TLS(buffers,gstcheck,GList*)
+#define buffers (*GET_GSTREAMER_WSD_VAR_NAME(buffers,gstcheck,g)())
+#else 
+extern GList *buffers;
+#endif
+
+
+#if EMULATOR
+GET_GLOBAL_VAR_FROM_TLS(check_mutex,gstcheck,GMutex *)
+#define check_mutex (*GET_GSTREAMER_WSD_VAR_NAME(check_mutex,gstcheck,g)())
+#else 
+extern GMutex *check_mutex;
+#endif
+
+
+#if EMULATOR
+GET_GLOBAL_VAR_FROM_TLS(check_cond,gstcheck,GCond *)
+#define check_cond (*GET_GSTREAMER_WSD_VAR_NAME(check_cond,gstcheck,g)())
+#else 
+extern GCond *check_cond;
+#endif
+
+//GList *buffers = NULL;
+static gint overrun_count = 0;
+static gint underrun_count = 0;
+
+/* For ease of programming we use globals to keep refs for our floating
+ * src and sink pads we create; otherwise we always have to do get_pad,
+ * get_peer, and then remove references in every test function */
+static GstPad *mysrcpad, *mysinkpad;
+
+static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static void
+queue_overrun (GstElement * queue, gpointer user_data)
+{
+  GST_DEBUG ("queue overrun");
+  overrun_count++;
+}
+
+static void
+queue_underrun (GstElement * queue, gpointer user_data)
+{
+  GST_DEBUG ("queue underrun");
+  g_mutex_lock (check_mutex);
+  underrun_count++;
+  g_cond_signal (check_cond);
+  g_mutex_unlock (check_mutex);
+  /// block this thread to wait to push some buffers in main thread.
+  sleep(2);
+}
+
+static GstElement *
+setup_queue (void)
+{
+  GstElement *queue;
+  
+  GST_DEBUG ("setup_queue");
+
+  overrun_count = 0;
+  underrun_count = 0;
+
+  queue = gst_check_setup_element ("queue");
+  g_signal_connect (queue, "overrun", G_CALLBACK (queue_overrun), NULL);
+  g_signal_connect (queue, "underrun", G_CALLBACK (queue_underrun), NULL);
+
+  return queue;
+}
+
+static void
+cleanup_queue (GstElement * queue)
+{
+  GST_DEBUG ("cleanup_queue");
+
+  gst_check_teardown_element (queue);
+}
+
+/* set queue size to 2 buffers
+ * pull 1 buffer
+ * check over/underuns
+ */
+void test_non_leaky_underrun()
+{
+  GstElement *queue;
+  GstBuffer *buffer = NULL;
+
+  xmlfile = "queue_test_non_leaky_underrun";
+  std_log(LOG_FILENAME_LINE, "Test Started test_non_leaky_underrun");
+    
+  queue = setup_queue ();
+  mysinkpad = gst_check_setup_sink_pad (queue, &sinktemplate, NULL);
+  gst_pad_set_active (mysinkpad, TRUE);
+  g_object_set (G_OBJECT (queue), "max-size-buffers", 2, NULL);
+
+  GST_DEBUG ("starting");
+
+  g_mutex_lock (check_mutex);
+  fail_unless (gst_element_set_state (queue,
+          GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
+      "could not set to playing");
+  TEST_ASSERT_FAIL
+  g_cond_wait (check_cond, check_mutex);
+  g_mutex_unlock (check_mutex);
+
+  fail_unless (overrun_count == 0);
+  TEST_ASSERT_FAIL
+  fail_unless (underrun_count == 1);
+  TEST_ASSERT_FAIL
+
+  fail_unless (buffer == NULL);
+  TEST_ASSERT_FAIL
+  
+  GST_DEBUG ("stopping");
+
+  /* cleanup */
+  gst_pad_set_active (mysinkpad, FALSE);
+  gst_check_teardown_sink_pad (queue);
+  cleanup_queue (queue);
+  std_log(LOG_FILENAME_LINE, "Test Successful");
+    create_xml(0);
+}
+
+
+/* set queue size to 2 buffers
+ * push 2 buffers
+ * check over/underuns
+ * push 1 more buffer
+ * check over/underuns again
+ */
+void test_non_leaky_overrun()
+{
+    GstElement *queue;
+    GstBuffer *buffer1, *buffer2, *buffer3;
+
+    xmlfile = "queue_test_non_leaky_overrun";
+      std_log(LOG_FILENAME_LINE, "Test Started test_non_leaky_overrun");
+      
+    queue = setup_queue ();
+    mysrcpad = gst_check_setup_src_pad (queue, &srctemplate, NULL);
+    mysinkpad = gst_check_setup_sink_pad (queue, &sinktemplate, NULL);
+    gst_pad_set_active (mysrcpad, TRUE);
+    g_object_set (G_OBJECT (queue), "max-size-buffers", 2, NULL);
+
+    GST_DEBUG ("starting");
+
+    g_mutex_lock (check_mutex);
+    fail_unless (gst_element_set_state (queue,
+            GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
+        "could not set to playing");
+    TEST_ASSERT_FAIL
+    /// wait for under run callback
+    g_cond_wait (check_cond, check_mutex);
+    g_mutex_unlock (check_mutex);
+    /// no buffer pushed, under run has to come, so make it zero
+    underrun_count = 0;
+    
+    buffer1 = gst_buffer_new_and_alloc (4);
+    ASSERT_BUFFER_REFCOUNT (buffer1, "buffer", 1);
+    TEST_ASSERT_FAIL
+    /* pushing gives away my reference ... */
+    gst_pad_push (mysrcpad, buffer1);
+
+    GST_DEBUG ("added 1st");
+    fail_unless (overrun_count == 0);
+    TEST_ASSERT_FAIL
+    fail_unless (underrun_count == 0);
+    TEST_ASSERT_FAIL
+
+    buffer2 = gst_buffer_new_and_alloc (4);
+    ASSERT_BUFFER_REFCOUNT (buffer2, "buffer", 1);
+    TEST_ASSERT_FAIL
+    /* pushing gives away my reference ... */
+    gst_pad_push (mysrcpad, buffer2);
+
+    GST_DEBUG ("added 2nd");
+    fail_unless (overrun_count == 0);
+    TEST_ASSERT_FAIL
+    fail_unless (underrun_count == 0);
+    TEST_ASSERT_FAIL
+
+    buffer3 = gst_buffer_new_and_alloc (4);
+    ASSERT_BUFFER_REFCOUNT (buffer3, "buffer", 1);
+    TEST_ASSERT_FAIL
+    /* pushing gives away my reference ... */
+    gst_pad_push (mysrcpad, buffer3);
+
+    GST_DEBUG ("stopping");
+
+    fail_unless (overrun_count == 1);
+    TEST_ASSERT_FAIL
+    fail_unless (underrun_count == 0);
+    TEST_ASSERT_FAIL
+
+    /* cleanup */
+    gst_pad_set_active (mysrcpad, FALSE);
+    gst_check_teardown_src_pad (queue);
+    gst_check_teardown_sink_pad (queue);
+    cleanup_queue (queue);
+    std_log(LOG_FILENAME_LINE, "Test Successful");
+      create_xml(0);
+    
+}
+
+/* set queue size to 2 buffers
+ * push 2 buffers
+ * check over/underuns
+ * push 1 more buffer
+ * check over/underuns again
+ * check which buffer was leaked
+ */
+void test_leaky_upstream()
+{
+  GstElement *queue;
+  GstBuffer *buffer1, *buffer2, *buffer3;
+  GstBuffer *buffer;
+
+  xmlfile = "queue_test_leaky_upstream";
+    std_log(LOG_FILENAME_LINE, "Test Started test_leaky_upstream");
+  queue = setup_queue ();
+  mysrcpad = gst_check_setup_src_pad (queue, &srctemplate, NULL);
+  mysinkpad = gst_check_setup_sink_pad (queue, &sinktemplate, NULL);
+  g_object_set (G_OBJECT (queue), "max-size-buffers", 2, "leaky", 1, NULL);
+  gst_pad_set_active (mysrcpad, TRUE);
+
+  GST_DEBUG ("starting");
+
+  g_mutex_lock (check_mutex);
+  fail_unless (gst_element_set_state (queue,
+          GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
+      "could not set to playing");
+  TEST_ASSERT_FAIL
+  g_cond_wait (check_cond, check_mutex);
+  g_mutex_unlock (check_mutex);
+  underrun_count = 0;
+  
+  buffer1 = gst_buffer_new_and_alloc (4);
+  ASSERT_BUFFER_REFCOUNT (buffer1, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer1);
+
+  GST_DEBUG ("added 1st");
+  fail_unless (overrun_count == 0);
+  TEST_ASSERT_FAIL
+  fail_unless (underrun_count == 0);
+  TEST_ASSERT_FAIL
+
+  buffer2 = gst_buffer_new_and_alloc (4);
+  ASSERT_BUFFER_REFCOUNT (buffer2, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer2);
+
+  GST_DEBUG ("added 2nd");
+  fail_unless (overrun_count == 0);
+  TEST_ASSERT_FAIL
+  fail_unless (underrun_count == 0);
+  TEST_ASSERT_FAIL
+
+  buffer3 = gst_buffer_new_and_alloc (4);
+  ASSERT_BUFFER_REFCOUNT (buffer3, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, gst_buffer_ref (buffer3));
+
+  g_mutex_lock (check_mutex);
+  /* start the src-task briefly leak buffer3 */
+  gst_pad_set_active (mysinkpad, TRUE);
+  g_cond_wait (check_cond, check_mutex);
+  g_mutex_unlock (check_mutex);
+
+  gst_pad_set_active (mysinkpad, FALSE);
+
+  GST_DEBUG ("stopping");
+
+  fail_unless (g_list_length (buffers) > 0);
+  TEST_ASSERT_FAIL
+  buffer = g_list_first (buffers)->data;
+  fail_unless (buffer == buffer1);
+  TEST_ASSERT_FAIL
+  ASSERT_BUFFER_REFCOUNT (buffer3, "buffer", 1);
+  TEST_ASSERT_FAIL
+
+  /* it still triggers overrun when leaking */
+  fail_unless (overrun_count == 1);
+  TEST_ASSERT_FAIL
+  /* cleanup */
+  gst_pad_set_active (mysrcpad, FALSE);
+  gst_buffer_unref (buffer3);
+  gst_check_teardown_src_pad (queue);
+  gst_check_teardown_sink_pad (queue);
+  cleanup_queue (queue);
+  std_log(LOG_FILENAME_LINE, "Test Successful");
+    create_xml(0);
+}
+
+
+void test_leaky_downstream()
+{
+  GstElement *queue;
+  GstBuffer *buffer1, *buffer2, *buffer3;
+  GstBuffer *buffer;
+
+  xmlfile = "queue_test_leaky_downstream";
+    std_log(LOG_FILENAME_LINE, "Test Started test_leaky_downstream");
+    
+  queue = setup_queue ();
+  mysrcpad = gst_check_setup_src_pad (queue, &srctemplate, NULL);
+  mysinkpad = gst_check_setup_sink_pad (queue, &sinktemplate, NULL);
+  g_object_set (G_OBJECT (queue), "max-size-buffers", 2, "leaky", 2, NULL);
+  gst_pad_set_active (mysrcpad, TRUE);
+
+  GST_DEBUG ("starting");
+
+  g_mutex_lock (check_mutex);
+  fail_unless (gst_element_set_state (queue,
+          GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
+      "could not set to playing");
+  TEST_ASSERT_FAIL
+  g_cond_wait (check_cond, check_mutex);
+  g_mutex_unlock (check_mutex);
+  underrun_count = 0;
+  
+  buffer1 = gst_buffer_new_and_alloc (4);
+  ASSERT_BUFFER_REFCOUNT (buffer1, "buffer", 1);
+  TEST_ASSERT_FAIL
+
+
+  
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, gst_buffer_ref (buffer1));
+
+  GST_DEBUG ("added 1st");
+  fail_unless (overrun_count == 0);
+  TEST_ASSERT_FAIL
+  fail_unless (underrun_count == 0);
+  TEST_ASSERT_FAIL
+
+  buffer2 = gst_buffer_new_and_alloc (4);
+  ASSERT_BUFFER_REFCOUNT (buffer2, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer2);
+
+  GST_DEBUG ("added 2nd");
+  fail_unless (overrun_count == 0);
+  TEST_ASSERT_FAIL
+  fail_unless (underrun_count == 0);
+  TEST_ASSERT_FAIL
+
+  buffer3 = gst_buffer_new_and_alloc (4);
+  ASSERT_BUFFER_REFCOUNT (buffer3, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer3);
+
+  g_mutex_lock (check_mutex);
+  /* start the src-task briefly and leak buffer1 */
+  gst_pad_set_active (mysinkpad, TRUE);
+  g_cond_wait (check_cond, check_mutex);
+  g_mutex_unlock (check_mutex);
+
+  gst_pad_set_active (mysinkpad, FALSE);
+
+  GST_DEBUG ("stopping");
+
+  fail_unless (g_list_length (buffers) > 0);
+  TEST_ASSERT_FAIL
+  buffer = g_list_first (buffers)->data;
+  fail_unless (buffer == buffer2);
+  TEST_ASSERT_FAIL
+  ASSERT_BUFFER_REFCOUNT (buffer1, "buffer", 1);
+  TEST_ASSERT_FAIL
+
+  /* it still triggers overrun when leaking */
+  fail_unless (overrun_count == 1);
+  TEST_ASSERT_FAIL
+  /* cleanup */
+  gst_pad_set_active (mysrcpad, FALSE);
+  gst_buffer_unref (buffer1);
+  gst_check_teardown_src_pad (queue);
+  gst_check_teardown_sink_pad (queue);
+  cleanup_queue (queue);
+  std_log(LOG_FILENAME_LINE, "Test Successful");
+    create_xml(0);
+}
+
+/* set queue size to 5 buffers
+ * pull 1 buffer
+ * check over/underuns
+ */
+void test_time_level()
+{
+  GstElement *queue;
+  GstBuffer *buffer = NULL;
+  GstClockTime time;
+
+  xmlfile = "queue_test_time_level";
+    std_log(LOG_FILENAME_LINE, "Test Started test_time_level");
+    
+  queue = setup_queue ();
+  mysrcpad = gst_check_setup_src_pad (queue, &srctemplate, NULL);
+  mysinkpad = gst_check_setup_sink_pad (queue, &sinktemplate, NULL);
+  g_object_set (G_OBJECT (queue), "max-size-buffers", 6, NULL);
+  g_object_set (G_OBJECT (queue), "max-size-time", 10 * GST_SECOND, NULL);
+  gst_pad_set_active (mysrcpad, TRUE);
+  gst_pad_set_active (mysinkpad, TRUE);
+
+  GST_DEBUG ("starting");
+
+  fail_unless (gst_element_set_state (queue,
+          GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS,
+      "could not set to playing");
+  TEST_ASSERT_FAIL
+
+  /* push buffer without duration */
+  buffer = gst_buffer_new_and_alloc (4);
+  GST_BUFFER_TIMESTAMP (buffer) = GST_SECOND;
+  ASSERT_BUFFER_REFCOUNT (buffer, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer);
+
+  /* level should be 1 seconds because buffer has no duration and starts at 1
+   * SECOND (sparse stream). */
+  g_object_get (G_OBJECT (queue), "current-level-time", &time, NULL);
+  fail_if (time != GST_SECOND);
+  TEST_ASSERT_FAIL
+  /* second push should set the level to 2 second */
+  buffer = gst_buffer_new_and_alloc (4);
+  GST_BUFFER_TIMESTAMP (buffer) = 2 * GST_SECOND;
+  ASSERT_BUFFER_REFCOUNT (buffer, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer);
+
+  g_object_get (G_OBJECT (queue), "current-level-time", &time, NULL);
+  fail_if (time != 2 * GST_SECOND);
+  TEST_ASSERT_FAIL
+
+  /* third push should set the level to 4 seconds, the 1 second diff with the
+   * previous buffer (without duration) and the 1 second duration of this
+   * buffer. */
+  buffer = gst_buffer_new_and_alloc (4);
+  GST_BUFFER_TIMESTAMP (buffer) = 3 * GST_SECOND;
+  GST_BUFFER_DURATION (buffer) = 1 * GST_SECOND;
+  ASSERT_BUFFER_REFCOUNT (buffer, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer);
+
+  g_object_get (G_OBJECT (queue), "current-level-time", &time, NULL);
+  fail_if (time != 4 * GST_SECOND);
+  TEST_ASSERT_FAIL
+
+  /* fourth push should set the level to 6 seconds, the 2 second diff with the
+   * previous buffer, same duration. */
+  buffer = gst_buffer_new_and_alloc (4);
+  GST_BUFFER_TIMESTAMP (buffer) = 5 * GST_SECOND;
+  GST_BUFFER_DURATION (buffer) = 1 * GST_SECOND;
+  ASSERT_BUFFER_REFCOUNT (buffer, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer);
+
+  g_object_get (G_OBJECT (queue), "current-level-time", &time, NULL);
+  fail_if (time != 6 * GST_SECOND);
+  TEST_ASSERT_FAIL
+
+  /* fifth push should not adjust the level, the timestamp and duration are the
+   * same, meaning the previous buffer did not really have a duration. */
+  buffer = gst_buffer_new_and_alloc (4);
+  GST_BUFFER_TIMESTAMP (buffer) = 5 * GST_SECOND;
+  GST_BUFFER_DURATION (buffer) = 1 * GST_SECOND;
+  ASSERT_BUFFER_REFCOUNT (buffer, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer);
+
+  g_object_get (G_OBJECT (queue), "current-level-time", &time, NULL);
+  fail_if (time != 6 * GST_SECOND);
+  TEST_ASSERT_FAIL
+
+  /* sixth push should adjust the level with 1 second, we now know the
+   * previous buffer actually had a duration of 2 SECONDS */
+  buffer = gst_buffer_new_and_alloc (4);
+  GST_BUFFER_TIMESTAMP (buffer) = 7 * GST_SECOND;
+  ASSERT_BUFFER_REFCOUNT (buffer, "buffer", 1);
+  TEST_ASSERT_FAIL
+  /* pushing gives away my reference ... */
+  gst_pad_push (mysrcpad, buffer);
+
+  g_object_get (G_OBJECT (queue), "current-level-time", &time, NULL);
+  fail_if (time != 7 * GST_SECOND);
+  TEST_ASSERT_FAIL
+
+  GST_DEBUG ("stopping");
+
+  /* cleanup */
+  gst_pad_set_active (mysinkpad, FALSE);
+  gst_check_teardown_sink_pad (queue);
+  cleanup_queue (queue);
+  std_log(LOG_FILENAME_LINE, "Test Successful");
+    create_xml(0);
+}
+
+//static Suite *
+//queue_suite (void)
+//{
+//  Suite *s = suite_create ("queue");
+//  TCase *tc_chain = tcase_create ("general");
+//
+//  suite_add_tcase (s, tc_chain);
+//  tcase_add_test (tc_chain, test_non_leaky_underrun);
+//  tcase_add_test (tc_chain, test_non_leaky_overrun);
+//  tcase_add_test (tc_chain, test_leaky_upstream);
+//  tcase_add_test (tc_chain, test_leaky_downstream);
+//  tcase_add_test (tc_chain, test_time_level);
+//
+//  return s;
+//}
+
+void (*fn[]) (void) = {
+        test_non_leaky_underrun,
+        test_non_leaky_overrun,
+        test_leaky_upstream,
+        test_leaky_downstream,
+        test_time_level
+};
+
+char *args[] = {
+        "test_non_leaky_underrun",
+        "test_non_leaky_overrun",
+        "test_leaky_upstream",
+        "test_leaky_downstream",
+        "test_time_level"
+};
+
+GST_CHECK_MAIN (queue);