/macosx-10.10/ruby-106/ruby/ |
H A D | probes_helper.h | 9 #define RUBY_DTRACE_HOOK(name, th, klazz, id) \ 18 rb_thread_method_id_and_class((th), &_id, &_klass); \ 55 #define RUBY_DTRACE_METHOD_ENTRY_HOOK(th, klass, id) \ 56 RUBY_DTRACE_HOOK(METHOD_ENTRY, th, klass, id) 58 #define RUBY_DTRACE_METHOD_RETURN_HOOK(th, klass, id) \ 59 RUBY_DTRACE_HOOK(METHOD_RETURN, th, klass, id) 61 #define RUBY_DTRACE_CMETHOD_ENTRY_HOOK(th, klass, id) \ 62 RUBY_DTRACE_HOOK(CMETHOD_ENTRY, th, klass, id) 64 #define RUBY_DTRACE_CMETHOD_RETURN_HOOK(th, klass, id) \ 65 RUBY_DTRACE_HOOK(CMETHOD_RETURN, th, klas [all...] |
H A D | thread.c | 86 static void sleep_timeval(rb_thread_t *th, struct timeval time, int spurious_check); 87 static void sleep_wait_for_interrupt(rb_thread_t *th, double sleepsec, int spurious_check); 88 static void sleep_forever(rb_thread_t *th, int nodeadlock, int spurious_check); 90 static int rb_threadptr_dead(rb_thread_t *th); 92 static int rb_threadptr_pending_interrupt_empty_p(rb_thread_t *th); 115 static int set_unblock_function(rb_thread_t *th, rb_unblock_function_t *func, void *arg, 117 static void reset_unblock_function(rb_thread_t *th, const struct rb_unblock_callback *old); 119 static inline int blocking_region_begin(rb_thread_t *th, struct rb_blocking_region_buffer *region, 121 static inline void blocking_region_end(rb_thread_t *th, struct rb_blocking_region_buffer *region); 124 #define RB_GC_SAVE_MACHINE_REGISTER_STACK(th) \ 293 set_unblock_function(rb_thread_t *th, rb_unblock_function_t *func, void *arg, struct rb_unblock_callback *old, int fail_if_interrupted) argument 322 reset_unblock_function(rb_thread_t *th, const struct rb_unblock_callback *old) argument 330 rb_threadptr_interrupt_common(rb_thread_t *th, int trap) argument 347 rb_threadptr_interrupt(rb_thread_t *th) argument 353 rb_threadptr_trap_interrupt(rb_thread_t *th) argument 362 rb_thread_t *th; local 380 struct rb_thread_struct volatile *th; member in struct:rb_mutex_struct 392 rb_threadptr_unlock_all_locking_mutexes(rb_thread_t *th) argument 411 rb_thread_t *th = GET_THREAD(); /* main thread */ local 445 rb_thread_t *th = th_ptr; local 456 rb_thread_t *th = th_ptr; local 476 ruby_thread_init_stack(rb_thread_t *th) argument 482 thread_start_func_2(rb_thread_t *th, VALUE *stack_start, VALUE *register_stack_start) argument 607 rb_thread_t *th, *current_th = GET_THREAD(); local 666 rb_thread_t *th; local 701 rb_thread_t *th; local 743 rb_thread_t *target_th = p->target, *th = p->waiting; local 764 rb_thread_t *target_th = p->target, *th = p->waiting; local 789 rb_thread_t *th = GET_THREAD(); local 909 rb_thread_t *th; local 940 sleep_forever(rb_thread_t *th, int deadlockable, int spurious_check) argument 980 sleep_timeval(rb_thread_t *th, struct timeval tv, int spurious_check) argument 1053 sleep_wait_for_interrupt(rb_thread_t *th, double sleepsec, int spurious_check) argument 1059 sleep_for_polling(rb_thread_t *th) argument 1070 rb_thread_t *th = GET_THREAD(); local 1078 rb_thread_t *th = GET_THREAD(); local 1111 rb_thread_t *th; local 1127 rb_thread_t *th = GET_THREAD(); local 1153 blocking_region_begin(rb_thread_t *th, struct rb_blocking_region_buffer *region, rb_unblock_function_t *ubf, void *arg, int fail_if_interrupted) argument 1171 blocking_region_end(rb_thread_t *th, struct rb_blocking_region_buffer *region) argument 1187 rb_thread_t *th = GET_THREAD(); local 1197 rb_thread_t *th = ruby_thread_from_native(); local 1210 rb_thread_t *th = GET_THREAD(); local 1336 rb_thread_t *th = GET_THREAD(); local 1405 rb_thread_t *th = ruby_thread_from_native(); local 1447 rb_thread_t *th = ruby_thread_from_native(); local 1491 rb_threadptr_pending_interrupt_clear(rb_thread_t *th) argument 1497 rb_threadptr_pending_interrupt_enque(rb_thread_t *th, VALUE v) argument 1511 rb_threadptr_pending_interrupt_check_mask(rb_thread_t *th, VALUE err) argument 1550 rb_threadptr_pending_interrupt_empty_p(rb_thread_t *th) argument 1556 rb_threadptr_pending_interrupt_include_p(rb_thread_t *th, VALUE err) argument 1569 rb_threadptr_pending_interrupt_deque(rb_thread_t *th, enum handle_interrupt_timing timing) argument 1606 rb_threadptr_pending_interrupt_active_p(rb_thread_t *th) argument 1744 rb_thread_t *th = GET_THREAD(); local 1883 rb_threadptr_to_kill(rb_thread_t *th) argument 1893 rb_threadptr_execute_interrupts(rb_thread_t *th, int blocking_timing) argument 1977 rb_thread_t *th; local 1983 rb_threadptr_ready(rb_thread_t *th) argument 1989 rb_threadptr_raise(rb_thread_t *th, int argc, VALUE *argv) argument 2009 rb_threadptr_signal_raise(rb_thread_t *th, int sig) argument 2019 rb_threadptr_signal_exit(rb_thread_t *th) argument 2033 ruby_thread_stack_overflow(rb_thread_t *th) argument 2045 rb_threadptr_set_raised(rb_thread_t *th) argument 2055 rb_threadptr_reset_raised(rb_thread_t *th) argument 2068 rb_thread_t *th; local 2110 rb_thread_t *th = GET_THREAD(); local 2137 rb_thread_t *th; local 2180 rb_thread_s_kill(VALUE obj, VALUE th) argument 2199 rb_thread_t *th = GET_THREAD(); local 2233 rb_thread_t *th; local 2307 rb_thread_t *th; local 2456 rb_thread_t *th; local 2474 rb_thread_t *th; local 2496 rb_thread_t *th; local 2508 thread_status_name(rb_thread_t *th) argument 2527 rb_threadptr_dead(rb_thread_t *th) argument 2558 rb_thread_t *th; local 2587 rb_thread_t *th; local 2610 rb_thread_t *th; local 2635 rb_thread_t *th; local 2652 rb_thread_t *th; local 2667 rb_thread_t *th; local 2752 rb_thread_t *th; local 2822 rb_thread_t *th; local 2847 rb_thread_t *th; local 2878 rb_thread_t *th; local 2933 rb_thread_t *th; local 3031 rb_thread_t *th; local 3066 rb_thread_t *th; local 3346 rb_thread_t *th = GET_THREAD(); local 3570 rb_thread_t *th = GET_THREAD(); local 3816 rb_thread_t *th = GET_THREAD(); local 3833 rb_thread_t *th; local 3858 rb_thread_t *th; local 3931 rb_thread_t *th; local 4042 rb_thread_t *th; local 4187 mutex_locked(rb_thread_t *th, VALUE self) argument 4225 lock_func(rb_thread_t *th, rb_mutex_t *mutex, int timeout_ms) argument 4291 rb_thread_t *th = GET_THREAD(); local 4368 rb_thread_t *th = GET_THREAD(); local 4380 rb_mutex_unlock_th(rb_mutex_t *mutex, rb_thread_t volatile *th) argument 4433 rb_mutex_abandon_keeping_mutexes(rb_thread_t *th) argument 4442 rb_mutex_abandon_locking_mutex(rb_thread_t *th) argument 4973 rb_thread_t *th = GET_THREAD(); local 5087 rb_thread_t *th = ruby_thread_from_native(); local 5096 rb_thread_t *th; local 5121 rb_thread_t *th; local [all...] |
H A D | cont.c | 26 * in Proc. of 51th Programming Symposium, pp.21--28 (2010) (in Japanese). 97 size_t vm_stack_slen; /* length of stack (head of th->stack) */ 98 size_t vm_stack_clen; /* length of control frames (tail of th->stack) */ 165 #define THREAD_MUST_BE_RUNNING(th) do { \ 166 if (!(th)->tag) rb_raise(rb_eThreadError, "not running thread"); \ 197 rb_thread_t *th; local 199 GetThreadPtr(cont->saved_thread.self, th); 200 if ((th->fiber != cont->self) && fib->status == RUNNING) { 374 cont_save_machine_stack(rb_thread_t *th, rb_context_t *cont) argument 378 SET_MACHINE_STACK_END(&th 423 cont_save_thread(rb_context_t *cont, rb_thread_t *th) argument 438 cont_init(rb_context_t *cont, rb_thread_t *th) argument 450 rb_thread_t *th = GET_THREAD(); local 463 rb_thread_t *th = GET_THREAD(), *sth; local 504 rb_thread_t *th = GET_THREAD(), *sth = &cont->saved_thread; local 554 rb_thread_t *th = GET_THREAD(); local 657 rb_thread_t *th = GET_THREAD(), *sth = &newfib->cont.saved_thread; local 937 rb_thread_t *th = GET_THREAD(); local 1046 rb_thread_t *th = GET_THREAD(); local 1071 rb_thread_t *th = &cont->saved_thread; local 1169 rb_thread_t *th = GET_THREAD(); local 1212 root_fiber_alloc(rb_thread_t *th) argument 1232 rb_thread_t *th = GET_THREAD(); local 1244 rb_thread_t *th = GET_THREAD(); local 1302 rb_thread_t *th = GET_THREAD(); local 1402 rb_thread_t *th; local 1553 rb_thread_t *th = GET_THREAD(); local [all...] |
H A D | thread_win32.c | 22 #define remove_signal_thread_list(th) 26 static int w32_wait_events(HANDLE *events, int count, DWORD timeout, rb_thread_t *th); 96 gvl_acquire(rb_vm_t *vm, rb_thread_t *th) argument 99 if (GVL_DEBUG) fprintf(stderr, "gvl acquire (%p): acquire\n", th); 109 gvl_yield(rb_vm_t *vm, rb_thread_t *th) argument 111 gvl_release(th->vm); 113 gvl_acquire(vm, th); 144 ruby_thread_set_native(rb_thread_t *th) argument 146 return TlsSetValue(ruby_native_thread_key, th); 152 rb_thread_t *th local 185 w32_wait_events(HANDLE *events, int count, DWORD timeout, rb_thread_t *th) argument 302 native_sleep(rb_thread_t *th, struct timeval *tv) argument 579 native_thread_init_stack(rb_thread_t *th) argument 601 native_thread_destroy(rb_thread_t *th) argument 611 rb_thread_t *th = th_ptr; local 629 native_thread_create(rb_thread_t *th) argument 650 native_thread_join(HANDLE th) argument 658 native_thread_apply_priority(rb_thread_t *th) argument 679 native_fd_select(int n, rb_fdset_t *readfds, rb_fdset_t *writefds, rb_fdset_t *exceptfds, struct timeval *timeout, rb_thread_t *th) argument 699 rb_w32_check_interrupt(rb_thread_t *th) argument 707 rb_thread_t *th = (rb_thread_t *)ptr; local 774 rb_thread_t *th = GET_THREAD(); local [all...] |
H A D | vm.c | 73 vm_invoke_proc(rb_thread_t *th, rb_proc_t *proc, VALUE self, VALUE defined_class, 136 vm_set_top_stack(rb_thread_t * th, VALUE iseqval) argument 146 CHECK_VM_STACK_OVERFLOW(th->cfp, iseq->local_size + iseq->stack_max); 147 vm_push_frame(th, iseq, VM_FRAME_MAGIC_TOP | VM_FRAME_FLAG_FINISH, 148 th->top_self, rb_cObject, VM_ENVVAL_BLOCK_PTR(0), 149 iseq->iseq_encoded, th->cfp->sp, iseq->local_size, 0); 153 vm_set_eval_stack(rb_thread_t * th, VALUE iseqval, const NODE *cref, rb_block_t *base_block) argument 158 CHECK_VM_STACK_OVERFLOW(th->cfp, iseq->local_size + iseq->stack_max); 159 vm_push_frame(th, iseq, VM_FRAME_MAGIC_EVAL | VM_FRAME_FLAG_FINISH, 162 th 170 vm_set_main_stack(rb_thread_t *th, VALUE iseqval) argument 189 rb_vm_get_binding_creatable_next_cfp(rb_thread_t *th, const rb_control_frame_t *cfp) argument 201 rb_vm_get_ruby_level_next_cfp(rb_thread_t *th, const rb_control_frame_t *cfp) argument 213 vm_get_ruby_level_caller_cfp(rb_thread_t *th, rb_control_frame_t *cfp) argument 373 vm_make_env_each(rb_thread_t * const th, rb_control_frame_t * const cfp, VALUE *envptr, VALUE * const endptr) argument 477 vm_collect_local_variables_in_heap(rb_thread_t *th, VALUE *ep, VALUE ary) argument 495 rb_vm_make_env_object(rb_thread_t * th, rb_control_frame_t *cfp) argument 502 vm_make_env_object(rb_thread_t *th, rb_control_frame_t *cfp, VALUE *blockprocptr) argument 527 vm_rewrite_ep_in_errinfo(rb_thread_t *th) argument 553 rb_vm_stack_to_heap(rb_thread_t *th) argument 565 vm_make_proc_from_block(rb_thread_t *th, rb_block_t *block) argument 574 rb_vm_make_proc(rb_thread_t *th, const rb_block_t *block, VALUE klass) argument 612 invoke_block_from_c(rb_thread_t *th, const rb_block_t *block, VALUE self, int argc, const VALUE *argv, const rb_block_t *blockptr, const NODE *cref, VALUE defined_class) argument 656 check_block(rb_thread_t *th) argument 668 vm_yield_with_cref(rb_thread_t *th, int argc, const VALUE *argv, const NODE *cref) argument 676 vm_yield(rb_thread_t *th, int argc, const VALUE *argv) argument 684 vm_invoke_proc(rb_thread_t *th, rb_proc_t *proc, VALUE self, VALUE defined_class, int argc, const VALUE *argv, const rb_block_t *blockptr) argument 712 rb_vm_invoke_proc(rb_thread_t *th, rb_proc_t *proc, int argc, const VALUE *argv, const rb_block_t *blockptr) argument 722 vm_normal_frame(rb_thread_t *th, rb_control_frame_t *cfp) argument 734 vm_cfp_svar_get(rb_thread_t *th, rb_control_frame_t *cfp, VALUE key) argument 741 vm_cfp_svar_set(rb_thread_t *th, rb_control_frame_t *cfp, VALUE key, const VALUE val) argument 750 rb_thread_t *th = GET_THREAD(); local 757 rb_thread_t *th = GET_THREAD(); local 790 rb_thread_t *th = GET_THREAD(); local 804 rb_thread_t *th = GET_THREAD(); local 818 rb_thread_t *th = GET_THREAD(); local 832 rb_thread_t *th = GET_THREAD(); local 856 rb_thread_t *th = GET_THREAD(); local 949 vm_iter_break(rb_thread_t *th, VALUE val) argument 1190 vm_exec(rb_thread_t *th) argument 1431 rb_thread_t *th = GET_THREAD(); local 1444 rb_thread_t *th = GET_THREAD(); local 1483 rb_thread_method_id_and_class(rb_thread_t *th, ID *idp, VALUE *klassp) argument 1495 rb_thread_current_status(const rb_thread_t *th) argument 1522 rb_thread_t *th = GET_THREAD(); local 1600 rb_thread_t *th = vm->main_thread; local 1790 rb_thread_t *th = NULL; local 1859 rb_thread_t *th; local 1901 const rb_thread_t *th = ptr; local 1943 rb_thread_t *th = thread_recycle_struct(); local 1946 rb_thread_t *th; local 1953 th_init(rb_thread_t *th, VALUE self) argument 1987 rb_thread_t *th; local 2010 vm_define_method(rb_thread_t *th, VALUE obj, ID id, VALUE iseqval, rb_num_t is_singleton, NODE *cref) argument 2339 rb_thread_t *th = GET_THREAD(); local 2383 rb_thread_t *th = GET_VM()->main_thread; local 2398 rb_thread_t * th = ruby_mimmalloc(sizeof(*th)); local [all...] |
H A D | safe.c | 42 rb_thread_t *th = GET_THREAD(); local 44 if (level > th->safe_level) { 48 th->safe_level = level; 62 rb_thread_t *th = GET_THREAD(); local 64 if (level < th->safe_level) { 67 th->safe_level, level); 75 th->safe_level = level;
|
H A D | vm_exec.c | 34 vm_exec_core(rb_thread_t *th, VALUE initial) argument 68 REG_CFP = th->cfp; \ 82 if (UNLIKELY(th == 0)) { 86 reg_cfp = th->cfp; 124 vm_exec_core(rb_thread_t *th, VALUE initial) argument 126 register rb_control_frame_t *reg_cfp = th->cfp; 129 reg_cfp = ((rb_insn_func_t) (*GET_PC()))(th, reg_cfp); 136 if (th->retval != Qundef) { 137 VALUE ret = th->retval; 138 th [all...] |
H A D | vm_eval.c | 15 static inline VALUE vm_yield_with_cref(rb_thread_t *th, int argc, const VALUE *argv, const NODE *cref); 16 static inline VALUE vm_yield(rb_thread_t *th, int argc, const VALUE *argv); 17 static NODE *vm_cref_push(rb_thread_t *th, VALUE klass, int noex, rb_block_t *blockptr); 18 static VALUE vm_exec(rb_thread_t *th); 19 static void vm_set_eval_stack(rb_thread_t * th, VALUE iseqval, const NODE *cref, rb_block_t *base_block); 20 static int vm_collect_local_variables_in_heap(rb_thread_t *th, VALUE *dfp, VALUE ary); 23 VALUE vm_backtrace_str_ary(rb_thread_t *th, int lev, int n); 34 static VALUE vm_call0_body(rb_thread_t* th, rb_call_info_t *ci, const VALUE *argv); 37 vm_call0(rb_thread_t* th, VALUE recv, ID id, int argc, const VALUE *argv, argument 49 return vm_call0_body(th, c 54 vm_call0_cfunc(rb_thread_t* th, rb_call_info_t *ci, const VALUE *argv) argument 94 vm_call0_cfunc_with_frame(rb_thread_t* th, rb_call_info_t *ci, const VALUE *argv) argument 132 vm_call0_cfunc(rb_thread_t* th, rb_call_info_t *ci, const VALUE *argv) argument 140 vm_call0_body(rb_thread_t* th, rb_call_info_t *ci, const VALUE *argv) argument 243 rb_vm_call(rb_thread_t *th, VALUE recv, VALUE id, int argc, const VALUE *argv, const rb_method_entry_t *me, VALUE defined_class) argument 250 vm_call_super(rb_thread_t *th, int argc, const VALUE *argv) argument 282 rb_thread_t *th = GET_THREAD(); local 317 rb_thread_t *th = GET_THREAD(); local 355 check_funcall_respond_to(rb_thread_t *th, VALUE klass, VALUE recv, ID mid) argument 382 check_funcall_callable(rb_thread_t *th, const rb_method_entry_t *me) argument 388 check_funcall_missing(rb_thread_t *th, VALUE klass, VALUE recv, ID mid, int argc, VALUE *argv) argument 412 rb_thread_t *th = GET_THREAD(); local 432 rb_thread_t *th = GET_THREAD(); local 526 rb_method_call_status(rb_thread_t *th, const rb_method_entry_t *me, call_type scope, VALUE self) argument 583 rb_thread_t *th = GET_THREAD(); local 626 rb_thread_t *th = GET_THREAD(); local 658 raise_method_missing(rb_thread_t *th, int argc, const VALUE *argv, VALUE obj, int last_call_status) argument 697 rb_thread_t *th = GET_THREAD(); local 728 rb_raise_method_missing(rb_thread_t *th, int argc, VALUE *argv, VALUE obj, int call_status) argument 836 rb_thread_t *th = GET_THREAD(); local 855 rb_thread_t *th = GET_THREAD(); local 1037 rb_thread_t *th = GET_THREAD(); local 1176 rb_thread_t *th = GET_THREAD(); local 1429 rb_thread_t *th = GET_THREAD(); local 1495 rb_thread_t *th = GET_THREAD(); local 1518 rb_thread_t *th = GET_THREAD(); local 1732 rb_thread_t *th = GET_THREAD(); local 1827 rb_thread_t *th = GET_THREAD(); local 1868 rb_thread_t *th = GET_THREAD(); local 1931 rb_thread_t *th = GET_THREAD(); local 1946 rb_thread_t *th = GET_THREAD(); local [all...] |
H A D | thread_pthread.c | 105 gvl_acquire(rb_vm_t *vm, rb_thread_t *th) argument 129 gvl_yield(rb_vm_t *vm, rb_thread_t *th) argument 438 static void add_signal_thread_list(rb_thread_t *th); 439 static void remove_signal_thread_list(rb_thread_t *th); 458 ruby_thread_set_native(rb_thread_t *th) argument 460 return pthread_setspecific(ruby_native_thread_key, th) == 0; 463 static void native_thread_init(rb_thread_t *th); 468 rb_thread_t *th = GET_THREAD(); local 471 th->thread_id = pthread_self(); 472 native_thread_init(th); 482 native_thread_init(rb_thread_t *th) argument 489 native_thread_destroy(rb_thread_t *th) argument 714 native_thread_init_stack(rb_thread_t *th) argument 754 rb_thread_t *th = th_ptr; local 773 rb_thread_t *th; local 851 use_cached_thread(rb_thread_t *th) argument 877 native_thread_create(rb_thread_t *th) argument 921 native_thread_join(pthread_t th) argument 933 native_thread_apply_priority(rb_thread_t *th) argument 961 native_fd_select(int n, rb_fdset_t *readfds, rb_fdset_t *writefds, rb_fdset_t *exceptfds, struct timeval *timeout, rb_thread_t *th) argument 969 rb_thread_t *th = (rb_thread_t *)ptr; local 975 native_sleep(rb_thread_t *th, struct timeval *timeout_tv) argument 1031 rb_thread_t *th; member in struct:signal_thread_list 1064 add_signal_thread_list(rb_thread_t *th) argument 1090 remove_signal_thread_list(rb_thread_t *th) argument 1110 ubf_select_each(rb_thread_t *th) argument 1121 rb_thread_t *th = (rb_thread_t *)ptr; local 1497 ruby_stack_overflowed_p(const rb_thread_t *th, const void *addr) argument [all...] |
H A D | vm_dump.c | 24 #define VM_CFP_CNT(th, cfp) \ 25 ((rb_control_frame_t *)((th)->stack + (th)->stack_size) - (rb_control_frame_t *)(cfp)) 28 control_frame_dump(rb_thread_t *th, rb_control_frame_t *cfp) argument 31 ptrdiff_t ep = cfp->ep - th->stack; 43 if (ep < 0 || (size_t)ep > th->stack_size) { 112 ((rb_control_frame_t *)(th->stack + th->stack_size) - cfp)); 119 fprintf(stderr, "s:%04"PRIdPTRDIFF" ", cfp->sp - th->stack); 138 rb_vmdebug_stack_dump_raw(rb_thread_t *th, rb_control_frame_ argument 172 rb_thread_t *th = GET_THREAD(); local 219 rb_thread_t *th; local 240 vm_stack_dump_each(rb_thread_t *th, rb_control_frame_t *cfp) argument 323 rb_vmdebug_debug_print_register(rb_thread_t *th) argument 346 rb_thread_t *th; local 352 rb_vmdebug_debug_print_pre(rb_thread_t *th, rb_control_frame_t *cfp) argument 378 rb_vmdebug_debug_print_post(rb_thread_t *th, rb_control_frame_t *cfp , VALUE reg_a, VALUE reg_b ) argument 415 rb_thread_t *th; local 514 HANDLE th; local 663 HANDLE th = (HANDLE)_beginthread(dump_thread, 0, &tid); local [all...] |
H A D | eval.c | 159 rb_thread_t *th = GET_THREAD(); local 162 rb_threadptr_interrupt(th); 163 rb_threadptr_check_signal(th); 166 SAVE_ROOT_JMPBUF(th, { RUBY_VM_CHECK_INTS(th); }); 170 errs[1] = th->errinfo; 171 th->safe_level = 0; 176 SAVE_ROOT_JMPBUF(th, ruby_finalize_0()); 181 th->status = THREAD_KILLED; 183 errs[0] = th 244 rb_thread_t *th = GET_THREAD(); local 428 setup_exception(rb_thread_t *th, int tag, volatile VALUE mesg) argument 518 rb_thread_t *th = GET_THREAD(); local 650 rb_thread_t *th = GET_THREAD(); local 674 rb_thread_t *th = GET_THREAD(); local 705 rb_thread_t *th = GET_THREAD(); local 775 rb_thread_t *th = GET_THREAD(); local 809 rb_thread_t *const th = GET_THREAD(); local 829 rb_thread_t *th = GET_THREAD(); local 908 previous_frame(rb_thread_t *th) argument 937 rb_thread_t *th = GET_THREAD(); local 1185 rb_thread_t *th = GET_THREAD(); local 1329 rb_thread_t *th = GET_THREAD(); local 1364 errinfo_place(rb_thread_t *th) argument 1386 get_thread_errinfo(rb_thread_t *th) argument 1431 rb_thread_t *th = GET_THREAD(); local [all...] |
H A D | eval_intern.h | 7 #define PASS_PASSED_BLOCK_TH(th) do { \ 8 (th)->passed_block = rb_vm_control_frame_block_ptr(th->cfp); \ 9 (th)->cfp->flag |= VM_FRAME_FLAG_PASSED; \ 86 #define SAVE_ROOT_JMPBUF(th, stmt) do \ 87 if (ruby_setjmp((th)->root_jmpbuf) == 0) { \ 94 #define TH_PUSH_TAG(th) do { \ 95 rb_thread_t * const _th = (th); \ 116 #define TH_JUMP_TAG(th, st) do { \ 117 ruby_longjmp((th) [all...] |
H A D | eval_jump.c | 64 rb_thread_t *th = GET_THREAD(); local 66 if (th->top_wrapper) { 103 rb_thread_t *th = GET_THREAD(); local 104 volatile VALUE errinfo = th->errinfo; 121 if (!NIL_P(th->errinfo)) errinfo = th->errinfo; 140 if (!NIL_P(th->errinfo)) errinfo = th->errinfo; 145 th->errinfo = errinfo;
|
H A D | vm_insnhelper.c | 25 static rb_control_frame_t *vm_get_ruby_level_caller_cfp(rb_thread_t *th, rb_control_frame_t *cfp); 34 vm_push_frame(rb_thread_t *th, argument 45 rb_control_frame_t *const cfp = th->cfp - 1; 52 th->cfp = cfp; 83 if (RUBY_VM_CONTROL_FRAME_STACK_OVERFLOW_P(th, prev_cfp)) { 99 vm_pop_frame(rb_thread_t *th) argument 101 th->cfp = RUBY_VM_PREVIOUS_CONTROL_FRAME(th->cfp); 172 lep_svar_place(rb_thread_t *th, VALUE *lep) argument 176 if (lep && th 189 lep_svar_get(rb_thread_t *th, VALUE *lep, rb_num_t key) argument 212 lep_svar_set(rb_thread_t *th, VALUE *lep, rb_num_t key, VALUE val) argument 235 vm_getspecial(rb_thread_t *th, VALUE *lep, rb_num_t key, rb_num_t type) argument 297 vm_cref_push(rb_thread_t *th, VALUE klass, int noex, rb_block_t *blockptr) argument 378 vm_get_ev_const(rb_thread_t *th, const rb_iseq_t *iseq, VALUE orig_klass, ID id, int is_defined) argument 611 vm_throw(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_num_t throw_state, VALUE throwobj) argument 1012 vm_caller_setup_args(const rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1138 vm_callee_setup_arg_complex(rb_thread_t *th, rb_call_info_t *ci, const rb_iseq_t *iseq, VALUE *orig_argv) argument 1235 vm_callee_setup_arg(rb_thread_t *th, rb_call_info_t *ci, const rb_iseq_t *iseq, VALUE *argv, int is_lambda) argument 1258 vm_call_iseq_setup(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1265 vm_call_iseq_setup_2(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1276 vm_call_iseq_setup_normal(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1299 vm_call_iseq_setup_tailcall(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1467 vm_call_cfunc_with_frame(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1506 vm_call_cfunc_latter(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1538 vm_call_cfunc(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1563 vm_call_cfunc_push_frame(rb_thread_t *th) argument 1578 vm_call_cfunc(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1585 vm_call_ivar(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1593 vm_call_attrset(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1601 vm_call_bmethod_body(rb_thread_t *th, rb_call_info_t *ci, const VALUE *argv) argument 1621 vm_call_bmethod(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1639 vm_call_opt_send(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1681 vm_call_opt_call(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1694 vm_call_method_missing(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1731 current_method_entry(rb_thread_t *th, rb_control_frame_t *cfp) argument 1755 vm_call_method(rb_thread_t *th, rb_control_frame_t *cfp, rb_call_info_t *ci) argument 1927 vm_call_general(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1933 vm_call_super_method(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 1980 rb_thread_t *th = GET_THREAD(); local 2009 vm_search_super_method(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument 2082 vm_yield_with_cfunc(rb_thread_t *th, const rb_block_t *block, VALUE self, int argc, const VALUE *argv, const rb_block_t *blockargptr) argument 2128 vm_yield_setup_block_args_complex(rb_thread_t *th, const rb_iseq_t *iseq, int argc, VALUE *argv) argument 2185 vm_yield_setup_block_args(rb_thread_t *th, const rb_iseq_t * iseq, int orig_argc, VALUE *argv, const rb_block_t *blockptr) argument 2296 vm_yield_setup_args(rb_thread_t * const th, const rb_iseq_t *iseq, int argc, VALUE *argv, const rb_block_t *blockptr, int lambda) argument 2325 vm_invoke_block(rb_thread_t *th, rb_control_frame_t *reg_cfp, rb_call_info_t *ci) argument [all...] |
H A D | vm_exec.h | 30 rb_vmdebug_debug_print_pre(th, GET_CFP()); 39 rb_vmdebug_debug_print_post(th, GET_CFP() SC_REGS()); 63 FUNC_FASTCALL(LABEL(insn))(rb_thread_t *th, rb_control_frame_t *reg_cfp) { 160 #define VM_SP_CNT(th, sp) ((sp) - (th)->stack) 164 th->errinfo = (VALUE)(exc); \
|
H A D | vm_core.h | 172 VALUE (*call)(struct rb_thread_struct *th, struct rb_control_frame_struct *cfp, struct rb_call_info_struct *ci); 489 struct rb_thread_struct *th; member in struct:rb_thread_list_struct 789 #define RUBY_VM_END_CONTROL_FRAME(th) \ 790 ((rb_control_frame_t *)((th)->stack + (th)->stack_size)) 793 #define RUBY_VM_CONTROL_FRAME_STACK_OVERFLOW_P(th, cfp) \ 794 (!RUBY_VM_VALID_CONTROL_FRAME_P((cfp), RUBY_VM_END_CONTROL_FRAME(th))) 811 extern void rb_vmdebug_debug_print_pre(rb_thread_t *th, rb_control_frame_t *cfp); 812 extern void rb_vmdebug_debug_print_post(rb_thread_t *th, rb_control_frame_t *cfp); 827 int rb_thread_method_id_and_class(rb_thread_t *th, I 885 rb_thread_t *th = ruby_current_thread; local 957 rb_thread_t *th; member in struct:rb_trace_arg_struct [all...] |
/macosx-10.10/ruby-106/ruby/test/socket/ |
H A D | test_tcp.rb | 11 th = Thread.new { 20 th.kill if th 21 th.join if th 26 th = Thread.new { 38 th.kill if th 39 th.join if th [all...] |
/macosx-10.10/ruby-106/ruby/lib/ |
H A D | thwait.rb | 23 # th = ThreadsWait.new(thread1,...) 24 # th.next_wait # next one to be done 41 tw.all_waits do |th| 42 yield th 92 for th in threads 93 Thread.start(th) do |t| 113 @threads.delete(th = @wait_queue.pop(nonblock)) 114 th 128 th = next_wait 129 yield th i [all...] |
H A D | debug.rb | 78 # th[read] l[ist] list all threads 79 # th[read] c[ur[rent]] show current thread 80 # th[read] [sw[itch]] <nnn> switch thread context to nnn 81 # th[read] stop <nnn> stop thread nnn 82 # th[read] resume <nnn> resume thread nnn 274 def context(th) 275 DEBUGGER__.context(th) 282 def set_last_thread(th) 283 DEBUGGER__.set_last_thread(th) 643 when /^\s*th( [all...] |
/macosx-10.10/libclosure-65/objectTests/ |
H A D | counting.m | 113 pthread_t th; 115 pthread_create(&th, NULL, testsingle, NULL); 116 pthread_join(th, NULL); 117 pthread_create(&th, NULL, testsingle, NULL); 118 pthread_join(th, NULL); 119 pthread_create(&th, NULL, testsingle, NULL); 120 pthread_join(th, NULL); 121 pthread_create(&th, NULL, testsingle, NULL); 122 pthread_join(th, NULL); 125 pthread_create(&th, NUL [all...] |
/macosx-10.10/xnu-2782.1.97/bsd/netinet/ |
H A D | tcp_cc.h | 104 void (*congestion_avd) (struct tcpcb *tp, struct tcphdr *th); 107 void (*ack_rcvd) (struct tcpcb *tp, struct tcphdr *th); 113 void (*post_fr) (struct tcpcb *tp, struct tcphdr *th); 122 int (*delay_ack)(struct tcpcb *tp, struct tcphdr *th); 140 extern int tcp_cc_delay_ack(struct tcpcb *tp, struct tcphdr *th); 141 extern void tcp_ccdbg_trace(struct tcpcb *tp, struct tcphdr *th,
|
H A D | tcp_debug.c | 110 tcp_trace(act, ostate, tp, ipgen, th, req) 114 struct tcphdr *th; 167 if (th) { 170 td->td_ti.ti_t = *th; 171 bzero((caddr_t)&td->td_ti6.th, sizeof(td->td_ti6.th)); 175 td->td_ti6.th = *th; 183 bzero((caddr_t)&td->td_ti6.th, sizeof(td->td_ti6.th)); [all...] |
/macosx-10.10/ppp-786.1.1/Family/ |
H A D | slcompress.c | 186 register struct tcphdr *th; local 201 th = (struct tcphdr *)&((int32_t *)ip)[hlen]; 202 if ((th->th_flags & (TH_SYN|TH_FIN|TH_RST|TH_ACK)) != TH_ACK) 214 *(int32_t *)th != ((int32_t *)&cs->cs_ip)[cs->cs_ip.ip_hl]) { 235 && *(int32_t *)th == 250 hlen += th->th_off; 274 * check is unnecessary but costless). The 4th line checks the TCP 275 * header length. The 5th line checks IP options, if any. The 6th 282 hlen += th 502 register struct tcphdr *th; local [all...] |
/macosx-10.10/ruby-106/ruby/test/ruby/ |
H A D | test_backtrace.rb | 125 th = Thread.new{ 129 th_backtrace = th.backtrace 130 th_locations = th.backtrace_locations 134 assert_equal(th_backtrace, th.backtrace(0)) 136 th.backtrace_locations(0).map{|e| e.to_s}) 138 assert_equal(n, th.backtrace(0, n).size) 139 assert_equal(n, th.backtrace_locations(0, n).size) 142 assert_equal(n, th.backtrace(0, n + 1).size) 143 assert_equal(n, th.backtrace_locations(0, n + 1).size) 152 th [all...] |
/macosx-10.10/dyld-353.2.1/unit-tests/test-cases/tlv-terminators/ |
H A D | main.c | 33 pthread_t th; member in struct:thread_var_info 60 if ( thread1.th == self && thread1.a_addr == objAddr ) 62 else if ( thread1.th == self && thread1.b_addr == objAddr ) 64 else if ( thread2.th == self && thread2.a_addr == objAddr ) 66 else if ( thread2.th == self && thread2.b_addr == objAddr ) 68 else if ( threadmain.th == self && threadmain.a_addr == objAddr ) 70 else if ( threadmain.th == self && threadmain.b_addr == objAddr ) 85 s->th = pthread_self(); 90 //fprintf(stderr, "self=%p, arg=%p, &a=%p, &b=%p\n", s->th, arg, s->a_addr , s->b_addr);
|