thread_pthread.c File Reference

#include "gc.h"

Data Structures
struct	cached_thread_entry
Defines
#define	RB_CONDATTR_CLOCK_MONOTONIC 1
#define	USE_MONOTONIC_COND 0
#define	USE_SLEEPY_TIMER_THREAD 0
#define	ARRAY_SIZE(x) (sizeof(x) / sizeof((x)[0]))
#define	NATIVE_MUTEX_LOCK_DEBUG 0
#define	TIMET_MAX (~(time_t)0 <= 0 ? (time_t)((~(unsigned_time_t)0) >> 1) : (time_t)(~(unsigned_time_t)0))
#define	native_cleanup_push pthread_cleanup_push
#define	native_cleanup_pop pthread_cleanup_pop
#define	native_thread_yield() ((void)0)
#define	USE_THREAD_CACHE 0
#define	MAINSTACKADDR_AVAILABLE 0
#define	CHECK_ERR(expr) {int err = (expr); if (err) {rb_bug_errno(#expr, err);}}
#define	USE_NATIVE_THREAD_INIT 1
#define	add_signal_thread_list(th) (void)(th)
#define	remove_signal_thread_list(th) (void)(th)
#define	ubf_select 0
#define	TT_DEBUG 0
#define	WRITE_CONST(fd, str) (void)(write((fd),(str),sizeof(str)-1)<0)
#define	TIME_QUANTUM_USEC (100 * 1000)
#define	PER_NANO 1000000000
Typedefs
typedef unsigned long	unsigned_time_t
Enumerations
enum	{ RUBY_STACK_SPACE_LIMIT = 1024 * 1024, RUBY_STACK_SPACE_RATIO = 5 }
Functions
static void	native_mutex_lock (pthread_mutex_t *lock)
static void	native_mutex_unlock (pthread_mutex_t *lock)
static int	native_mutex_trylock (pthread_mutex_t *lock)
static void	native_mutex_initialize (pthread_mutex_t *lock)
static void	native_mutex_destroy (pthread_mutex_t *lock)
static void	native_cond_signal (rb_thread_cond_t *cond)
static void	native_cond_broadcast (rb_thread_cond_t *cond)
static void	native_cond_wait (rb_thread_cond_t cond, pthread_mutex_t mutex)
static void	native_cond_initialize (rb_thread_cond_t *cond, int flags)
static void	native_cond_destroy (rb_thread_cond_t *cond)
static void	rb_thread_wakeup_timer_thread_low (void)
static void	gvl_acquire_common (rb_vm_t *vm)
static void	gvl_acquire (rb_vm_t vm, rb_thread_t th)
static void	gvl_release_common (rb_vm_t *vm)
static void	gvl_release (rb_vm_t *vm)
static void	gvl_yield (rb_vm_t vm, rb_thread_t th)
static void	gvl_init (rb_vm_t *vm)
static void	gvl_destroy (rb_vm_t *vm)
static void	gvl_atfork (rb_vm_t *vm)
static void	mutex_debug (const char msg, pthread_mutex_t lock)
static int	native_cond_timedwait (rb_thread_cond_t cond, pthread_mutex_t mutex, struct timespec *ts)
static struct timespec	native_cond_timeout (rb_thread_cond_t *cond, struct timespec timeout_rel)
static void	null_func (int i)
static rb_thread_t *	ruby_thread_from_native (void)
static int	ruby_thread_set_native (rb_thread_t *th)
static void	native_thread_init (rb_thread_t *th)
void	Init_native_thread (void)
static void	native_thread_destroy (rb_thread_t *th)
static size_t	space_size (size_t stack_size)
void	ruby_init_stack (volatile VALUE *addr)
static int	native_thread_init_stack (rb_thread_t *th)
static void *	thread_start_func_1 (void *th_ptr)
static int	use_cached_thread (rb_thread_t *th)
static int	native_thread_create (rb_thread_t *th)
static void	native_thread_join (pthread_t th)
static int	native_fd_select (int n, rb_fdset_t readfds, rb_fdset_t writefds, rb_fdset_t exceptfds, struct timeval timeout, rb_thread_t *th)
static void	ubf_pthread_cond_signal (void *ptr)
static void	native_sleep (rb_thread_t th, struct timeval timeout_tv)
static void	ping_signal_thread_list (void)
static int	check_signal_thread_list (void)
void	rb_thread_wakeup_timer_thread (void)
static void	timer_thread_sleep (rb_global_vm_lock_t *unused)
static void *	thread_timer (void *p)
static void	rb_thread_create_timer_thread (void)
static int	native_stop_timer_thread (int close_anyway)
static void	native_reset_timer_thread (void)
int	rb_reserved_fd_p (int fd)
Variables
static pthread_t	timer_thread_id
static pthread_key_t	ruby_native_thread_key
struct {
rb_thread_id_t id
size_t stack_maxsize
VALUE * stack_start
}	native_main_thread
static pthread_mutex_t	timer_thread_lock
static rb_thread_cond_t	timer_thread_cond

