#include "eval_intern.h"
#include "gc.h"
#include "timev.h"
#include "ruby/io.h"
#include "ruby/thread.h"
#include "ruby/thread_native.h"
#include "ruby/debug.h"
#include "internal.h"
#include "thread_sync.c"

Data Structures
struct	waiting_fd

struct	rb_blocking_region_buffer

struct	join_arg

struct	select_args

struct	thgroup

struct	exec_recursive_params

Macros
#define	__USE_FORTIFY_LEVEL 0

#define	USE_NATIVE_THREAD_PRIORITY 0

#define	RUBY_THREAD_PRIORITY_MAX 3

#define	RUBY_THREAD_PRIORITY_MIN -3

#define	THREAD_DEBUG 0

#define	eKillSignal INT2FIX(0)

#define	eTerminateSignal INT2FIX(1)

#define	THREAD_SYSTEM_DEPENDENT_IMPLEMENTATION

#define	RB_GC_SAVE_MACHINE_REGISTER_STACK(th)

#define	RB_GC_SAVE_MACHINE_CONTEXT(th)

#define	GVL_UNLOCK_BEGIN()

#define	GVL_UNLOCK_END()

#define	only_if_constant(expr, notconst) notconst

#define	BLOCKING_REGION(exec, ubf, ubfarg, fail_if_interrupted)

#define	RUBY_VM_CHECK_INTS_BLOCKING(th) vm_check_ints_blocking(th)

#define	thread_debug if(0)printf

#define	fill_thread_id_string(thid, buf) (void *)(thid)

#define	fill_thread_id_str(th) (void)0

#define	thread_id_str(th) ((void *)(th)->thread_id)

#define	PRI_THREAD_ID "p"

#define	thread_start_func_2(th, st, rst) thread_start_func_2(th, st)

#define	threadptr_initialized(th) ((th)->first_args != 0)

#define	DELAY_INFTY 1E30

#define	rb_fd_no_init(fds) (void)(fds)

#define	restore_fdset(fds1, fds2) ((fds1) ? rb_fd_dup(fds1, fds2) : (void)0)

#define	do_select_update()

#define	fd_init_copy(f) (f##fds) ? rb_fd_init_copy(&orig_##f, f##fds) : rb_fd_no_init(&orig_##f)

#define	fd_term(f) if (f##fds) rb_fd_term(&orig_##f)

#define	GetThreadShieldPtr(obj) ((VALUE)rb_check_typeddata((obj), &thread_shield_data_type))

#define	THREAD_SHIELD_WAITING_MASK (FL_USER0\|FL_USER1\|FL_USER2\|FL_USER3\|FL_USER4\|FL_USER5\|FL_USER6\|FL_USER7\|FL_USER8\|FL_USER9\|FL_USER10\|FL_USER11\|FL_USER12\|FL_USER13\|FL_USER14\|FL_USER15\|FL_USER16\|FL_USER17\|FL_USER18\|FL_USER19)

#define	THREAD_SHIELD_WAITING_SHIFT (FL_USHIFT)

#define	rb_thread_shield_waiting(b) (int)((RBASIC(b)->flags&THREAD_SHIELD_WAITING_MASK)>>THREAD_SHIELD_WAITING_SHIFT)

#define	OBJ_ID_EQL(obj_id, other) ((obj_id) == (other))

#define	rb_intern(str) rb_intern_const(str)

Enumerations
enum	handle_interrupt_timing { INTERRUPT_NONE, INTERRUPT_IMMEDIATE, INTERRUPT_ON_BLOCKING, INTERRUPT_NEVER }

Functions
	NOINLINE (static int thread_start_func_2(rb_thread_t th, VALUE stack_start, VALUE *register_stack_start))

void	rb_vm_gvl_destroy (rb_vm_t *vm)

void	rb_nativethread_lock_initialize (rb_nativethread_lock_t *lock)

void	rb_nativethread_lock_destroy (rb_nativethread_lock_t *lock)

void	rb_nativethread_lock_lock (rb_nativethread_lock_t *lock)

void	rb_nativethread_lock_unlock (rb_nativethread_lock_t *lock)

void	rb_threadptr_interrupt (rb_thread_t *th)

void	rb_threadptr_trap_interrupt (rb_thread_t *th)

void	rb_threadptr_unlock_all_locking_mutexes (rb_thread_t *th)

void	rb_thread_terminate_all (void)

void	ruby_thread_init_stack (rb_thread_t *th)

const VALUE *	rb_vm_proc_local_ep (VALUE proc)

VALUE	rb_thread_create (VALUE(fn)(ANYARGS), void arg)

