Searched refs:th (Results 1 - 25 of 328) sorted by relevance

1234567891011>>

/macosx-10.10/ruby-106/ruby/
H A Dprobes_helper.h9 #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 Dthread.c86 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 Dcont.c26 * 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 Dthread_win32.c22 #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 Dvm.c73 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 Dsafe.c42 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 Dvm_exec.c34 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 Dvm_eval.c15 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 Dthread_pthread.c105 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 Dvm_dump.c24 #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 Deval.c159 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 Deval_intern.h7 #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 Deval_jump.c64 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 Dvm_insnhelper.c25 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 Dvm_exec.h30 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 Dvm_core.h172 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 Dtest_tcp.rb11 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 Dthwait.rb23 # 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 Ddebug.rb78 # 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 Dcounting.m113 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 Dtcp_cc.h104 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 Dtcp_debug.c110 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 Dslcompress.c186 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 Dtest_backtrace.rb125 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 Dmain.c33 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);

Completed in 896 milliseconds

1234567891011>>