Define Documentation

#define add_signal_thread_list ( th ) (void)(th)

Definition at line 1153 of file thread_pthread.c.

#define ARRAY_SIZE ( x ) (sizeof(x) / sizeof((x)[0]))

Definition at line 71 of file thread_pthread.c.

#define CHECK_ERR ( expr ) {int err = (expr); if (err) {rb_bug_errno(#expr, err);}}

Definition at line 710 of file thread_pthread.c.

Referenced by native_thread_create(), and native_thread_init_stack().

#define MAINSTACKADDR_AVAILABLE 0

Definition at line 520 of file thread_pthread.c.

#define native_cleanup_pop pthread_cleanup_pop

Definition at line 427 of file thread_pthread.c.

#define native_cleanup_push pthread_cleanup_push

Definition at line 426 of file thread_pthread.c.

#define NATIVE_MUTEX_LOCK_DEBUG 0

Definition at line 191 of file thread_pthread.c.

Referenced by mutex_debug().

#define native_thread_yield ( ) ((void)0)

Definition at line 431 of file thread_pthread.c.

Referenced by gvl_yield().

#define PER_NANO 1000000000

Definition at line 1353 of file thread_pthread.c.

#define RB_CONDATTR_CLOCK_MONOTONIC 1

Definition at line 53 of file thread_pthread.c.

Referenced by gvl_init(), mutex_alloc(), native_cond_initialize(), native_thread_init(), and thread_timer().

#define remove_signal_thread_list ( th ) (void)(th)

Definition at line 1154 of file thread_pthread.c.

Referenced by blocking_region_end().

#define TIME_QUANTUM_USEC (100 * 1000)

Definition at line 1166 of file thread_pthread.c.

Referenced by rb_threadptr_execute_interrupts(), timer_thread_func(), and timer_thread_sleep().

#define TIMET_MAX (~(time_t)0 <= 0 ? (time_t)((~(unsigned_time_t)0) >> 1) : (time_t)(~(unsigned_time_t)0))

Definition at line 379 of file thread_pthread.c.

#define TT_DEBUG 0

Definition at line 1160 of file thread_pthread.c.

Referenced by native_reset_timer_thread(), native_stop_timer_thread(), and thread_timer().

#define ubf_select 0

Definition at line 1155 of file thread_pthread.c.

Referenced by call_without_gvl(), do_select(), rb_thread_blocking_region_begin(), and rb_thread_io_blocking_region().

#define USE_MONOTONIC_COND 0

Definition at line 60 of file thread_pthread.c.

#define USE_NATIVE_THREAD_INIT 1

Definition at line 744 of file thread_pthread.c.

#define USE_SLEEPY_TIMER_THREAD 0

Definition at line 67 of file thread_pthread.c.

#define USE_THREAD_CACHE 0

Definition at line 495 of file thread_pthread.c.