void	rb_thread_sleep_forever (void)

void	rb_thread_sleep_deadly (void)

void	rb_thread_wait_for (struct timeval time)

void	rb_thread_check_ints (void)

int	rb_thread_check_trap_pending (void)

int	rb_thread_interrupted (VALUE thval)

void	rb_thread_sleep (int sec)

void	rb_thread_schedule (void)

void *	rb_thread_call_without_gvl2 (void (func)(void ), void data1, rb_unblock_function_t ubf, void data2)

void *	rb_thread_call_without_gvl (void (func)(void data), void data1, rb_unblock_function_t ubf, void data2)

VALUE	rb_thread_io_blocking_region (rb_blocking_function_t func, void data1, int fd)

void *	rb_thread_call_with_gvl (void (func)(void ), void data1)

int	ruby_thread_has_gvl_p (void)

void	rb_threadptr_pending_interrupt_clear (rb_thread_t *th)

void	rb_threadptr_pending_interrupt_enque (rb_thread_t *th, VALUE v)

int	rb_threadptr_pending_interrupt_active_p (rb_thread_t *th)

void	rb_threadptr_execute_interrupts (rb_thread_t *th, int blocking_timing)

void	rb_thread_execute_interrupts (VALUE thval)

void	rb_threadptr_setup_exception (rb_thread_t *th, VALUE mesg, VALUE cause)

void	rb_threadptr_signal_raise (rb_thread_t *th, int sig)

void	rb_threadptr_signal_exit (rb_thread_t *th)

int	rb_threadptr_set_raised (rb_thread_t *th)

int	rb_threadptr_reset_raised (rb_thread_t *th)

int	rb_notify_fd_close (int fd)

void	rb_thread_fd_close (int fd)

VALUE	rb_thread_kill (VALUE thread)

int	rb_thread_to_be_killed (VALUE thread)

VALUE	rb_thread_wakeup (VALUE thread)

VALUE	rb_thread_wakeup_alive (VALUE thread)

VALUE	rb_thread_run (VALUE thread)

VALUE	rb_thread_stop (void)

VALUE	rb_thread_list (void)

VALUE	rb_thread_current (void)

VALUE	rb_thread_main (void)

VALUE	rb_thread_group (VALUE thread)

VALUE	rb_thread_local_aref (VALUE thread, ID id)

VALUE	rb_thread_local_aset (VALUE thread, ID id, VALUE val)

int	rb_thread_alone (void)

void	rb_thread_wait_fd (int fd)

int	rb_thread_fd_writable (int fd)

int	rb_thread_fd_select (int max, rb_fdset_t read, rb_fdset_t write, rb_fdset_t except, struct timeval timeout)

int	rb_wait_for_single_fd (int fd, int events, struct timeval *tv)

void	rb_gc_set_stack_end (VALUE **stack_end_p)

void	rb_threadptr_check_signal (rb_thread_t *mth)

void	rb_thread_stop_timer_thread (void)

void	rb_thread_reset_timer_thread (void)

void	rb_thread_start_timer_thread (void)

void	rb_thread_atfork (void)

void	rb_thread_atfork_before_exec (void)

VALUE	rb_thread_shield_new (void)

VALUE	rb_thread_shield_wait (VALUE self)

VALUE	rb_thread_shield_release (VALUE self)

VALUE	rb_thread_shield_destroy (VALUE self)

ID	rb_frame_last_func (void)
	Returns the ID of the last method in the call stack. More...

VALUE	rb_exec_recursive (VALUE(*func)(VALUE, VALUE, int), VALUE obj, VALUE arg)

VALUE	rb_exec_recursive_paired (VALUE(*func)(VALUE, VALUE, int), VALUE obj, VALUE paired_obj, VALUE arg)

VALUE	rb_exec_recursive_outer (VALUE(*func)(VALUE, VALUE, int), VALUE obj, VALUE arg)

VALUE	rb_exec_recursive_paired_outer (VALUE(*func)(VALUE, VALUE, int), VALUE obj, VALUE paired_obj, VALUE arg)

void	Init_Thread (void)

int	ruby_native_thread_p (void)

VALUE	rb_get_coverages (void)

void	rb_set_coverages (VALUE coverages, int mode)

void	rb_reset_coverages (void)

VALUE	rb_default_coverage (int n)

VALUE	rb_uninterruptible (VALUE(*b_proc)(ANYARGS), VALUE data)

Macro Definition Documentation

◆ __USE_FORTIFY_LEVEL

#define __USE_FORTIFY_LEVEL 0

