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