summaryrefslogtreecommitdiff
path: root/src/3rd_party/dbus-1.7.8/test/internals/refs.c
diff options
context:
space:
mode:
authorJackLivio <jack@livio.io>2018-01-21 12:04:31 -0500
committerJackLivio <jack@livio.io>2018-01-21 12:04:31 -0500
commit08fcc026eafab3d8058d16b353be0995258d82dc (patch)
treea66516a47140df9f3d4a658a06315d2f790540a4 /src/3rd_party/dbus-1.7.8/test/internals/refs.c
parentad04121909b2de7d625acd8ec4aff390b39196aa (diff)
downloadsdl_core-08fcc026eafab3d8058d16b353be0995258d82dc.tar.gz
Remove Dbus and Iap libraries
Fix compilation error for build dbus and removes the dbus library from the core project. Dbus is still supported but now Core will not install it on the users system.
Diffstat (limited to 'src/3rd_party/dbus-1.7.8/test/internals/refs.c')
-rw-r--r--src/3rd_party/dbus-1.7.8/test/internals/refs.c607
1 files changed, 0 insertions, 607 deletions
diff --git a/src/3rd_party/dbus-1.7.8/test/internals/refs.c b/src/3rd_party/dbus-1.7.8/test/internals/refs.c
deleted file mode 100644
index 202dc04320..0000000000
--- a/src/3rd_party/dbus-1.7.8/test/internals/refs.c
+++ /dev/null
@@ -1,607 +0,0 @@
-/* Regression test for thread-safe reference-counting
- *
- * Author: Simon McVittie <simon.mcvittie@collabora.co.uk>
- * Copyright © 2011 Nokia Corporation
- *
- * Permission is hereby granted, free of charge, to any person
- * obtaining a copy of this software and associated documentation files
- * (the "Software"), to deal in the Software without restriction,
- * including without limitation the rights to use, copy, modify, merge,
- * publish, distribute, sublicense, and/or sell copies of the Software,
- * and to permit persons to whom the Software is furnished to do so,
- * subject to the following conditions:
- *
- * The above copyright notice and this permission notice shall be
- * included in all copies or substantial portions of the Software.
- *
- * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
- * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
- * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
- * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
- * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
- * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
- * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
- * SOFTWARE.
- */
-
-#include <config.h>
-
-#include <glib.h>
-#include <glib-object.h>
-
-#include <dbus/dbus.h>
-#include <dbus/dbus-connection-internal.h>
-#include <dbus/dbus-mainloop.h>
-#include <dbus/dbus-message-internal.h>
-#include <dbus/dbus-pending-call-internal.h>
-#include <dbus/dbus-server-protected.h>
-#include "test-utils.h"
-
-static void
-assert_no_error (const DBusError *e)
-{
- if (G_UNLIKELY (dbus_error_is_set (e)))
- g_error ("expected success but got error: %s: %s", e->name, e->message);
-}
-
-#define N_THREADS 200
-#define N_REFS 10000
-G_STATIC_ASSERT (((unsigned) N_THREADS * (unsigned) N_REFS) < G_MAXINT32);
-
-static dbus_int32_t connection_slot = -1;
-static dbus_int32_t server_slot = -1;
-static dbus_int32_t message_slot = -1;
-static dbus_int32_t pending_call_slot = -1;
-
-typedef struct {
- DBusError e;
- DBusLoop *loop;
- DBusServer *server;
- DBusConnection *connection;
- DBusConnection *server_connection;
- DBusMessage *message;
- GThread *threads[N_THREADS];
- gboolean last_unref;
-} Fixture;
-
-typedef void *(*RefFunc) (void *);
-typedef void (*VoidFunc) (void *);
-
-typedef struct {
- void *thing;
- RefFunc ref;
- VoidFunc ref_void;
- VoidFunc unref;
- void *mutex;
- VoidFunc lock;
- VoidFunc unlock;
-} Thread;
-
-/* provide backwards compatibility shim when building with a glib <= 2.30.x */
-#if !GLIB_CHECK_VERSION(2,31,0)
-#define g_thread_new(name,func,data) g_thread_create(func,data,TRUE,NULL)
-#endif
-
-static gpointer
-ref_thread (gpointer data)
-{
- Thread *thread = data;
- int i;
-
- for (i = 0; i < N_REFS; i++)
- {
- if (thread->lock != NULL)
- (thread->lock) (thread->mutex);
-
- if (thread->ref != NULL)
- {
- gpointer ret = (thread->ref) (thread->thing);
-
- g_assert (ret == thread->thing);
- }
- else
- {
- (thread->ref_void) (thread->thing);
- }
-
- if (thread->unlock != NULL)
- (thread->unlock) (thread->mutex);
- }
-
- return NULL;
-}
-
-static gpointer
-cycle_thread (gpointer data)
-{
- Thread *thread = data;
- int i;
-
- for (i = 0; i < N_REFS; i++)
- {
- if (thread->lock != NULL)
- (thread->lock) (thread->mutex);
-
- if (thread->ref != NULL)
- {
- gpointer ret = (thread->ref) (thread->thing);
-
- g_assert (ret == thread->thing);
- }
- else
- {
- (thread->ref_void) (thread->thing);
- }
-
- (thread->unref) (thread->thing);
-
- if (thread->unlock != NULL)
- (thread->unlock) (thread->mutex);
- }
-
- return NULL;
-}
-
-static gpointer
-unref_thread (gpointer data)
-{
- Thread *thread = data;
- int i;
-
- for (i = 0; i < N_REFS; i++)
- {
- if (thread->lock != NULL)
- (thread->lock) (thread->mutex);
-
- (thread->unref) (thread->thing);
-
- if (thread->unlock != NULL)
- (thread->unlock) (thread->mutex);
- }
-
- return NULL;
-}
-
-static void
-last_unref (void *data)
-{
- Fixture *f = data;
-
- g_assert (!f->last_unref);
- f->last_unref = TRUE;
-}
-
-static void
-wait_for_all_threads (Fixture *f)
-{
- int i;
-
- for (i = 0; i < N_THREADS; i++)
- g_thread_join (f->threads[i]);
-}
-
-static void
-new_conn_cb (DBusServer *server,
- DBusConnection *server_connection,
- void *data)
-{
- Fixture *f = data;
-
- g_assert (f->server_connection == NULL);
- f->server_connection = dbus_connection_ref (server_connection);
-
- test_connection_setup (f->loop, f->server_connection);
-}
-
-static void
-setup (Fixture *f,
- gconstpointer data)
-{
- if (!dbus_threads_init_default ())
- g_error ("OOM");
-
- f->loop = _dbus_loop_new ();
- g_assert (f->loop != NULL);
-
- dbus_error_init (&f->e);
-
- f->server = dbus_server_listen ("tcp:host=127.0.0.1", &f->e);
- assert_no_error (&f->e);
- g_assert (f->server != NULL);
-
- if (!dbus_connection_allocate_data_slot (&connection_slot))
- g_error ("OOM");
-
- if (!dbus_server_allocate_data_slot (&server_slot))
- g_error ("OOM");
-
- if (!dbus_message_allocate_data_slot (&message_slot))
- g_error ("OOM");
-
- if (!dbus_pending_call_allocate_data_slot (&pending_call_slot))
- g_error ("OOM");
-}
-
-static void
-setup_connection (Fixture *f,
- gconstpointer data)
-{
- char *address;
-
- setup (f, data);
-
- dbus_server_set_new_connection_function (f->server,
- new_conn_cb, f, NULL);
-
- if (!test_server_setup (f->loop, f->server))
- g_error ("failed to set up server");
-
- address = dbus_server_get_address (f->server);
- g_assert (address != NULL);
- f->connection = dbus_connection_open_private (address, &f->e);
- assert_no_error (&f->e);
- g_assert (f->connection != NULL);
- dbus_free (address);
-
- if (!test_connection_setup (f->loop, f->connection))
- g_error ("failed to set up connection");
-
- while (f->server_connection == NULL)
- _dbus_loop_iterate (f->loop, TRUE);
-
- test_connection_shutdown (f->loop, f->connection);
- test_server_shutdown (f->loop, f->server);
-}
-
-static void
-test_connection (Fixture *f,
- gconstpointer data)
-{
- Thread public_api = { f->connection,
- (RefFunc) dbus_connection_ref,
- NULL,
- (VoidFunc) dbus_connection_unref,
- NULL,
- NULL,
- NULL };
- Thread internal_api = { f->connection,
- (RefFunc) _dbus_connection_ref_unlocked,
- NULL,
- (VoidFunc) _dbus_connection_unref_unlocked,
- f->connection,
- (VoidFunc) _dbus_connection_lock,
- (VoidFunc) _dbus_connection_unlock };
- int i;
-
- /* Use a slot as a pseudo-weakref */
- if (!dbus_connection_set_data (f->connection, connection_slot, f,
- last_unref))
- g_error ("OOM");
-
- for (i = 0; i < N_THREADS; i++)
- {
- if ((i % 2) == 0)
- f->threads[i] = g_thread_new (NULL, ref_thread, &public_api);
- else
- f->threads[i] = g_thread_new (NULL, ref_thread, &internal_api);
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- if ((i % 2) == 0)
- f->threads[i] = g_thread_new (NULL, cycle_thread, &public_api);
- else
- f->threads[i] = g_thread_new (NULL, cycle_thread, &internal_api);
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- if ((i % 2) == 0)
- f->threads[i] = g_thread_new (NULL, unref_thread, &public_api);
- else
- f->threads[i] = g_thread_new (NULL, unref_thread, &internal_api);
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- /* Destroy the connection. This should be the last-unref. */
- g_assert (!f->last_unref);
- dbus_connection_close (f->connection);
- dbus_connection_unref (f->connection);
- f->connection = NULL;
- g_assert (f->last_unref);
-}
-
-static void
-server_lock (void *server)
-{
- SERVER_LOCK (((DBusServer *) server));
-}
-
-static void
-server_unlock (void *server)
-{
- SERVER_UNLOCK (((DBusServer *) server));
-}
-
-static void
-test_server (Fixture *f,
- gconstpointer data)
-{
- Thread public_api = { f->server,
- (RefFunc) dbus_server_ref,
- NULL,
- (VoidFunc) dbus_server_unref,
- NULL,
- NULL,
- NULL };
- Thread internal_api = { f->server,
- NULL,
- (VoidFunc) _dbus_server_ref_unlocked,
- (VoidFunc) _dbus_server_unref_unlocked,
- f->server,
- server_lock,
- server_unlock };
- int i;
-
- if (!dbus_server_set_data (f->server, server_slot, f, last_unref))
- g_error ("OOM");
-
- for (i = 0; i < N_THREADS; i++)
- {
- if ((i % 2) == 0)
- f->threads[i] = g_thread_new (NULL, ref_thread, &public_api);
- else
- f->threads[i] = g_thread_new (NULL, ref_thread, &internal_api);
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- if ((i % 2) == 0)
- f->threads[i] = g_thread_new (NULL, cycle_thread, &public_api);
- else
- f->threads[i] = g_thread_new (NULL, cycle_thread, &internal_api);
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- if ((i % 2) == 0)
- f->threads[i] = g_thread_new (NULL, unref_thread, &public_api);
- else
- f->threads[i] = g_thread_new (NULL, unref_thread, &internal_api);
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- /* Destroy the server. This should be the last-unref. */
- g_assert (!f->last_unref);
- dbus_server_disconnect (f->server);
- dbus_server_unref (f->server);
- f->server = NULL;
- g_assert (f->last_unref);
-}
-
-static void
-test_message (Fixture *f,
- gconstpointer data)
-{
- DBusMessage *message = dbus_message_new_signal ("/foo", "foo.bar.baz",
- "Foo");
- Thread public_api = { message,
- (RefFunc) dbus_message_ref,
- NULL,
- (VoidFunc) dbus_message_unref,
- NULL,
- NULL,
- NULL };
- int i;
-
- if (!dbus_message_set_data (message, message_slot, f, last_unref))
- g_error ("OOM");
-
- for (i = 0; i < N_THREADS; i++)
- {
- f->threads[i] = g_thread_new (NULL, ref_thread, &public_api);
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- f->threads[i] = g_thread_new (NULL, cycle_thread, &public_api);
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- f->threads[i] = g_thread_new (NULL, unref_thread, &public_api);
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- /* Destroy the server. This should be the last-unref. */
- g_assert (!f->last_unref);
- dbus_message_unref (message);
- g_assert (f->last_unref);
-}
-
-static void
-test_pending_call (Fixture *f,
- gconstpointer data)
-{
- Thread public_api = { NULL,
- (RefFunc) dbus_pending_call_ref,
- NULL,
- (VoidFunc) dbus_pending_call_unref,
- NULL,
- NULL,
- NULL };
- Thread internal_api = { NULL,
- (RefFunc) _dbus_pending_call_ref_unlocked,
- NULL,
- (VoidFunc) dbus_pending_call_unref,
- f->connection,
- (VoidFunc) _dbus_connection_lock,
- (VoidFunc) _dbus_connection_unlock };
- /* This one can't be used to ref, only to cycle or unref. */
- Thread unref_and_unlock_api = { NULL,
- (RefFunc) _dbus_pending_call_ref_unlocked,
- NULL,
- (VoidFunc) _dbus_pending_call_unref_and_unlock,
- f->connection,
- (VoidFunc) _dbus_connection_lock,
- NULL };
- int i;
- DBusPendingCall *pending_call;
-
- _dbus_connection_lock (f->connection);
- pending_call = _dbus_pending_call_new_unlocked (f->connection,
- DBUS_TIMEOUT_INFINITE, NULL);
- g_assert (pending_call != NULL);
- _dbus_connection_unlock (f->connection);
-
- public_api.thing = pending_call;
- internal_api.thing = pending_call;
- unref_and_unlock_api.thing = pending_call;
-
- if (!dbus_pending_call_set_data (pending_call, pending_call_slot, f,
- last_unref))
- g_error ("OOM");
-
- for (i = 0; i < N_THREADS; i++)
- {
- if ((i % 2) == 0)
- f->threads[i] = g_thread_new (NULL, ref_thread, &public_api);
- else
- f->threads[i] = g_thread_new (NULL, ref_thread, &internal_api);
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- switch (i % 3)
- {
- case 0:
- f->threads[i] = g_thread_new (NULL, cycle_thread, &public_api);
- break;
- case 1:
- f->threads[i] = g_thread_new (NULL, cycle_thread, &internal_api);
- break;
- default:
- f->threads[i] = g_thread_new (NULL, cycle_thread,
- &unref_and_unlock_api);
- }
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- for (i = 0; i < N_THREADS; i++)
- {
- switch (i % 3)
- {
- case 0:
- f->threads[i] = g_thread_new (NULL, unref_thread, &public_api);
- break;
- case 1:
- f->threads[i] = g_thread_new (NULL, unref_thread, &internal_api);
- break;
- default:
- f->threads[i] = g_thread_new (NULL, unref_thread,
- &unref_and_unlock_api);
- }
-
- g_assert (f->threads[i] != NULL);
- }
-
- wait_for_all_threads (f);
-
- /* Destroy the pending call. This should be the last-unref. */
- g_assert (!f->last_unref);
- dbus_pending_call_unref (pending_call);
- g_assert (f->last_unref);
-}
-
-static void
-teardown (Fixture *f,
- gconstpointer data)
-{
- if (f->server_connection != NULL)
- {
- dbus_connection_close (f->server_connection);
- dbus_connection_unref (f->server_connection);
- }
-
- if (f->connection != NULL)
- {
- dbus_connection_close (f->connection);
- dbus_connection_unref (f->connection);
- }
-
- if (f->server != NULL)
- {
- dbus_server_disconnect (f->server);
- dbus_server_unref (f->server);
- }
-
- dbus_connection_free_data_slot (&connection_slot);
- dbus_server_free_data_slot (&server_slot);
- dbus_message_free_data_slot (&message_slot);
- dbus_pending_call_free_data_slot (&pending_call_slot);
-
- _dbus_loop_unref (f->loop);
- dbus_error_free (&f->e);
-}
-
-int
-main (int argc,
- char **argv)
-{
- /* In GLib >= 2.24, < 2.31 this acts like g_thread_init() but avoids
- * the deprecation of that function. In GLib >= 2.32 this is not
- * necessary at all.
- */
- g_type_init ();
-
- g_test_init (&argc, &argv, NULL);
- g_test_bug_base ("https://bugs.freedesktop.org/show_bug.cgi?id=");
-
- g_test_add ("/refs/connection", Fixture, NULL, setup_connection,
- test_connection, teardown);
- g_test_add ("/refs/message", Fixture, NULL, setup,
- test_message, teardown);
- g_test_add ("/refs/pending-call", Fixture, NULL, setup_connection,
- test_pending_call, teardown);
- g_test_add ("/refs/server", Fixture, NULL, setup,
- test_server, teardown);
-
- return g_test_run ();
-}