Definition at line 62 of file thread.c.

◆ BLOCKING_REGION

#define BLOCKING_REGION	(	exec,
		ubf,
		ubfarg,
		fail_if_interrupted
	)

Value:

do { \
    rb_thread_t *__th = GET_THREAD(); \
    struct rb_blocking_region_buffer __region; \
    if (blocking_region_begin(__th, &__region, (ubf), (ubfarg), fail_if_interrupted) || \
        /* always return true unless fail_if_interrupted */ \
        !only_if_constant(fail_if_interrupted, TRUE)) { \
        exec; \
        blocking_region_end(__th, &__region); \
    }; \
} while(0)

Definition at line 165 of file thread.c.

Referenced by rb_thread_io_blocking_region().

◆ DELAY_INFTY

#define DELAY_INFTY 1E30

Definition at line 838 of file thread.c.

◆ do_select_update

#define do_select_update ( )

Value:

(restore_fdset(readfds, &orig_read), \
     restore_fdset(writefds, &orig_write), \
     restore_fdset(exceptfds, &orig_except), \
     update_timeval(timeout, limit), \
     TRUE)

◆ eKillSignal

#define eKillSignal INT2FIX(0)

Definition at line 101 of file thread.c.

◆ eTerminateSignal

#define eTerminateSignal INT2FIX(1)

Definition at line 102 of file thread.c.

◆ fd_init_copy

#define fd_init_copy ( f ) (f##fds) ? rb_fd_init_copy(&orig_##f, f##fds) : rb_fd_no_init(&orig_##f)

◆ fd_term

#define fd_term ( f ) if (f##fds) rb_fd_term(&orig_##f)

◆ fill_thread_id_str

#define fill_thread_id_str ( th ) (void)0

Definition at line 278 of file thread.c.

◆ fill_thread_id_string

#define fill_thread_id_string	(	thid,
		buf
	)	(void *)(thid)

Definition at line 277 of file thread.c.

◆ GetThreadShieldPtr

#define GetThreadShieldPtr ( obj ) ((VALUE)rb_check_typeddata((obj), &thread_shield_data_type))

Definition at line 4395 of file thread.c.

Referenced by rb_thread_shield_wait().

◆ GVL_UNLOCK_BEGIN

#define GVL_UNLOCK_BEGIN ( )

Value:

do { \
  rb_thread_t *_th_stored = GET_THREAD(); \
  RB_GC_SAVE_MACHINE_CONTEXT(_th_stored); \
  gvl_release(_th_stored->vm);

Definition at line 146 of file thread.c.

◆ GVL_UNLOCK_END

#define GVL_UNLOCK_END ( )

Value:

gvl_acquire(_th_stored->vm, _th_stored); \
  rb_thread_set_current(_th_stored); \
} while(0)

Definition at line 151 of file thread.c.

◆ OBJ_ID_EQL

#define OBJ_ID_EQL	(	obj_id,
		other
	)	((obj_id) == (other))

◆ only_if_constant

#define only_if_constant	(	expr,
		notconst
	)	notconst

Definition at line 163 of file thread.c.

◆ PRI_THREAD_ID

#define PRI_THREAD_ID "p"

Definition at line 280 of file thread.c.

◆ rb_fd_no_init

#define rb_fd_no_init ( fds ) (void)(fds)

Definition at line 3671 of file thread.c.

◆ RB_GC_SAVE_MACHINE_CONTEXT

#define RB_GC_SAVE_MACHINE_CONTEXT ( th )

Value:

do {                                                    \
        FLUSH_REGISTER_WINDOWS;                                 \
        RB_GC_SAVE_MACHINE_REGISTER_STACK(th);                  \
        setjmp((th)->ec.machine.regs);                          \
        SET_MACHINE_STACK_END(&(th)->ec.machine.stack_end);     \
    } while (0)

Definition at line 138 of file thread.c.

◆ RB_GC_SAVE_MACHINE_REGISTER_STACK

#define RB_GC_SAVE_MACHINE_REGISTER_STACK ( th )

Definition at line 136 of file thread.c.

◆ rb_intern

#define rb_intern ( str ) rb_intern_const(str)

◆ rb_thread_shield_waiting

#define rb_thread_shield_waiting ( b ) (int)((RBASIC(b)->flags&THREAD_SHIELD_WAITING_MASK)>>THREAD_SHIELD_WAITING_SHIFT)

Definition at line 4398 of file thread.c.

◆ restore_fdset

#define restore_fdset	(	fds1,
		fds2
	)	((fds1) ? rb_fd_dup(fds1, fds2) : (void)0)

