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