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