Definition at line 3684 of file thread.c.

◆ RUBY_THREAD_PRIORITY_MAX

#define RUBY_THREAD_PRIORITY_MAX 3

Definition at line 77 of file thread.c.

◆ RUBY_THREAD_PRIORITY_MIN

#define RUBY_THREAD_PRIORITY_MIN -3

Definition at line 78 of file thread.c.

◆ RUBY_VM_CHECK_INTS_BLOCKING

#define RUBY_VM_CHECK_INTS_BLOCKING ( th ) vm_check_ints_blocking(th)

Definition at line 176 of file thread.c.

Referenced by rb_thread_check_ints(), and rb_thread_io_blocking_region().

◆ THREAD_DEBUG

#define THREAD_DEBUG 0

Definition at line 82 of file thread.c.

◆ thread_debug

#define thread_debug if(0)printf

Definition at line 273 of file thread.c.

Referenced by rb_thread_sleep_deadly(), rb_thread_sleep_forever(), and rb_thread_terminate_all().

◆ thread_id_str

#define thread_id_str ( th ) ((void *)(th)->thread_id)

Definition at line 279 of file thread.c.

◆ THREAD_SHIELD_WAITING_MASK

Definition at line 4396 of file thread.c.

◆ THREAD_SHIELD_WAITING_SHIFT

#define THREAD_SHIELD_WAITING_SHIFT (FL_USHIFT)

Definition at line 4397 of file thread.c.

◆ thread_start_func_2

#define thread_start_func_2	(	th,
		st,
		rst
	)	thread_start_func_2(th, st)

Definition at line 284 of file thread.c.

◆ THREAD_SYSTEM_DEPENDENT_IMPLEMENTATION

#define THREAD_SYSTEM_DEPENDENT_IMPLEMENTATION

Definition at line 119 of file thread.c.

◆ threadptr_initialized

#define threadptr_initialized ( th ) ((th)->first_args != 0)

Definition at line 751 of file thread.c.

◆ USE_NATIVE_THREAD_PRIORITY

#define USE_NATIVE_THREAD_PRIORITY 0

Definition at line 76 of file thread.c.

Enumeration Type Documentation

◆ handle_interrupt_timing

enum handle_interrupt_timing

Enumerator
INTERRUPT_NONE
INTERRUPT_IMMEDIATE
INTERRUPT_ON_BLOCKING
INTERRUPT_NEVER

Definition at line 1609 of file thread.c.

Function Documentation

◆ Init_Thread()

void Init_Thread ( void )

Definition at line 4796 of file thread.c.

References GET_THREAD.

◆ NOINLINE()

NOINLINE ( static int thread_start_func_2rb_thread_t *th, VALUE *stack_start, VALUE *register_stack_start )

◆ rb_default_coverage()

VALUE rb_default_coverage ( int n )

Definition at line 5081 of file thread.c.

◆ rb_exec_recursive()

VALUE rb_exec_recursive	(	VALUE(*)(VALUE, VALUE, int)	func,
		VALUE	obj,
		VALUE	arg
	)

Definition at line 4709 of file thread.c.

Referenced by rb_invcmp(), and rb_io_puts().

◆ rb_exec_recursive_outer()

VALUE rb_exec_recursive_outer	(	VALUE(*)(VALUE, VALUE, int)	func,
		VALUE	obj,
		VALUE	arg
	)

Definition at line 4732 of file thread.c.

Referenced by rb_hash().

◆ rb_exec_recursive_paired()

VALUE rb_exec_recursive_paired	(	VALUE(*)(VALUE, VALUE, int)	func,
		VALUE	obj,
		VALUE	paired_obj,
		VALUE	arg
	)

Definition at line 4720 of file thread.c.

Referenced by rb_ary_cmp().

◆ rb_exec_recursive_paired_outer()

VALUE rb_exec_recursive_paired_outer	(	VALUE(*)(VALUE, VALUE, int)	func,
		VALUE	obj,
		VALUE	paired_obj,
		VALUE	arg
	)

Definition at line 4744 of file thread.c.

◆ rb_gc_set_stack_end()

void rb_gc_set_stack_end ( VALUE ** stack_end_p )

Definition at line 4016 of file thread.c.

◆ rb_get_coverages()

VALUE rb_get_coverages ( void )

Definition at line 5044 of file thread.c.

References GET_VM.

Referenced by rb_reset_coverages().

◆ rb_nativethread_lock_destroy()

void rb_nativethread_lock_destroy ( rb_nativethread_lock_t * lock )

Definition at line 362 of file thread.c.

