[mono-threads] Use create_suspended_sem on windows (#3482)
[mono.git] / mono / utils / mono-threads.h
1 /*
2  * mono-threads.h: Low-level threading
3  *
4  * Author:
5  *      Rodrigo Kumpera (kumpera@gmail.com)
6  *
7  * (C) 2011 Novell, Inc
8  */
9
10 #ifndef __MONO_THREADS_H__
11 #define __MONO_THREADS_H__
12
13 #include <mono/utils/mono-os-semaphore.h>
14 #include <mono/utils/mono-stack-unwinding.h>
15 #include <mono/utils/mono-linked-list-set.h>
16 #include <mono/utils/mono-tls.h>
17 #include <mono/utils/mono-coop-semaphore.h>
18
19 #include <mono/io-layer/io-layer.h>
20
21 #include <glib.h>
22 #include <config.h>
23 #ifdef HOST_WIN32
24
25 #include <windows.h>
26
27 typedef DWORD MonoNativeThreadId;
28 typedef HANDLE MonoNativeThreadHandle; /* unused */
29
30 typedef DWORD mono_native_thread_return_t;
31
32 #define MONO_NATIVE_THREAD_ID_TO_UINT(tid) (tid)
33 #define MONO_UINT_TO_NATIVE_THREAD_ID(tid) ((MonoNativeThreadId)(tid))
34
35 typedef LPTHREAD_START_ROUTINE MonoThreadStart;
36
37 #else
38
39 #include <pthread.h>
40
41 #if defined(__MACH__)
42 #include <mono/utils/mach-support.h>
43
44 typedef thread_port_t MonoNativeThreadHandle;
45
46 #else
47
48 #include <unistd.h>
49
50 typedef pid_t MonoNativeThreadHandle;
51
52 #endif /* defined(__MACH__) */
53
54 typedef pthread_t MonoNativeThreadId;
55
56 typedef void* mono_native_thread_return_t;
57
58 #define MONO_NATIVE_THREAD_ID_TO_UINT(tid) (gsize)(tid)
59 #define MONO_UINT_TO_NATIVE_THREAD_ID(tid) (MonoNativeThreadId)(gsize)(tid)
60
61 typedef gsize (*MonoThreadStart)(gpointer);
62
63 #endif /* #ifdef HOST_WIN32 */
64
65 /*
66 THREAD_INFO_TYPE is a way to make the mono-threads module parametric - or sort of.
67 The GC using mono-threads might extend the MonoThreadInfo struct to add its own
68 data, this avoid a pointer indirection on what is on a lot of hot paths.
69
70 But extending MonoThreadInfo has de disavantage that all functions here return type
71 would require a cast, something like the following:
72
73 typedef struct {
74         MonoThreadInfo info;
75         int stuff;
76 }  MyThreadInfo;
77
78 ...
79 ((MyThreadInfo*)mono_thread_info_current ())->stuff = 1;
80
81 While porting sgen to use mono-threads, the number of casts required was too much and
82 code ended up looking horrible. So we use this cute little hack. The idea is that
83 whomever is including this header can set the expected type to be used by functions here
84 and reduce the number of casts drastically.
85
86 */
87 #ifndef THREAD_INFO_TYPE
88 #define THREAD_INFO_TYPE MonoThreadInfo
89 #endif
90
91 /* Mono Threads internal configuration knows*/
92
93 /* Logging - enable them below if you need specific logging for the category you need */
94 #define MOSTLY_ASYNC_SAFE_PRINTF(...) do { \
95         char __buff[1024];      __buff [0] = '\0'; \
96         g_snprintf (__buff, sizeof (__buff), __VA_ARGS__);      \
97         write (1, __buff, strlen (__buff));     \
98 } while (0)
99
100
101 #if 1
102 #define THREADS_DEBUG(...)
103 #else
104 #define THREADS_DEBUG MOSTLY_ASYNC_SAFE_PRINTF
105 #endif
106
107 #if 1
108 #define THREADS_STW_DEBUG(...)
109 #else
110 #define THREADS_STW_DEBUG MOSTLY_ASYNC_SAFE_PRINTF
111 #endif
112
113 #if 1
114 #define THREADS_SUSPEND_DEBUG(...)
115 #else
116 #define THREADS_SUSPEND_DEBUG MOSTLY_ASYNC_SAFE_PRINTF
117 #endif
118
119 #if 1
120 #define THREADS_STATE_MACHINE_DEBUG(...)
121 #else
122 #define THREADS_STATE_MACHINE_DEBUG MOSTLY_ASYNC_SAFE_PRINTF
123 #endif
124
125 #if 1
126 #define THREADS_INTERRUPT_DEBUG(...)
127 #else
128 #define THREADS_INTERRUPT_DEBUG MOSTLY_ASYNC_SAFE_PRINTF
129 #endif
130
131 /* If this is defined, use the signals backed on Mach. Debug only as signals can't be made usable on OSX. */
132 // #define USE_SIGNALS_ON_MACH
133
134 #if defined (_POSIX_VERSION) || defined (__native_client__)
135 #if defined (__MACH__) && !defined (USE_SIGNALS_ON_MACH)
136 #define USE_MACH_BACKEND
137 #else
138 #define USE_POSIX_BACKEND
139 #endif
140 #elif HOST_WIN32
141 #define USE_WINDOWS_BACKEND
142 #else
143 #error "no backend support for current platform"
144 #endif /* defined (_POSIX_VERSION) || defined (__native_client__) */
145
146 enum {
147         STATE_STARTING                          = 0x00,
148         STATE_RUNNING                           = 0x01,
149         STATE_DETACHED                          = 0x02,
150
151         STATE_ASYNC_SUSPENDED                   = 0x03,
152         STATE_SELF_SUSPENDED                    = 0x04,
153         STATE_ASYNC_SUSPEND_REQUESTED   = 0x05,
154         STATE_SELF_SUSPEND_REQUESTED    = 0x06,
155         STATE_BLOCKING                                  = 0x07,
156         STATE_BLOCKING_AND_SUSPENDED    = 0x8,
157
158         STATE_MAX                                               = 0x08,
159
160         THREAD_STATE_MASK                       = 0x00FF,
161         THREAD_SUSPEND_COUNT_MASK       = 0xFF00,
162         THREAD_SUSPEND_COUNT_SHIFT      = 8,
163         THREAD_SUSPEND_COUNT_MAX        = 0xFF,
164
165         SELF_SUSPEND_STATE_INDEX = 0,
166         ASYNC_SUSPEND_STATE_INDEX = 1,
167 };
168
169 typedef struct _MonoThreadInfoInterruptToken MonoThreadInfoInterruptToken;
170
171 typedef struct {
172         MonoLinkedListSetNode node;
173         guint32 small_id; /*Used by hazard pointers */
174         MonoNativeThreadHandle native_handle; /* Valid on mach and android */
175         int thread_state;
176
177         /*Tells if this thread was created by the runtime or not.*/
178         gboolean runtime_thread;
179
180         /* Tells if this thread should be ignored or not by runtime services such as GC and profiling */
181         gboolean tools_thread;
182
183         /* Max stack bounds, all valid addresses must be between [stack_start_limit, stack_end[ */
184         void *stack_start_limit, *stack_end;
185
186         /* suspend machinery, fields protected by suspend_semaphore */
187         MonoSemType suspend_semaphore;
188         int suspend_count;
189
190         MonoSemType resume_semaphore;
191
192         /* only needed by the posix backend */
193 #if defined(USE_POSIX_BACKEND)
194         MonoSemType finish_resume_semaphore;
195         gboolean syscall_break_signal;
196         int signal;
197 #endif
198
199         gboolean suspend_can_continue;
200
201         /* This memory pool is used by coop GC to save stack data roots between GC unsafe regions */
202         GByteArray *stackdata;
203
204         /*In theory, only the posix backend needs this, but having it on mach/win32 simplifies things a lot.*/
205         MonoThreadUnwindState thread_saved_state [2]; //0 is self suspend, 1 is async suspend.
206
207         /*async call machinery, thread MUST be suspended before accessing those fields*/
208         void (*async_target)(void*);
209         void *user_data;
210
211         /*
212         If true, this thread is running a critical region of code and cannot be suspended.
213         A critical session is implicitly started when you call mono_thread_info_safe_suspend_sync
214         and is ended when you call either mono_thread_info_resume or mono_thread_info_finish_suspend.
215         */
216         gboolean inside_critical_region;
217
218         /*
219          * If TRUE, the thread is in async context. Code can use this information to avoid async-unsafe
220          * operations like locking without having to pass an 'async' parameter around.
221          */
222         gboolean is_async_context;
223
224         gboolean create_suspended;
225
226         /* Semaphore used to implement CREATE_SUSPENDED */
227         MonoCoopSem create_suspended_sem;
228
229         /*
230          * Values of TLS variables for this thread.
231          * This can be used to obtain the values of TLS variable for threads
232          * other than the current one.
233          */
234         gpointer tls [TLS_KEY_NUM];
235
236         /* IO layer handle for this thread */
237         /* Set when the thread is started, or in _wapi_thread_duplicate () */
238         HANDLE handle;
239
240         void *jit_data;
241
242         MonoThreadInfoInterruptToken *interrupt_token;
243
244         /* HandleStack for coop handles */
245         gpointer handle_stack;
246
247         /* Stack mark for targets that explicitly require one */
248         gpointer stack_mark;
249 } MonoThreadInfo;
250
251 typedef struct {
252         void* (*thread_register)(THREAD_INFO_TYPE *info, void *baseaddr);
253         /*
254         This callback is called with @info still on the thread list.
255         This call is made while holding the suspend lock, so don't do callbacks.
256         SMR remains functional as its small_id has not been reclaimed.
257         */
258         void (*thread_unregister)(THREAD_INFO_TYPE *info);
259         /*
260         This callback is called right before thread_unregister. This is called
261         without any locks held so it's the place for complicated cleanup.
262
263         The thread must remain operational between this call and thread_unregister.
264         It must be possible to successfully suspend it after thread_unregister completes.
265         */
266         void (*thread_detach)(THREAD_INFO_TYPE *info);
267         void (*thread_attach)(THREAD_INFO_TYPE *info);
268         gboolean (*mono_method_is_critical) (void *method);
269         gboolean (*mono_thread_in_critical_region) (THREAD_INFO_TYPE *info);
270 } MonoThreadInfoCallbacks;
271
272 typedef struct {
273         void (*setup_async_callback) (MonoContext *ctx, void (*async_cb)(void *fun), gpointer user_data);
274         gboolean (*thread_state_init_from_sigctx) (MonoThreadUnwindState *state, void *sigctx);
275         gboolean (*thread_state_init_from_handle) (MonoThreadUnwindState *tctx, MonoThreadInfo *info);
276         void (*thread_state_init) (MonoThreadUnwindState *tctx);
277 } MonoThreadInfoRuntimeCallbacks;
278
279 //Not using 0 and 1 to ensure callbacks are not returning bad data
280 typedef enum {
281         MonoResumeThread = 0x1234,
282         KeepSuspended = 0x4321,
283 } SuspendThreadResult;
284
285 typedef SuspendThreadResult (*MonoSuspendThreadCallback) (THREAD_INFO_TYPE *info, gpointer user_data);
286
287 /*
288  * Parameters to pass for thread creation
289  */
290 typedef struct {
291         int priority;
292         guint32 creation_flags; 
293         guint32 stack_size;             
294 } MonoThreadParm;
295
296 typedef enum {
297         MONO_THREAD_PRIORITY_LOWEST       = 0,
298         MONO_THREAD_PRIORITY_BELOW_NORMAL = 1,
299         MONO_THREAD_PRIORITY_NORMAL       = 2,
300         MONO_THREAD_PRIORITY_ABOVE_NORMAL = 3,
301         MONO_THREAD_PRIORITY_HIGHEST      = 4,
302 } MonoThreadPriority;
303
304 static inline gboolean
305 mono_threads_filter_tools_threads (THREAD_INFO_TYPE *info)
306 {
307         return !((MonoThreadInfo*)info)->tools_thread;
308 }
309
310 /*
311 Requires the world to be stoped
312 */
313 #define FOREACH_THREAD(thread) \
314         MONO_LLS_FOREACH_FILTERED (mono_thread_info_list_head (), THREAD_INFO_TYPE, thread, mono_threads_filter_tools_threads)
315
316 #define FOREACH_THREAD_END \
317         MONO_LLS_FOREACH_END
318
319 /*
320 Snapshot iteration.
321 */
322 #define FOREACH_THREAD_SAFE(thread) \
323         MONO_LLS_FOREACH_FILTERED_SAFE (mono_thread_info_list_head (), THREAD_INFO_TYPE, thread, mono_threads_filter_tools_threads)
324
325 #define FOREACH_THREAD_SAFE_END \
326         MONO_LLS_FOREACH_SAFE_END
327
328 static inline MonoNativeThreadId
329 mono_thread_info_get_tid (THREAD_INFO_TYPE *info)
330 {
331         return MONO_UINT_TO_NATIVE_THREAD_ID (((MonoThreadInfo*) info)->node.key);
332 }
333
334 static inline void
335 mono_thread_info_set_tid (THREAD_INFO_TYPE *info, MonoNativeThreadId tid)
336 {
337         ((MonoThreadInfo*) info)->node.key = (uintptr_t) MONO_NATIVE_THREAD_ID_TO_UINT (tid);
338 }
339
340 /*
341  * @thread_info_size is sizeof (GcThreadInfo), a struct the GC defines to make it possible to have
342  * a single block with info from both camps. 
343  */
344 void
345 mono_threads_init (MonoThreadInfoCallbacks *callbacks, size_t thread_info_size);
346
347 void
348 mono_threads_runtime_init (MonoThreadInfoRuntimeCallbacks *callbacks);
349
350 MonoThreadInfoRuntimeCallbacks *
351 mono_threads_get_runtime_callbacks (void);
352
353 int
354 mono_thread_info_register_small_id (void);
355
356 THREAD_INFO_TYPE *
357 mono_thread_info_attach (void *baseptr);
358
359 MONO_API void
360 mono_thread_info_detach (void);
361
362 gboolean
363 mono_thread_info_is_exiting (void);
364
365 THREAD_INFO_TYPE *
366 mono_thread_info_current (void);
367
368 THREAD_INFO_TYPE*
369 mono_thread_info_current_unchecked (void);
370
371 int
372 mono_thread_info_get_small_id (void);
373
374 MonoLinkedListSet*
375 mono_thread_info_list_head (void);
376
377 THREAD_INFO_TYPE*
378 mono_thread_info_lookup (MonoNativeThreadId id);
379
380 gboolean
381 mono_thread_info_resume (MonoNativeThreadId tid);
382
383 void
384 mono_thread_info_safe_suspend_and_run (MonoNativeThreadId id, gboolean interrupt_kernel, MonoSuspendThreadCallback callback, gpointer user_data);
385
386 //XXX new API, fix the world
387 void
388 mono_thread_info_begin_self_suspend (void);
389
390 void
391 mono_thread_info_end_self_suspend (void);
392
393 //END of new API
394
395 gboolean
396 mono_thread_info_unified_management_enabled (void);
397
398 void
399 mono_thread_info_setup_async_call (THREAD_INFO_TYPE *info, void (*target_func)(void*), void *user_data);
400
401 void
402 mono_thread_info_suspend_lock (void);
403
404 void
405 mono_thread_info_suspend_unlock (void);
406
407 void
408 mono_thread_info_abort_socket_syscall_for_close (MonoNativeThreadId tid);
409
410 void
411 mono_thread_info_set_is_async_context (gboolean async_context);
412
413 gboolean
414 mono_thread_info_is_async_context (void);
415
416 void
417 mono_thread_info_get_stack_bounds (guint8 **staddr, size_t *stsize);
418
419 gboolean
420 mono_thread_info_yield (void);
421
422 gint
423 mono_thread_info_sleep (guint32 ms, gboolean *alerted);
424
425 gint
426 mono_thread_info_usleep (guint64 us);
427
428 gpointer
429 mono_thread_info_tls_get (THREAD_INFO_TYPE *info, MonoTlsKey key);
430
431 void
432 mono_thread_info_tls_set (THREAD_INFO_TYPE *info, MonoTlsKey key, gpointer value);
433
434 void
435 mono_thread_info_exit (void);
436
437 void
438 mono_thread_info_set_exited (THREAD_INFO_TYPE *info);
439
440 void
441 mono_thread_info_install_interrupt (void (*callback) (gpointer data), gpointer data, gboolean *interrupted);
442
443 void
444 mono_thread_info_uninstall_interrupt (gboolean *interrupted);
445
446 MonoThreadInfoInterruptToken*
447 mono_thread_info_prepare_interrupt (THREAD_INFO_TYPE *info);
448
449 void
450 mono_thread_info_finish_interrupt (MonoThreadInfoInterruptToken *token);
451
452 void
453 mono_thread_info_self_interrupt (void);
454
455 void
456 mono_thread_info_clear_self_interrupt (void);
457
458 gboolean
459 mono_thread_info_is_interrupt_state (THREAD_INFO_TYPE *info);
460
461 void
462 mono_thread_info_describe_interrupt_token (THREAD_INFO_TYPE *info, GString *text);
463
464 gboolean
465 mono_thread_info_is_live (THREAD_INFO_TYPE *info);
466
467 HANDLE
468 mono_threads_create_thread (MonoThreadStart start, gpointer arg, MonoThreadParm *tp, MonoNativeThreadId *out_tid);
469
470 int
471 mono_threads_get_max_stack_size (void);
472
473 HANDLE
474 mono_threads_open_thread_handle (HANDLE handle, MonoNativeThreadId tid);
475
476 MONO_API void
477 mono_threads_attach_tools_thread (void);
478
479
480 #if !defined(HOST_WIN32)
481
482 /*Use this instead of pthread_kill */
483 int
484 mono_threads_pthread_kill (THREAD_INFO_TYPE *info, int signum);
485
486 #endif /* !defined(HOST_WIN32) */
487
488 /* Internal API between mono-threads and its backends. */
489
490 /* Backend functions - a backend must implement all of the following */
491 /*
492 This is called very early in the runtime, it cannot access any runtime facilities.
493
494 */
495 void mono_threads_suspend_init (void); //ok
496
497 void mono_threads_platform_init (void);
498
499 void mono_threads_coop_init (void);
500
501 void mono_threads_abort_syscall_init (void);
502
503 /*
504 This begins async suspend. This function must do the following:
505
506 -Ensure the target will EINTR any syscalls if @interrupt_kernel is true
507 -Call mono_threads_transition_finish_async_suspend as part of its async suspend.
508 -Register the thread for pending suspend with mono_threads_add_to_pending_operation_set if needed.
509
510 If begin suspend fails the thread must be left uninterrupted and resumed.
511 */
512 gboolean mono_threads_suspend_begin_async_suspend (THREAD_INFO_TYPE *info, gboolean interrupt_kernel);
513
514 /*
515 This verifies the outcome of an async suspend operation.
516
517 Some targets, such as posix, verify suspend results assynchronously. Suspend results must be
518 available (in a non blocking way) after mono_threads_wait_pending_operations completes.
519 */
520 gboolean mono_threads_suspend_check_suspend_result (THREAD_INFO_TYPE *info);
521
522 /*
523 This begins async resume. This function must do the following:
524
525 - Install an async target if one was requested.
526 - Notify the target to resume.
527 - Register the thread for pending ack with mono_threads_add_to_pending_operation_set if needed.
528 */
529 gboolean mono_threads_suspend_begin_async_resume (THREAD_INFO_TYPE *info);
530
531 void mono_threads_suspend_register (THREAD_INFO_TYPE *info); //ok
532 void mono_threads_suspend_free (THREAD_INFO_TYPE *info);
533 void mono_threads_suspend_abort_syscall (THREAD_INFO_TYPE *info);
534 gboolean mono_threads_suspend_needs_abort_syscall (void);
535
536 void mono_threads_platform_register (THREAD_INFO_TYPE *info);
537 void mono_threads_platform_unregister (THREAD_INFO_TYPE *info);
538 HANDLE mono_threads_platform_create_thread (MonoThreadStart start, gpointer arg, MonoThreadParm *, MonoNativeThreadId *out_tid);
539 void mono_threads_platform_get_stack_bounds (guint8 **staddr, size_t *stsize);
540 gboolean mono_threads_platform_yield (void);
541 void mono_threads_platform_exit (int exit_code);
542 HANDLE mono_threads_platform_open_thread_handle (HANDLE handle, MonoNativeThreadId tid);
543 void mono_threads_platform_set_exited (THREAD_INFO_TYPE *info);
544 void mono_threads_platform_describe (THREAD_INFO_TYPE *info, GString *text);
545 void mono_threads_platform_own_mutex (THREAD_INFO_TYPE *info, gpointer mutex_handle);
546 void mono_threads_platform_disown_mutex (THREAD_INFO_TYPE *info, gpointer mutex_handle);
547 MonoThreadPriority mono_threads_platform_get_priority (THREAD_INFO_TYPE *info);
548 gboolean mono_threads_platform_set_priority (THREAD_INFO_TYPE *info, MonoThreadPriority priority);
549
550 void mono_threads_coop_begin_global_suspend (void);
551 void mono_threads_coop_end_global_suspend (void);
552
553 MONO_API MonoNativeThreadId
554 mono_native_thread_id_get (void);
555
556 gboolean
557 mono_native_thread_id_equals (MonoNativeThreadId id1, MonoNativeThreadId id2);
558
559 gboolean
560 mono_native_thread_create (MonoNativeThreadId *tid, gpointer func, gpointer arg);
561
562 MONO_API void
563 mono_native_thread_set_name (MonoNativeThreadId tid, const char *name);
564
565 /*Mach specific internals */
566 void mono_threads_init_dead_letter (void);
567 void mono_threads_install_dead_letter (void);
568
569 /* mono-threads internal API used by the backends. */
570 /*
571 This tells the suspend initiator that we completed suspend and will now be waiting for resume.
572 */
573 void mono_threads_notify_initiator_of_suspend (THREAD_INFO_TYPE* info);
574 /*
575 This tells the resume initiator that we completed resume duties and will return to runnable state.
576 */
577 void mono_threads_notify_initiator_of_resume (THREAD_INFO_TYPE* info);
578
579 /*
580 This tells the resume initiator that we completed abort duties and will return to previous state.
581 */
582 void mono_threads_notify_initiator_of_abort (THREAD_INFO_TYPE* info);
583
584 /* Thread state machine functions */
585
586 typedef enum {
587         ResumeError,
588         ResumeOk,
589         ResumeInitSelfResume,
590         ResumeInitAsyncResume,
591         ResumeInitBlockingResume,
592 } MonoResumeResult;
593
594 typedef enum {
595         SelfSuspendResumed,
596         SelfSuspendWait,
597         SelfSuspendNotifyAndWait,
598 } MonoSelfSupendResult;
599
600 typedef enum {
601         AsyncSuspendAlreadySuspended,
602         AsyncSuspendWait,
603         AsyncSuspendInitSuspend,
604         AsyncSuspendBlocking,
605 } MonoRequestAsyncSuspendResult;
606
607 typedef enum {
608         DoBlockingContinue, //in blocking mode, continue
609         DoBlockingPollAndRetry, //async suspend raced blocking and won, pool and retry
610 } MonoDoBlockingResult;
611
612 typedef enum {
613         DoneBlockingOk, //exited blocking fine
614         DoneBlockingWait, //thread should end suspended
615 } MonoDoneBlockingResult;
616
617
618 typedef enum {
619         AbortBlockingIgnore, //Ignore
620         AbortBlockingIgnoreAndPoll, //Ignore and poll
621         AbortBlockingOk, //Abort worked
622         AbortBlockingWait, //Abort worked, but should wait for resume
623 } MonoAbortBlockingResult;
624
625
626 void mono_threads_transition_attach (THREAD_INFO_TYPE* info);
627 gboolean mono_threads_transition_detach (THREAD_INFO_TYPE *info);
628 void mono_threads_transition_request_self_suspension (THREAD_INFO_TYPE *info);
629 MonoRequestAsyncSuspendResult mono_threads_transition_request_async_suspension (THREAD_INFO_TYPE *info);
630 MonoSelfSupendResult mono_threads_transition_state_poll (THREAD_INFO_TYPE *info);
631 MonoResumeResult mono_threads_transition_request_resume (THREAD_INFO_TYPE* info);
632 gboolean mono_threads_transition_finish_async_suspend (THREAD_INFO_TYPE* info);
633 MonoDoBlockingResult mono_threads_transition_do_blocking (THREAD_INFO_TYPE* info);
634 MonoDoneBlockingResult mono_threads_transition_done_blocking (THREAD_INFO_TYPE* info);
635 MonoAbortBlockingResult mono_threads_transition_abort_blocking (THREAD_INFO_TYPE* info);
636
637 MonoThreadUnwindState* mono_thread_info_get_suspend_state (THREAD_INFO_TYPE *info);
638
639 gpointer
640 mono_threads_enter_gc_unsafe_region_cookie (void);
641
642
643 void mono_thread_info_wait_for_resume (THREAD_INFO_TYPE *info);
644 /* Advanced suspend API, used for suspending multiple threads as once. */
645 gboolean mono_thread_info_is_running (THREAD_INFO_TYPE *info);
646 gboolean mono_thread_info_is_live (THREAD_INFO_TYPE *info);
647 int mono_thread_info_suspend_count (THREAD_INFO_TYPE *info);
648 int mono_thread_info_current_state (THREAD_INFO_TYPE *info);
649 const char* mono_thread_state_name (int state);
650
651 gboolean mono_thread_info_in_critical_location (THREAD_INFO_TYPE *info);
652 gboolean mono_thread_info_begin_suspend (THREAD_INFO_TYPE *info);
653 gboolean mono_thread_info_begin_resume (THREAD_INFO_TYPE *info);
654
655 void mono_threads_add_to_pending_operation_set (THREAD_INFO_TYPE* info); //XXX rename to something to reflect the fact that this is used for both suspend and resume
656 gboolean mono_threads_wait_pending_operations (void);
657 void mono_threads_begin_global_suspend (void);
658 void mono_threads_end_global_suspend (void);
659
660 gboolean
661 mono_thread_info_is_current (THREAD_INFO_TYPE *info);
662
663 gpointer
664 mono_thread_info_get_handle (THREAD_INFO_TYPE *info);
665
666 void
667 mono_thread_info_describe (THREAD_INFO_TYPE *info, GString *text);
668
669 void
670 mono_thread_info_own_mutex (THREAD_INFO_TYPE *info, gpointer mutex_handle);
671
672 void
673 mono_thread_info_disown_mutex (THREAD_INFO_TYPE *info, gpointer mutex_handle);
674
675 MonoThreadPriority
676 mono_thread_info_get_priority (THREAD_INFO_TYPE *info);
677
678 gboolean
679 mono_thread_info_set_priority (THREAD_INFO_TYPE *info, MonoThreadPriority priority);
680
681 #endif /* __MONO_THREADS_H__ */