* Makefile (MCS) [PROFILE=default]: Force testing of 'mcs'.

[mono.git] / mono / io-layer / timed-thread.h

diff --git a/mono/io-layer/timed-thread.h b/mono/io-layer/timed-thread.h
index bb5908058c24cd613dc4c53c4745f589b78873c6..a656f8b8221cd5370f81d8667b160e3857ab1a00 100644 (file)
--- a/mono/io-layer/timed-thread.h
+++ b/mono/io-layer/timed-thread.h
@@ -1,31 +1,86 @@
+/*
+ * timed-thread.h:  Implementation of timed thread joining
+ *
+ * Author:
+ *     Dick Porter (dick@ximian.com)
+ *
+ * (C) 2002 Ximian, Inc.
+ */
+
 #ifndef _WAPI_TIMED_THREAD_H_
 #define _WAPI_TIMED_THREAD_H_
 
 #include <config.h>
 #include <glib.h>
 #include <pthread.h>
+#ifdef HAVE_SEMAPHORE_H
+#include <semaphore.h>
+#endif
+#ifdef USE_MACH_SEMA
+#include <mach/mach_init.h>
+#include <mach/task.h>
+#include <mach/semaphore.h>
+typedef semaphore_t MonoSemType;
+#define MONO_SEM_INIT(addr,value) semaphore_create(current_task(), (addr), SYNC_POLICY_FIFO, (value))
+#define MONO_SEM_WAIT(sem) semaphore_wait(*(sem))
+#define MONO_SEM_POST(sem) semaphore_signal(*(sem))
+#define MONO_SEM_DESTROY(sem) semaphore_destroy(current_task(), *(sem))
+#else
+typedef sem_t MonoSemType;
+#define MONO_SEM_INIT(addr,value) sem_init ((addr), 0, (value))
+#define MONO_SEM_WAIT(sem) sem_wait((sem))
+#define MONO_SEM_POST(sem) sem_post((sem))
+#define MONO_SEM_DESTROY(sem) sem_destroy((sem))
+#endif
+
+#include "mono-mutex.h"
 
 typedef struct
 {
        pthread_t id;
-       pthread_mutex_t join_mutex;
+       mono_mutex_t join_mutex;
        pthread_cond_t exit_cond;
+       guint32 create_flags;
+       int suspend_count;
+       MonoSemType suspend_sem;
+       MonoSemType suspended_sem;
        guint32 (*start_routine)(gpointer arg);
        void (*exit_routine)(guint32 exitstatus, gpointer userdata);
        gpointer arg;
        gpointer exit_userdata;
        guint32 exitstatus;
        gboolean exiting;
+       gpointer stack_ptr;
+       GSList *apc_queue;
 } TimedThread;
 
+typedef struct
+{
+       guint32 (*callback)(gpointer arg);
+       gpointer param;
+} ApcInfo;
+
 extern void _wapi_timed_thread_exit(guint32 exitstatus) G_GNUC_NORETURN;
 extern int _wapi_timed_thread_create(TimedThread **threadp,
                                     const pthread_attr_t *attr,
+                                    guint32 create_flags,
                                     guint32 (*start_routine)(gpointer),
                                     void (*exit_routine)(guint32, gpointer),
                                     gpointer arg, gpointer exit_userdata);
+extern int _wapi_timed_thread_attach(TimedThread **threadp,
+                                    void (*exit_routine)(guint32, gpointer),
+                                    gpointer exit_userdata);
 extern int _wapi_timed_thread_join(TimedThread *thread,
                                   struct timespec *timeout,
                                   guint32 *exitstatus);
+extern void _wapi_timed_thread_destroy (TimedThread *thread);
+extern void _wapi_timed_thread_suspend (TimedThread *thread);
+extern void _wapi_timed_thread_resume (TimedThread *thread);
+                                  
+extern void _wapi_timed_thread_queue_apc (TimedThread *thread, 
+                                       guint32 (*apc_callback)(gpointer), gpointer param);
+extern gboolean _wapi_timed_thread_apc_pending (TimedThread *thread);
+extern void _wapi_timed_thread_dispatch_apc_queue (TimedThread *thread);
+                  
 
 #endif /* _WAPI_TIMED_THREAD_H_ */