◆ rb_nativethread_lock_initialize()

void rb_nativethread_lock_initialize ( rb_nativethread_lock_t * lock )

Definition at line 356 of file thread.c.

◆ rb_nativethread_lock_lock()

void rb_nativethread_lock_lock ( rb_nativethread_lock_t * lock )

Definition at line 368 of file thread.c.

◆ rb_nativethread_lock_unlock()

void rb_nativethread_lock_unlock ( rb_nativethread_lock_t * lock )

Definition at line 374 of file thread.c.

◆ rb_notify_fd_close()

int rb_notify_fd_close ( int fd )

Definition at line 2193 of file thread.c.

References err, waiting_fd::fd, GET_THREAD, rb_threadptr_interrupt(), rb_threadptr_pending_interrupt_enque(), ruby_error_stream_closed, rb_vm_struct::special_exceptions, waiting_fd::th, rb_thread_struct::vm, rb_vm_struct::waiting_fds, and waiting_fd::wfd_node.

Referenced by rb_thread_fd_close().

◆ rb_reset_coverages()

void rb_reset_coverages ( void )

Definition at line 5072 of file thread.c.

References rb_get_coverages(), rb_hash_tbl_raw(), and st_foreach.

◆ rb_set_coverages()

void rb_set_coverages	(	VALUE	coverages,
		int	mode
	)

Definition at line 5050 of file thread.c.

References GET_VM, and rb_add_event_hook2().

◆ rb_thread_alone()

int rb_thread_alone ( void )

Definition at line 3273 of file thread.c.

Referenced by rb_thread_stop().

◆ rb_thread_atfork()

void rb_thread_atfork ( void )

Definition at line 4186 of file thread.c.

◆ rb_thread_atfork_before_exec()

void rb_thread_atfork_before_exec ( void )

Definition at line 4191 of file thread.c.

◆ rb_thread_call_with_gvl()

void* rb_thread_call_with_gvl	(	void ()(void *)	func,
		void *	data1
	)

Definition at line 1501 of file thread.c.

References rb_thread_struct::blocking_region_buffer, EXIT_FAILURE, if(), rb_bug(), and rb_thread_struct::unblock.

◆ rb_thread_call_without_gvl()

void* rb_thread_call_without_gvl	(	void ()(void *data)	func,
		void *	data1,
		rb_unblock_function_t *	ubf,
		void *	data2
	)

Definition at line 1429 of file thread.c.

◆ rb_thread_call_without_gvl2()

void* rb_thread_call_without_gvl2	(	void ()(void *)	func,
		void *	data1,
		rb_unblock_function_t *	ubf,
		void *	data2
	)

Definition at line 1422 of file thread.c.

◆ rb_thread_check_ints()

void rb_thread_check_ints ( void )

Definition at line 1219 of file thread.c.

References GET_THREAD, and RUBY_VM_CHECK_INTS_BLOCKING.

◆ rb_thread_check_trap_pending()

int rb_thread_check_trap_pending ( void )

Definition at line 1230 of file thread.c.

References rb_signal_buff_size().

◆ rb_thread_create()

VALUE rb_thread_create	(	VALUE(*)(ANYARGS)	fn,
		void *	arg
	)

Definition at line 831 of file thread.c.

Referenced by rb_detach_process().

◆ rb_thread_current()

VALUE rb_thread_current ( void )

Definition at line 2494 of file thread.c.

References GET_THREAD.

Referenced by VpGetPrecLimit(), and VpGetRoundMode().

◆ rb_thread_execute_interrupts()

void rb_thread_execute_interrupts ( VALUE thval )

Definition at line 2107 of file thread.c.

References rb_threadptr_execute_interrupts().

◆ rb_thread_fd_close()

void rb_thread_fd_close ( int fd )

Definition at line 2219 of file thread.c.

References rb_notify_fd_close(), and rb_thread_schedule().

◆ rb_thread_fd_select()

int rb_thread_fd_select	(	int	max,
		rb_fdset_t *	read,
		rb_fdset_t *	write,
		rb_fdset_t *	except,
		struct timeval *	timeout
	)

Definition at line 3789 of file thread.c.

References rb_fd_resize, rb_thread_sleep_forever(), and rb_thread_wait_for().

◆ rb_thread_fd_writable()

int rb_thread_fd_writable ( int fd )

Definition at line 3782 of file thread.c.

◆ rb_thread_group()

VALUE rb_thread_group ( VALUE thread )

Definition at line 2758 of file thread.c.

◆ rb_thread_interrupted()

int rb_thread_interrupted ( VALUE thval )