#define WRITE_CONST	(	fd,
		str		)	(void)(write((fd),(str),sizeof(str)-1)<0)

Definition at line 1161 of file thread_pthread.c.

Typedef Documentation

typedef unsigned long unsigned_time_t

Definition at line 370 of file thread_pthread.c.

Enumeration Type Documentation

anonymous enum

Enumerator:

RUBY_STACK_SPACE_LIMIT
RUBY_STACK_SPACE_RATIO

Definition at line 606 of file thread_pthread.c.

Function Documentation

static int check_signal_thread_list ( void ) [static]

Definition at line 1157 of file thread_pthread.c.

static void gvl_acquire	(	rb_vm_t *	vm,
		rb_thread_t *	th
	)			`[static]`

Definition at line 105 of file thread_pthread.c.

References rb_vm_struct::gvl, gvl_acquire_common(), rb_global_vm_lock_struct::lock, native_mutex_lock(), and native_mutex_unlock().

Referenced by blocking_region_end(), gvl_atfork(), Init_Thread(), and thread_start_func_2().

static void gvl_acquire_common ( rb_vm_t * vm ) [static]

Definition at line 75 of file thread_pthread.c.

References rb_global_vm_lock_struct::acquired, rb_global_vm_lock_struct::cond, rb_vm_struct::gvl, rb_global_vm_lock_struct::lock, native_cond_signal(), native_cond_wait(), rb_global_vm_lock_struct::need_yield, rb_thread_wakeup_timer_thread_low(), rb_global_vm_lock_struct::switch_cond, and rb_global_vm_lock_struct::waiting.

Referenced by gvl_acquire(), and gvl_yield().

static void gvl_atfork ( rb_vm_t * vm ) [static]

Definition at line 185 of file thread_pthread.c.

References GET_THREAD(), gvl_acquire(), and gvl_init().

Referenced by rb_thread_atfork_internal().

static void gvl_destroy ( rb_vm_t * vm ) [static]

Definition at line 176 of file thread_pthread.c.

References rb_global_vm_lock_struct::cond, rb_vm_struct::gvl, rb_global_vm_lock_struct::lock, native_cond_destroy(), native_mutex_destroy(), rb_global_vm_lock_struct::switch_cond, and rb_global_vm_lock_struct::switch_wait_cond.

Referenced by rb_vm_gvl_destroy().

static void gvl_init ( rb_vm_t * vm ) [static]

Definition at line 163 of file thread_pthread.c.

References rb_global_vm_lock_struct::acquired, rb_global_vm_lock_struct::cond, rb_vm_struct::gvl, rb_global_vm_lock_struct::lock, native_cond_initialize(), native_mutex_initialize(), rb_global_vm_lock_struct::need_yield, RB_CONDATTR_CLOCK_MONOTONIC, rb_global_vm_lock_struct::switch_cond, rb_global_vm_lock_struct::switch_wait_cond, rb_global_vm_lock_struct::wait_yield, and rb_global_vm_lock_struct::waiting.

Referenced by gvl_atfork(), and Init_Thread().

static void gvl_release ( rb_vm_t * vm ) [static]

Definition at line 121 of file thread_pthread.c.

References rb_vm_struct::gvl, gvl_release_common(), rb_global_vm_lock_struct::lock, native_mutex_lock(), and native_mutex_unlock().

Referenced by blocking_region_begin(), and rb_vm_gvl_destroy().

static void gvl_release_common ( rb_vm_t * vm ) [static]

Definition at line 113 of file thread_pthread.c.

References rb_global_vm_lock_struct::acquired, rb_global_vm_lock_struct::cond, rb_vm_struct::gvl, native_cond_signal(), and rb_global_vm_lock_struct::waiting.

Referenced by gvl_release(), and gvl_yield().

static void gvl_yield	(	rb_vm_t *	vm,
		rb_thread_t *	th
	)			`[static]`

Definition at line 129 of file thread_pthread.c.

