summaryrefslogtreecommitdiff
path: root/gthread.c
diff options
context:
space:
mode:
authorSebastian Wilhelmi <wilhelmi@ira.uka.de>2000-09-01 13:03:23 +0000
committerSebastian Wilhelmi <wilhelmi@src.gnome.org>2000-09-01 13:03:23 +0000
commit64bbfbb6dae9a6f9f5b839b85beb42c3d7f2a790 (patch)
treea15ffff00cbecb08378efd5d4ecca39a00abbd74 /gthread.c
parent21a498b1a54aa59bd0a3c4e6985307ec326683d2 (diff)
Include gerror.h before it is used for some g_thread_* functions.
2000-09-01 Sebastian Wilhelmi <wilhelmi@ira.uka.de> * glib.h: Include gerror.h before it is used for some g_thread_* functions. * gthread.c, gthreadpool.c, glib.h: Enable error reporting for thread creation, namly for g_thread_create, g_thread_pool_new, g_thread_pool_push and g_thread_pool_set_max_threads. * tests/thread-test.c, tests/threadpool-test.c: Adapted accordingly. * gthread-posix.c (g_thread_create_posix_impl): Use GError to report errors.
Diffstat (limited to 'gthread.c')
-rw-r--r--gthread.c36
1 files changed, 30 insertions, 6 deletions
diff --git a/gthread.c b/gthread.c
index f644f7044..654138f6f 100644
--- a/gthread.c
+++ b/gthread.c
@@ -51,6 +51,21 @@
(memcpy (&dest, &src, GLIB_SIZEOF_SYSTEM_THREAD))
#endif /* GLIB_SIZEOF_SYSTEM_THREAD == SIZEOF_VOID_P */
+GQuark
+g_thread_error_quark()
+{
+ static GQuark quark;
+ G_LOCK_DEFINE_STATIC(lock);
+ if (!quark)
+ {
+ G_LOCK (lock);
+ if (!quark)
+ quark = g_quark_from_static_string ("g-thread-error");
+ G_UNLOCK (lock);
+ }
+ return quark;
+}
+
typedef struct _GRealThread GRealThread;
struct _GRealThread
{
@@ -97,7 +112,7 @@ GThreadFunctions g_thread_functions_for_glib_use = {
NULL, /* private_set */
(void(*)(GThreadFunc, gpointer, gulong,
gboolean, gboolean, GThreadPriority,
- gpointer))g_thread_fail, /* thread_create */
+ gpointer, GError**))g_thread_fail, /* thread_create */
NULL, /* thread_yield */
NULL, /* thread_join */
NULL, /* thread_exit */
@@ -381,10 +396,11 @@ g_thread_create (GThreadFunc thread_func,
gulong stack_size,
gboolean joinable,
gboolean bound,
- GThreadPriority priority)
+ GThreadPriority priority,
+ GError **error)
{
GRealThread* result = g_new (GRealThread, 1);
-
+ GError *local_error = NULL;
g_return_val_if_fail (thread_func, NULL);
result->thread.joinable = joinable;
@@ -394,10 +410,18 @@ g_thread_create (GThreadFunc thread_func,
result->arg = arg;
result->private_data = NULL;
G_LOCK (g_thread_create);
- G_THREAD_UF (thread_create, (g_thread_create_proxy, result, stack_size,
- joinable, bound, priority,
- &result->system_thread));
+ G_THREAD_UF (thread_create, (g_thread_create_proxy, result,
+ stack_size, joinable, bound, priority,
+ &result->system_thread, &local_error));
G_UNLOCK (g_thread_create);
+
+ if (local_error)
+ {
+ g_propagate_error (error, local_error);
+ g_free (result);
+ return NULL;
+ }
+
return (GThread*) result;
}