Definition at line 1237 of file thread.c.

References RUBY_VM_INTERRUPTED.

◆ rb_thread_io_blocking_region()

VALUE rb_thread_io_blocking_region	(	rb_blocking_function_t *	func,
		void *	data1,
		int	fd
	)

Definition at line 1436 of file thread.c.

References BLOCKING_REGION, errno, EXEC_TAG, FALSE, waiting_fd::fd, GET_THREAD, GET_VM, Qundef, RUBY_VM_CHECK_INTS_BLOCKING, TAG_NONE, waiting_fd::th, TH_JUMP_TAG, TH_POP_TAG, TH_PUSH_TAG, val, rb_vm_struct::waiting_fds, and waiting_fd::wfd_node.

◆ rb_thread_kill()

VALUE rb_thread_kill ( VALUE thread )

Definition at line 2276 of file thread.c.

◆ rb_thread_list()

VALUE rb_thread_list ( void )

Definition at line 2474 of file thread.c.

References GET_THREAD, rb_vm_struct::living_threads, rb_ary_new(), rb_ary_push(), rb_thread_struct::self, rb_thread_struct::status, THREAD_RUNNABLE, THREAD_STOPPED, and THREAD_STOPPED_FOREVER.

◆ rb_thread_local_aref()

VALUE rb_thread_local_aref	(	VALUE	thread,
		ID	id
	)

Definition at line 3013 of file thread.c.

Referenced by VpGetPrecLimit(), and VpGetRoundMode().

◆ rb_thread_local_aset()

VALUE rb_thread_local_aset	(	VALUE	thread,
		ID	id,
		VALUE	val
	)

Definition at line 3148 of file thread.c.

References OBJ_FROZEN, and rb_error_frozen().

◆ rb_thread_main()

VALUE rb_thread_main ( void )

Definition at line 2515 of file thread.c.

References GET_THREAD.

◆ rb_thread_reset_timer_thread()

void rb_thread_reset_timer_thread ( void )

Definition at line 4078 of file thread.c.

◆ rb_thread_run()

VALUE rb_thread_run ( VALUE thread )

Definition at line 2417 of file thread.c.

References rb_thread_schedule(), and rb_thread_wakeup().

◆ rb_thread_schedule()

void rb_thread_schedule ( void )

Definition at line 1266 of file thread.c.

References GET_THREAD.

Referenced by rb_thread_fd_close(), and rb_thread_run().

◆ rb_thread_shield_destroy()

VALUE rb_thread_shield_destroy ( VALUE self )

Definition at line 4478 of file thread.c.

◆ rb_thread_shield_new()

VALUE rb_thread_shield_new ( void )

Definition at line 4422 of file thread.c.

◆ rb_thread_shield_release()

VALUE rb_thread_shield_release ( VALUE self )

Definition at line 4467 of file thread.c.

◆ rb_thread_shield_wait()

VALUE rb_thread_shield_wait ( VALUE self )

Definition at line 4438 of file thread.c.

References GET_THREAD, GetMutexPtr, GetThreadShieldPtr, Qfalse, Qnil, and rb_mutex_struct::th.

◆ rb_thread_sleep()

void rb_thread_sleep ( int sec )

Definition at line 1243 of file thread.c.

References INT2FIX, rb_thread_wait_for(), and rb_time_timeval().

◆ rb_thread_sleep_deadly()

void rb_thread_sleep_deadly ( void )

Definition at line 1167 of file thread.c.

References thread_debug.

Referenced by rb_thread_stop().

◆ rb_thread_sleep_forever()

void rb_thread_sleep_forever ( void )

Definition at line 1160 of file thread.c.

References thread_debug.

Referenced by rb_thread_fd_select().

◆ rb_thread_start_timer_thread()

void rb_thread_start_timer_thread ( void )

Definition at line 4084 of file thread.c.

◆ rb_thread_stop()

VALUE rb_thread_stop ( void )

Definition at line 2441 of file thread.c.

References Qnil, rb_eThreadError, rb_raise(), rb_thread_alone(), and rb_thread_sleep_deadly().

◆ rb_thread_stop_timer_thread()

void rb_thread_stop_timer_thread ( void )

Definition at line 4070 of file thread.c.

◆ rb_thread_terminate_all()

void rb_thread_terminate_all ( void )

Definition at line 479 of file thread.c.

References GET_THREAD, rb_vm_struct::main_thread, rb_bug(), rb_threadptr_unlock_all_locking_mutexes(), TAG_NONE, TH_EXEC_TAG, TH_PUSH_TAG, thread_debug, and rb_thread_struct::vm.