References rb_vm_struct::gvl, gvl_acquire_common(), gvl_release_common(), rb_global_vm_lock_struct::lock, native_cond_broadcast(), native_cond_wait(), native_mutex_lock(), native_mutex_unlock(), rb_global_vm_lock_struct::need_yield, rb_global_vm_lock_struct::switch_cond, rb_global_vm_lock_struct::switch_wait_cond, UNLIKELY, rb_global_vm_lock_struct::wait_yield, and rb_global_vm_lock_struct::waiting.

Referenced by rb_thread_schedule_limits().

void Init_native_thread ( void )

Definition at line 466 of file thread_pthread.c.

References GET_THREAD(), native_mutex_initialize(), native_thread_init(), NULL, null_func(), posix_signal(), ruby_native_thread_key, and rb_thread_struct::thread_id.

Referenced by Init_BareVM().

static void mutex_debug	(	const char *	msg,
		pthread_mutex_t *	lock
	)			`[static]`

Definition at line 194 of file thread_pthread.c.

References EXIT_FAILURE, and NATIVE_MUTEX_LOCK_DEBUG.

Referenced by native_mutex_destroy(), native_mutex_initialize(), native_mutex_lock(), native_mutex_trylock(), and native_mutex_unlock().

static void native_cond_broadcast ( rb_thread_cond_t * cond ) [static]

Definition at line 327 of file thread_pthread.c.

References rb_thread_cond_struct::cond, and rb_bug_errno().

Referenced by gvl_yield(), and lock_interrupt().

static void native_cond_destroy ( rb_thread_cond_t * cond ) [static]

Definition at line 294 of file thread_pthread.c.

References rb_thread_cond_struct::cond, and rb_bug_errno().

Referenced by gvl_destroy(), mutex_free(), native_thread_destroy(), and thread_timer().

static void native_cond_initialize	(	rb_thread_cond_t *	cond,
		int	flags
	)			`[static]`

Definition at line 263 of file thread_pthread.c.

References rb_thread_cond_struct::cond, NULL, rb_bug_errno(), and RB_CONDATTR_CLOCK_MONOTONIC.

Referenced by gvl_init(), mutex_alloc(), native_thread_init(), and thread_timer().

static void native_cond_signal ( rb_thread_cond_t * cond ) [static]

Definition at line 315 of file thread_pthread.c.

References rb_thread_cond_struct::cond, and rb_bug_errno().

Referenced by gvl_acquire_common(), gvl_release_common(), rb_mutex_unlock_th(), ubf_pthread_cond_signal(), and use_cached_thread().

static int native_cond_timedwait	(	rb_thread_cond_t *	cond,
		pthread_mutex_t *	mutex,
		struct timespec *	ts
	)			`[static]`

Definition at line 348 of file thread_pthread.c.

References rb_thread_cond_struct::cond, ETIMEDOUT, and rb_bug_errno().

Referenced by lock_func(), native_sleep(), and timer_thread_sleep().

static struct timespec native_cond_timeout	(	rb_thread_cond_t *	cond,
		struct timespec	timeout_rel
	)			`[static, read]`

Definition at line 382 of file thread_pthread.c.

References cond, gettimeofday(), PRIdVALUE, rb_bug(), rb_sys_fail(), SIGNED_VALUE, TIMET_MAX, timeval::tv_sec, and timeval::tv_usec.

Referenced by lock_func(), native_sleep(), and timer_thread_sleep().

static void native_cond_wait	(	rb_thread_cond_t *	cond,
		pthread_mutex_t *	mutex
	)			`[static]`

Definition at line 339 of file thread_pthread.c.

References rb_thread_cond_struct::cond, and rb_bug_errno().

Referenced by gvl_acquire_common(), gvl_yield(), lock_func(), and native_sleep().

static int native_fd_select	(	int	n,
		rb_fdset_t *	readfds,
		rb_fdset_t *	writefds,
		rb_fdset_t *	exceptfds,
		struct timeval *	timeout,
		rb_thread_t *	th
	)			`[static]`