diff options
author | Wim Taymans <wim.taymans@gmail.com> | 2001-05-16 22:09:29 +0000 |
---|---|---|
committer | Wim Taymans <wim.taymans@gmail.com> | 2001-05-16 22:09:29 +0000 |
commit | 846ce23d289a3877d42a701868ba2ddd665485ad (patch) | |
tree | a2b13307db196af51970dd7eb757ea64fa8e5829 | |
parent | 137e5a6d93862855a0df9f32a662bb81c3cf2699 (diff) |
Added thread refcounting and module test case
Original commit message from CVS:
Added thread refcounting and module test case
-rw-r--r-- | tests/old/testsuite/refcounting/thread.c | 281 | ||||
-rw-r--r-- | testsuite/refcounting/thread.c | 281 |
2 files changed, 562 insertions, 0 deletions
diff --git a/tests/old/testsuite/refcounting/thread.c b/tests/old/testsuite/refcounting/thread.c new file mode 100644 index 0000000000..f229a54c60 --- /dev/null +++ b/tests/old/testsuite/refcounting/thread.c @@ -0,0 +1,281 @@ +#include <gst/gst.h> + +#define ITERS 100000 +#include <stdlib.h> +#include "mem.h" + +static GstElement* +create_thread (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + gst_bin_add (GST_BIN (thread), element); + element = gst_element_new (); + gst_element_set_name (element, "test2"); + gst_bin_add (GST_BIN (thread), element); + + return thread; +} + +static GstElement* +create_thread_ghostpads (void) +{ + GstElement *thread; + GstElement *element1, *element2; + + thread = gst_thread_new ("testthread"); + element1 = gst_element_new (); + gst_element_set_name (element1, "test1"); + gst_element_add_pad (element1, gst_pad_new ("src1", GST_PAD_SRC)); + gst_bin_add (GST_BIN (thread), element1); + element2 = gst_element_new (); + gst_element_set_name (element2, "test2"); + gst_element_add_pad (element2, gst_pad_new ("sink1", GST_PAD_SINK)); + gst_bin_add (GST_BIN (thread), element2); + gst_element_connect (element1, "src1", element2, "sink1"); + gst_element_add_ghost_pad (thread, gst_element_get_pad (element2, "sink1"), "sink1"); + + return thread; +} + +static void +add_remove_test1 (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + gst_bin_remove (GST_BIN (thread), element); + + gst_object_unref (GST_OBJECT (thread)); +} + +static void +add_remove_test2 (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + gst_object_ref (GST_OBJECT (element)); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + gst_bin_remove (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + g_assert (!GST_OBJECT_DESTROYED (element)); + + gst_object_destroy (GST_OBJECT (element)); + g_assert (GST_OBJECT_DESTROYED (element)); + gst_object_unref (GST_OBJECT (element)); + + gst_object_unref (GST_OBJECT (thread)); +} + +static void +add_remove_test3 (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + + gst_object_destroy (GST_OBJECT (element)); + g_assert (gst_bin_get_by_name (GST_BIN (thread), "test1") == NULL); + + gst_object_unref (GST_OBJECT (thread)); +} + +static void +add_remove_test4 (void) +{ + GstElement *thread, *thread2; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + + thread2 = create_thread (); + g_assert (GST_OBJECT_FLOATING (thread2)); + gst_bin_add (GST_BIN (thread), thread2); + g_assert (!GST_OBJECT_FLOATING (thread2)); + + gst_object_destroy (GST_OBJECT (thread2)); + g_assert (gst_bin_get_by_name (GST_BIN (thread), "testthread") == NULL); + gst_object_destroy (GST_OBJECT (element)); + g_assert (gst_bin_get_by_name (GST_BIN (thread), "test1") == NULL); + + gst_object_unref (GST_OBJECT (thread)); +} + +int +main (int argc, gchar *argv[]) +{ + GstElement *thread, *element; + long usage1; + gint i, iters; + + gst_init (&argc, &argv); + + if (argc == 2) + iters = atoi (argv[1]); + else + iters = ITERS; + + g_print ("starting test\n"); + usage1 = vmsize(); + + thread = gst_thread_new ("somethread"); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d threads %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + g_assert (GST_OBJECT_FLOATING (thread)); + gst_object_ref (GST_OBJECT (thread)); + gst_object_sink (GST_OBJECT (thread)); + g_assert (!GST_OBJECT_FLOATING (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/ref/sink/unref new thread %ld\n", vmsize()-usage1); + + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_sink (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/ref/sink/unref %d threads %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + g_assert (!GST_OBJECT_DESTROYED (thread)); + gst_object_destroy (GST_OBJECT (thread)); + g_assert (GST_OBJECT_DESTROYED (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/destroy/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_destroy (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/destroy/unref %d thread %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/ref/unref/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/ref/unref/unref %d thread %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_destroy (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("craete/ref/destroy/unref/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_destroy (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("craete/ref/destroy/unref/unref %d threads %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_element_set_name (thread, "testing123"); + gst_object_destroy (GST_OBJECT (thread)); + gst_element_set_name (thread, "testing123"); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("craete/ref/destroy/unref/unref %d threads with name %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + for (i=0; i<iters;i++) { + gst_element_set_name (thread, "testing"); + } + gst_object_unref (GST_OBJECT (thread)); + g_print ("set name %d times %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + gst_bin_add (GST_BIN (thread), element); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d thread with one element %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = create_thread(); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d thread with children %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters/2;i++) { + thread = create_thread_ghostpads(); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d thread with children and ghostpads %ld\n", iters/2, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test1(); + } + g_print ("add/remove test1 %d in thread %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test2(); + } + g_print ("add/remove test2 %d in thread %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test3(); + } + g_print ("add/destroy/remove test3 %d in thread %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test4(); + } + g_print ("add/destroy/remove test4 %d in thread %ld\n", iters, vmsize()-usage1); + + g_print ("leaked: %ld\n", vmsize()-usage1); + + return (vmsize()-usage1 ? -1 : 0); +} diff --git a/testsuite/refcounting/thread.c b/testsuite/refcounting/thread.c new file mode 100644 index 0000000000..f229a54c60 --- /dev/null +++ b/testsuite/refcounting/thread.c @@ -0,0 +1,281 @@ +#include <gst/gst.h> + +#define ITERS 100000 +#include <stdlib.h> +#include "mem.h" + +static GstElement* +create_thread (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + gst_bin_add (GST_BIN (thread), element); + element = gst_element_new (); + gst_element_set_name (element, "test2"); + gst_bin_add (GST_BIN (thread), element); + + return thread; +} + +static GstElement* +create_thread_ghostpads (void) +{ + GstElement *thread; + GstElement *element1, *element2; + + thread = gst_thread_new ("testthread"); + element1 = gst_element_new (); + gst_element_set_name (element1, "test1"); + gst_element_add_pad (element1, gst_pad_new ("src1", GST_PAD_SRC)); + gst_bin_add (GST_BIN (thread), element1); + element2 = gst_element_new (); + gst_element_set_name (element2, "test2"); + gst_element_add_pad (element2, gst_pad_new ("sink1", GST_PAD_SINK)); + gst_bin_add (GST_BIN (thread), element2); + gst_element_connect (element1, "src1", element2, "sink1"); + gst_element_add_ghost_pad (thread, gst_element_get_pad (element2, "sink1"), "sink1"); + + return thread; +} + +static void +add_remove_test1 (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + gst_bin_remove (GST_BIN (thread), element); + + gst_object_unref (GST_OBJECT (thread)); +} + +static void +add_remove_test2 (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + gst_object_ref (GST_OBJECT (element)); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + gst_bin_remove (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + g_assert (!GST_OBJECT_DESTROYED (element)); + + gst_object_destroy (GST_OBJECT (element)); + g_assert (GST_OBJECT_DESTROYED (element)); + gst_object_unref (GST_OBJECT (element)); + + gst_object_unref (GST_OBJECT (thread)); +} + +static void +add_remove_test3 (void) +{ + GstElement *thread; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + + gst_object_destroy (GST_OBJECT (element)); + g_assert (gst_bin_get_by_name (GST_BIN (thread), "test1") == NULL); + + gst_object_unref (GST_OBJECT (thread)); +} + +static void +add_remove_test4 (void) +{ + GstElement *thread, *thread2; + GstElement *element; + + thread = gst_thread_new ("testthread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + g_assert (GST_OBJECT_FLOATING (element)); + gst_bin_add (GST_BIN (thread), element); + g_assert (!GST_OBJECT_FLOATING (element)); + + thread2 = create_thread (); + g_assert (GST_OBJECT_FLOATING (thread2)); + gst_bin_add (GST_BIN (thread), thread2); + g_assert (!GST_OBJECT_FLOATING (thread2)); + + gst_object_destroy (GST_OBJECT (thread2)); + g_assert (gst_bin_get_by_name (GST_BIN (thread), "testthread") == NULL); + gst_object_destroy (GST_OBJECT (element)); + g_assert (gst_bin_get_by_name (GST_BIN (thread), "test1") == NULL); + + gst_object_unref (GST_OBJECT (thread)); +} + +int +main (int argc, gchar *argv[]) +{ + GstElement *thread, *element; + long usage1; + gint i, iters; + + gst_init (&argc, &argv); + + if (argc == 2) + iters = atoi (argv[1]); + else + iters = ITERS; + + g_print ("starting test\n"); + usage1 = vmsize(); + + thread = gst_thread_new ("somethread"); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d threads %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + g_assert (GST_OBJECT_FLOATING (thread)); + gst_object_ref (GST_OBJECT (thread)); + gst_object_sink (GST_OBJECT (thread)); + g_assert (!GST_OBJECT_FLOATING (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/ref/sink/unref new thread %ld\n", vmsize()-usage1); + + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_sink (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/ref/sink/unref %d threads %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + g_assert (!GST_OBJECT_DESTROYED (thread)); + gst_object_destroy (GST_OBJECT (thread)); + g_assert (GST_OBJECT_DESTROYED (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/destroy/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_destroy (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/destroy/unref %d thread %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("create/ref/unref/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/ref/unref/unref %d thread %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_destroy (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + g_print ("craete/ref/destroy/unref/unref new thread %ld\n", vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_object_destroy (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("craete/ref/destroy/unref/unref %d threads %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + gst_object_ref (GST_OBJECT (thread)); + gst_element_set_name (thread, "testing123"); + gst_object_destroy (GST_OBJECT (thread)); + gst_element_set_name (thread, "testing123"); + gst_object_unref (GST_OBJECT (thread)); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("craete/ref/destroy/unref/unref %d threads with name %ld\n", iters, vmsize()-usage1); + + thread = gst_thread_new ("somethread"); + for (i=0; i<iters;i++) { + gst_element_set_name (thread, "testing"); + } + gst_object_unref (GST_OBJECT (thread)); + g_print ("set name %d times %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = gst_thread_new ("somethread"); + element = gst_element_new (); + gst_element_set_name (element, "test1"); + gst_bin_add (GST_BIN (thread), element); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d thread with one element %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + thread = create_thread(); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d thread with children %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters/2;i++) { + thread = create_thread_ghostpads(); + gst_object_unref (GST_OBJECT (thread)); + } + g_print ("create/unref %d thread with children and ghostpads %ld\n", iters/2, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test1(); + } + g_print ("add/remove test1 %d in thread %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test2(); + } + g_print ("add/remove test2 %d in thread %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test3(); + } + g_print ("add/destroy/remove test3 %d in thread %ld\n", iters, vmsize()-usage1); + + for (i=0; i<iters;i++) { + add_remove_test4(); + } + g_print ("add/destroy/remove test4 %d in thread %ld\n", iters, vmsize()-usage1); + + g_print ("leaked: %ld\n", vmsize()-usage1); + + return (vmsize()-usage1 ? -1 : 0); +} |