◆ rb_thread_to_be_killed()

int rb_thread_to_be_killed ( VALUE thread )

Definition at line 2302 of file thread.c.

◆ rb_thread_wait_fd()

void rb_thread_wait_fd ( int fd )

Definition at line 3776 of file thread.c.

Referenced by rb_io_read_check().

◆ rb_thread_wait_for()

void rb_thread_wait_for ( struct timeval time )

Definition at line 1205 of file thread.c.

References GET_THREAD.

Referenced by rb_thread_fd_select(), and rb_thread_sleep().

◆ rb_thread_wakeup()

VALUE rb_thread_wakeup ( VALUE thread )

Definition at line 2370 of file thread.c.

References rb_eThreadError, rb_raise(), rb_thread_wakeup_alive(), and RTEST.

Referenced by rb_thread_run().

◆ rb_thread_wakeup_alive()

VALUE rb_thread_wakeup_alive ( VALUE thread )

Definition at line 2379 of file thread.c.

Referenced by rb_thread_wakeup().

◆ rb_threadptr_check_signal()

void rb_threadptr_check_signal ( rb_thread_t * mth )

Definition at line 4029 of file thread.c.

References rb_signal_buff_size(), and rb_threadptr_trap_interrupt().

Referenced by ruby_cleanup().

◆ rb_threadptr_execute_interrupts()

void rb_threadptr_execute_interrupts	(	rb_thread_t *	th,
		int	blocking_timing
	)

Definition at line 2029 of file thread.c.

References rb_thread_struct::ec, and rb_execution_context_struct::raised_flag.

Referenced by rb_thread_execute_interrupts().

◆ rb_threadptr_interrupt()

void rb_threadptr_interrupt ( rb_thread_t * th )

Definition at line 433 of file thread.c.

Referenced by rb_notify_fd_close(), and ruby_cleanup().

◆ rb_threadptr_pending_interrupt_active_p()

int rb_threadptr_pending_interrupt_active_p ( rb_thread_t * th )

Definition at line 1716 of file thread.c.

References rb_thread_struct::pending_interrupt_queue_checked.

◆ rb_threadptr_pending_interrupt_clear()

void rb_threadptr_pending_interrupt_clear ( rb_thread_t * th )

Definition at line 1589 of file thread.c.

References rb_thread_struct::pending_interrupt_queue, and rb_ary_clear().

◆ rb_threadptr_pending_interrupt_enque()

void rb_threadptr_pending_interrupt_enque	(	rb_thread_t *	th,
		VALUE	v
	)

Definition at line 1595 of file thread.c.

References rb_thread_struct::pending_interrupt_queue, rb_thread_struct::pending_interrupt_queue_checked, and rb_ary_push().

Referenced by rb_fiber_start(), and rb_notify_fd_close().

◆ rb_threadptr_reset_raised()

int rb_threadptr_reset_raised ( rb_thread_t * th )

Definition at line 2183 of file thread.c.

References rb_thread_struct::ec, RAISED_EXCEPTION, and rb_execution_context_struct::raised_flag.

◆ rb_threadptr_set_raised()

int rb_threadptr_set_raised ( rb_thread_t * th )

Definition at line 2173 of file thread.c.

References rb_thread_struct::ec, RAISED_EXCEPTION, and rb_execution_context_struct::raised_flag.

◆ rb_threadptr_setup_exception()

void rb_threadptr_setup_exception	(	rb_thread_t *	th,
		VALUE	mesg,
		VALUE	cause
	)

Definition at line 586 of file eval.c.

References Qundef.

◆ rb_threadptr_signal_exit()

void rb_threadptr_signal_exit ( rb_thread_t * th )

Definition at line 2159 of file thread.c.

References rb_eSystemExit, and rb_str_new2.

Referenced by rb_signal_exec().

◆ rb_threadptr_signal_raise()

void rb_threadptr_signal_raise	(	rb_thread_t *	th,
		int	sig
	)

Definition at line 2149 of file thread.c.

References INT2FIX, and rb_eSignal.

Referenced by rb_signal_exec().

◆ rb_threadptr_trap_interrupt()

void rb_threadptr_trap_interrupt ( rb_thread_t * th )

Definition at line 439 of file thread.c.

Referenced by rb_threadptr_check_signal().

◆ rb_threadptr_unlock_all_locking_mutexes()

void rb_threadptr_unlock_all_locking_mutexes ( rb_thread_t * th )

Definition at line 462 of file thread.c.

References err, rb_thread_struct::keeping_mutexes, and rb_mutex_struct::next_mutex.

Referenced by rb_thread_terminate_all().

◆ rb_uninterruptible()

VALUE rb_uninterruptible	(	VALUE(*)(ANYARGS)	b_proc,
		VALUE	data
	)

Definition at line 5128 of file thread.c.

References GET_THREAD, rb_cObject, rb_hash_aset(), and rb_ident_hash_new().

◆ rb_vm_gvl_destroy()

void rb_vm_gvl_destroy ( rb_vm_t * vm )

Definition at line 348 of file thread.c.

References rb_vm_struct::thread_destruct_lock.

◆ rb_vm_proc_local_ep()

const VALUE* rb_vm_proc_local_ep ( VALUE proc )

Definition at line 565 of file thread.c.

Referenced by rb_fiber_start().

◆ rb_wait_for_single_fd()

int rb_wait_for_single_fd	(	int	fd,
		int	events,
		struct timeval *	tv
	)

Definition at line 3989 of file thread.c.

References select_args::as, waiting_fd::fd, select_args::fd, RB_WAITFD_IN, and select_args::read.

◆ ruby_native_thread_p()

int ruby_native_thread_p ( void )

Definition at line 4913 of file thread.c.

◆ ruby_thread_has_gvl_p()

int ruby_thread_has_gvl_p ( void )

Definition at line 1543 of file thread.c.

References rb_thread_struct::blocking_region_buffer.

◆ ruby_thread_init_stack()

void ruby_thread_init_stack ( rb_thread_t * th )

Definition at line 559 of file thread.c.

Data Structures

Macros

Enumerations

Functions

Macro Definition Documentation

◆ __USE_FORTIFY_LEVEL

◆ BLOCKING_REGION

◆ DELAY_INFTY

◆ do_select_update

◆ eKillSignal

◆ eTerminateSignal

◆ fd_init_copy

◆ fd_term

◆ fill_thread_id_str

◆ fill_thread_id_string

◆ GetThreadShieldPtr

◆ GVL_UNLOCK_BEGIN

◆ GVL_UNLOCK_END

◆ OBJ_ID_EQL

◆ only_if_constant

◆ PRI_THREAD_ID

◆ rb_fd_no_init

◆ RB_GC_SAVE_MACHINE_CONTEXT

◆ RB_GC_SAVE_MACHINE_REGISTER_STACK

◆ rb_intern

◆ rb_thread_shield_waiting

◆ restore_fdset

◆ RUBY_THREAD_PRIORITY_MAX

◆ RUBY_THREAD_PRIORITY_MIN

◆ RUBY_VM_CHECK_INTS_BLOCKING

◆ THREAD_DEBUG

◆ thread_debug

◆ thread_id_str

◆ THREAD_SHIELD_WAITING_MASK

◆ THREAD_SHIELD_WAITING_SHIFT

◆ thread_start_func_2

◆ THREAD_SYSTEM_DEPENDENT_IMPLEMENTATION

◆ threadptr_initialized

◆ USE_NATIVE_THREAD_PRIORITY

Enumeration Type Documentation

◆ handle_interrupt_timing

Function Documentation

◆ Init_Thread()

◆ NOINLINE()

◆ rb_default_coverage()

◆ rb_exec_recursive()

◆ rb_exec_recursive_outer()

◆ rb_exec_recursive_paired()

◆ rb_exec_recursive_paired_outer()

◆ rb_gc_set_stack_end()

◆ rb_get_coverages()

◆ rb_nativethread_lock_destroy()

◆ rb_nativethread_lock_initialize()

◆ rb_nativethread_lock_lock()

◆ rb_nativethread_lock_unlock()

◆ rb_notify_fd_close()

◆ rb_reset_coverages()

◆ rb_set_coverages()

◆ rb_thread_alone()

◆ rb_thread_atfork()

◆ rb_thread_atfork_before_exec()

◆ rb_thread_call_with_gvl()

◆ rb_thread_call_without_gvl()

◆ rb_thread_call_without_gvl2()

◆ rb_thread_check_ints()

◆ rb_thread_check_trap_pending()

◆ rb_thread_create()

◆ rb_thread_current()

◆ rb_thread_execute_interrupts()

◆ rb_thread_fd_close()

◆ rb_thread_fd_select()

◆ rb_thread_fd_writable()

◆ rb_thread_group()

◆ rb_thread_interrupted()

◆ rb_thread_io_blocking_region()

◆ rb_thread_kill()

◆ rb_thread_list()

◆ rb_thread_local_aref()

◆ rb_thread_local_aset()

◆ rb_thread_main()