/dragonfly/sys/kern/ |
H A D | lwkt_thread.c | 309 KASSERT(td != &td->td_gd->gd_idlethread, in lwkt_schedule_self() 455 td->td_toks_stop = &td->td_toks_base; in lwkt_init_thread() 457 lwkt_initport_spin(&td->td_msgport, td, in lwkt_init_thread() 460 lwkt_initport_thread(&td->td_msgport, td); in lwkt_init_thread() 488 KTR_LOG(ctxsw_newtd, td, td->td_comm); in lwkt_set_comm() 604 "thread %p (%s)\n", td, td->td_comm); in lwkt_switch() 632 td->td_release(td); in lwkt_switch() 656 td); in lwkt_switch() 1403 td, td->td_flags); in lwkt_acquire() 1571 td->td_release(td); in lwkt_setcpu_self() [all …]
|
H A D | lwkt_token.c | 235 ref->tr_owner = td; in _lwkt_tokref_init() 350 td->td_toks_stop != &td->td_toks_base + 1) in _lwkt_trytokref() 488 for (scan = &td->td_toks_base; scan < td->td_toks_stop; ++scan) { in lwkt_getalltokens() 662 ++td->td_toks_stop; in lwkt_gettoken() 703 td->td_toks_have = td->td_toks_stop - 1; in lwkt_gettoken() 709 tok, td, tok->t_desc, td->td_comm); in lwkt_gettoken() 733 ++td->td_toks_stop; in lwkt_gettoken_shared() 767 td->td_toks_have = td->td_toks_stop - 1; in lwkt_gettoken_shared() 773 tok, td, tok->t_desc, td->td_comm); in lwkt_gettoken_shared() 844 td, tok, &td->td_toks_base, ref); in lwkt_reltoken() [all …]
|
H A D | kern_kthread.c | 49 thread_t td; in _kthread_create() local 54 *tdp = td; in _kthread_create() 60 kvsnprintf(td->td_comm, sizeof(td->td_comm), fmt, ap); in _kthread_create() 68 lwkt_schedule(td); in _kthread_create() 131 thread_t td; 136 *tdp = td; 140 kvsnprintf(td->td_comm, sizeof(td->td_comm), fmt, ap); 143 lwkt_schedule(td); 194 wakeup(td); in suspend_kproc() 217 wakeup(td); in kproc_suspend_loop() [all …]
|
H A D | kern_synch.c | 447 crit_exit_quick(td); in _tsleep_interlock() 468 KKASSERT(td->td_gd == gd && IN_CRITICAL_SECT(td)); in _tsleep_remove() 488 _tsleep_remove(td); in tsleep_remove() 553 gd = td->td_gd; in tsleep() 771 _tsleep_remove(td); in tsleep() 937 thread_t td = arg; in endtsleep() local 1002 struct thread *td; in _wakeup() local 1017 for (td = TAILQ_FIRST(&qp->queue); td != NULL; td = ntd) { in _wakeup() 1153 if (td && (td->td_flags & TDF_DELAYED_WAKEUP)) { in wakeup() 1439 thread_t td; in loadav_count_runnable() local [all …]
|
H A D | subr_sleepqueue.c | 273 td = curthread; in sleepq_add() 282 td->td_sqwc = wc; in sleepq_add() 297 td = curthread; in sleepq_set_timeout_sbt() 298 wc = td->td_sqwc; in sleepq_set_timeout_sbt() 331 ret = tsleep(td->td_wchan, tflags, td->td_wmesg, timo); in _sleepq_wait_begin() 336 ret = tsleep(td->td_wchan, tflags, td->td_wmesg, 0); in _sleepq_wait_begin() 393 td = curthread; in sleepq_wait() 410 td = curthread; in sleepq_wait_sig() 429 td = curthread; in sleepq_timedwait() 448 td = curthread; in sleepq_timedwait_sig() [all …]
|
H A D | kern_lock.c | 81 #define COUNT(td, x) (td)->td_locks += (x) argument 110 thread_t td; in lockmgr_shared() local 119 td = curthread; in lockmgr_shared() 143 COUNT(td, 1); in lockmgr_shared() 289 thread_t td; in lockmgr_exclusive() local 504 thread_t td; in lockmgr_downgrade() local 581 thread_t td; in lockmgr_upgrade() local 748 thread_t td; in lockmgr_release() local 778 (td->td_proc ? td->td_proc->p_pid : -1), in lockmgr_release() 1349 if (td == NULL || lkp->lk_lockholder == td) in lockstatus() [all …]
|
H A D | kern_iosched.c | 66 badjiosched(thread_t td, size_t bytes) in badjiosched() argument 79 td->td_iosdata.iowbytes += bytes; in badjiosched() 82 delta = ticks - td->td_iosdata.lastticks; in badjiosched() 84 td->td_iosdata.lastticks = ticks; in badjiosched() 89 td->td_iosdata.iowbytes -= bytes; in badjiosched() 102 td->td_comm, in badjiosched() 103 (td->td_lwp ? (int)td->td_lwp->lwp_proc->p_pid : -1), in badjiosched() 104 factor, td->td_iosdata.iowbytes, iostotal); in badjiosched() 110 biosched_done(thread_t td) in biosched_done() argument 115 if ((bytes = td->td_iosdata.iowbytes) != 0) { in biosched_done() [all …]
|
H A D | kern_umtx.c | 119 thread_t td; in sys_umtx_sleep() local 124 td = curthread; in sys_umtx_sleep() 141 uptr, td->td_comm, in sys_umtx_sleep() 142 (int)td->td_proc->p_pid, in sys_umtx_sleep() 152 uptr, td->td_comm, in sys_umtx_sleep() 153 (int)td->td_proc->p_pid, in sys_umtx_sleep() 259 thread_t td; in sys_umtx_wakeup() local 261 td = curthread; in sys_umtx_wakeup() 280 uptr, td->td_comm, in sys_umtx_wakeup() 291 uptr, td->td_comm, in sys_umtx_wakeup() [all …]
|
/dragonfly/sys/ddb/ |
H A D | db_ps.c | 106 thread_t td; in db_ps() local 138 td, in db_ps() 139 (td->td_proc ? td->td_proc->p_pid : -1), in db_ps() 143 td->td_sp, in db_ps() 144 td->td_wmesg ? td->td_wmesg : "-", in db_ps() 146 td->td_proc ? td->td_proc->p_comm : td->td_comm); in db_ps() 163 np, td, in db_ps() 164 (td->td_proc ? td->td_proc->p_pid : -1), in db_ps() 168 td->td_sp, in db_ps() 169 td->td_wmesg ? td->td_wmesg : "-", in db_ps() [all …]
|
/dragonfly/sys/netinet/ |
H A D | tcp_debug.c | 108 bzero(td->td_ip6buf, sizeof td->td_ip6buf); in tcp_trace() 113 bzero(&td->td_ti.ti_i, sizeof td->td_ti.ti_i); in tcp_trace() 117 bzero(td->td_ip6buf, sizeof td->td_ip6buf); in tcp_trace() 118 bzero(&td->td_ti.ti_i, sizeof td->td_ti.ti_i); in tcp_trace() 122 bzero(&td->td_ti.ti_i, sizeof td->td_ti.ti_i); in tcp_trace() 123 bzero(td->td_ip6buf, sizeof td->td_ip6buf); in tcp_trace() 129 bzero(&td->td_ti6.th, sizeof td->td_ti6.th); in tcp_trace() 134 bzero(&td->td_ti.ti_t, sizeof td->td_ti.ti_t); in tcp_trace() 139 bzero(&td->td_ti6.th, sizeof td->td_ti6.th); in tcp_trace() 143 bzero(&td->td_ti.ti_t, sizeof td->td_ti.ti_t); in tcp_trace() [all …]
|
/dragonfly/sys/sys/ |
H A D | thread2.h | 38 crit_enter_raw(thread_t td) in crit_enter_raw() argument 41 ++td->td_critcount; in crit_enter_raw() 46 crit_exit_raw(thread_t td) in crit_exit_raw() argument 49 --td->td_critcount; in crit_exit_raw() 65 if (tok->t_ref >= &td->td_toks_base && tok->t_ref < td->td_toks_stop) in _lwkt_token_held_any() 91 #define __DEBUG_CRIT_ENTER(td) _debug_crit_enter((td), id) argument 92 #define __DEBUG_CRIT_EXIT(td) _debug_crit_exit((td), id) argument 184 crit_enter_raw(td); in _crit_enter_quick() 219 crit_exit_raw(td); in _crit_exit_noyield() 231 lwkt_maybe_splz(td); in _crit_exit_quick() [all …]
|
/dragonfly/sys/platform/pc64/x86_64/ |
H A D | npx.c | 360 thread_t td; in npxdna() local 404 md->gd_npxthread = td; in npxdna() 422 td->td_comm, td->td_savefpu->sv_xmm.sv_env.en_mxcsr, in npxdna() 425 lwpsignal(td->td_proc, td->td_lwp, SIGFPE); in npxdna() 514 thread_t td = curthread; in npxpush() local 529 bcopy(td->td_savefpu, mctx->mc_fpregs, sizeof(*td->td_savefpu)); in npxpush() 554 thread_t td = curthread; in npxpop() local 588 bcopy(mctx->mc_fpregs, td->td_savefpu, sizeof(*td->td_savefpu)); in npxpop() 612 thread_t td = curthread; in kernel_fpu_begin() local 618 td->td_kfpuctx = kmalloc(sizeof(*td->td_kfpuctx), M_FPUCTX, in kernel_fpu_begin() [all …]
|
H A D | trap.c | 410 p = td->td_proc; in trap() 462 td->td_comm, in trap() 477 userenter(td, p); in trap() 831 td->td_toks_stop - &td->td_toks_base, in trap() 839 userenter(td, td->td_proc); in trap_handle_userenter() 1003 p = td->td_proc; in trap_pfault() 1372 crit_count, td->td_critcount, td->td_comm, code)); in syscall2() 1373 KASSERT(&td->td_toks_base == td->td_toks_stop, in syscall2() 1375 td->td_toks_stop - &td->td_toks_base, in syscall2() 1398 td = curthread; in sys_xsyscall() [all …]
|
H A D | vm_machdep.c | 308 pcb = td->td_pcb; in cpu_lwp_exit() 322 crit_enter_quick(td); in cpu_lwp_exit() 324 tsleep_remove(td); in cpu_lwp_exit() 325 lwkt_deschedule_self(td); in cpu_lwp_exit() 326 lwkt_remove_tdallq(td); in cpu_lwp_exit() 1304 KKASSERT(td->td_lwp); 1312 (char *)frame > td->td_kstack + td->td_kstack_size) { 1324 KKASSERT(td->td_lwp); 1330 td->td_comm, td->td_proc->p_pid, 1336 td->td_comm, td->td_proc->p_pid, [all …]
|
H A D | tls.c | 160 thread_t td = gd->mi.gd_curthread; in set_user_TLS() local 162 crit_enter_quick(td); in set_user_TLS() 163 td->td_pcb->pcb_fsbase = (register_t)td->td_tls.info[0].base; in set_user_TLS() 164 td->td_pcb->pcb_gsbase = (register_t)td->td_tls.info[1].base; in set_user_TLS() 165 if (gd->gd_user_fs != td->td_pcb->pcb_fsbase) { in set_user_TLS() 166 gd->gd_user_fs = td->td_pcb->pcb_fsbase; in set_user_TLS() 169 if (gd->gd_user_gs != td->td_pcb->pcb_gsbase) { in set_user_TLS() 170 gd->gd_user_gs = td->td_pcb->pcb_gsbase; in set_user_TLS() 175 crit_exit_quick(td); in set_user_TLS()
|
/dragonfly/usr.sbin/trpt/ |
H A D | trpt.c | 231 tcp_trace(td->td_act, td->td_ostate, in dotrace() 233 &td->td_cb, td->td_family, &td->td_ti.ti_i, in dotrace() 234 &td->td_ti.ti_t, td->td_req); in dotrace() 238 tcp_trace(td->td_act, td->td_ostate, in dotrace() 240 &td->td_cb, td->td_family, &td->td_ti6.ip6, in dotrace() 241 &td->td_ti6.th, td->td_req); in dotrace() 260 tcp_trace(td->td_act, td->td_ostate, in dotrace() 262 &td->td_cb, td->td_family, &td->td_ti.ti_i, in dotrace() 263 &td->td_ti.ti_t, td->td_req); in dotrace() 269 &td->td_cb, td->td_family, &td->td_ti6.ip6, in dotrace() [all …]
|
/dragonfly/sys/bus/u4b/controller/ |
H A D | uhci.c | 1062 td = td->obj_next; in uhci_isoc_done() 1136 td = td->alt_next; in uhci_non_isoc_done_sub() 1143 td = td->obj_next; in uhci_non_isoc_done_sub() 1258 td = td->alt_next; in uhci_check_transfer_sub() 1281 td = td->obj_next; in uhci_check_transfer_sub() 1386 td = td->obj_next; in uhci_check_transfer() 1550 td = temp->td; in uhci_setup_standard_chain_sub() 1656 temp->td = td; in uhci_setup_standard_chain_sub() 1812 td = temp.td; in uhci_setup_standard_chain() 2117 for (td = xfer->td_start[ds]; td; td = td->obj_next) { in uhci_device_isoc_open() [all …]
|
H A D | ehci.c | 1175 td = td->alt_next; in ehci_non_isoc_done_sub() 1182 td = td->obj_next; in ehci_non_isoc_done_sub() 1415 td = td->obj_next; in ehci_check_transfer() 1778 temp->td = td; in ehci_setup_standard_chain_sub() 1946 td = temp.td; in ehci_setup_standard_chain() 2124 td = td->obj_next; in ehci_isoc_fs_done() 2194 td = td->obj_next; in ehci_isoc_hs_done() 2466 for (td = xfer->td_start[ds]; td; td = td->obj_next) { in ehci_device_isoc_fs_open() 2689 td = td->obj_next; in ehci_device_isoc_fs_enter() 2749 for (td = xfer->td_start[ds]; td; td = td->obj_next) { in ehci_device_isoc_hs_open() [all …]
|
H A D | ohci.c | 121 ohci_td_t *td; member 759 td = td->obj_next; in ohci_isoc_done() 860 td = td->alt_next; in ohci_non_isoc_done_sub() 867 td = td->obj_next; in ohci_non_isoc_done_sub() 977 td = td->alt_next; in ohci_check_transfer_sub() 980 td = td->obj_next; in ohci_check_transfer_sub() 987 if (td) { in ohci_check_transfer_sub() 1270 td = temp->td; in ohci_setup_standard_chain_sub() 1381 temp->td = td; in ohci_setup_standard_chain_sub() 1532 td = temp.td; in ohci_setup_standard_chain() [all …]
|
/dragonfly/sys/platform/vkernel64/x86_64/ |
H A D | npx.c | 345 thread_t td = curthread; in npxdna() local 350 mdcpu->gd_npxthread, td); in npxdna() 377 mdcpu->gd_npxthread = td; in npxdna() 453 thread_t td = curthread; in npxpush() local 463 npxsave(td->td_savefpu); in npxpush() 482 thread_t td = curthread; in npxpop() local 494 npxsave(td->td_savefpu); in npxpop() 514 npxsave(td->td_savefpu); in npxpop() 515 bcopy(mctx->mc_fpregs, td->td_savefpu, sizeof(*td->td_savefpu)); in npxpop() 521 td->td_proc->p_pid, in npxpop() [all …]
|
H A D | trap.c | 347 p = td->td_proc; in user_trap() 383 userenter(td, p); in user_trap() 583 td->td_toks_stop - &td->td_toks_base)); in user_trap() 601 lp = td->td_lwp; in kern_trap() 602 p = td->td_proc; in kern_trap() 778 td->td_toks_stop - &td->td_toks_base)); in kern_trap() 1206 KASSERT(&td->td_toks_base == td->td_toks_stop, in syscall2() 1211 td->td_toks_stop - &td->td_toks_base)); in syscall2() 1232 td = curthread; in sys_xsyscall() 1262 if (KTRPOINTP(td->td_proc, td, KTR_SYSCALL)) { in sys_xsyscall() [all …]
|
H A D | vm_machdep.c | 246 td->td_pcb->pcb_r12 = (long)arg; in cpu_set_thread_handler() 248 td->td_sp -= sizeof(void *); in cpu_set_thread_handler() 250 td->td_sp -= sizeof(void *); in cpu_set_thread_handler() 257 struct thread *td = curthread; in cpu_lwp_exit() local 260 pcb = td->td_pcb; in cpu_lwp_exit() 272 td->td_gd->gd_cnt.v_swtch++; in cpu_lwp_exit() 274 crit_enter_quick(td); in cpu_lwp_exit() 275 if (td->td_flags & TDF_TSLEEPQ) in cpu_lwp_exit() 276 tsleep_remove(td); in cpu_lwp_exit() 277 lwkt_deschedule_self(td); in cpu_lwp_exit() [all …]
|
/dragonfly/lib/libthread_xu/thread/ |
H A D | thr_list.c | 106 pthread_t td, td_next; in _thr_gc() local 113 for (td = TAILQ_FIRST(&_thread_gc_list); td != NULL; td = td_next) { in _thr_gc() 115 if (td->terminated == 0) { in _thr_gc() 119 _thr_stack_free(&td->attr); in _thr_gc() 121 (td->refcount == 0)) { in _thr_gc() 122 THR_GCLIST_REMOVE(td); in _thr_gc() 128 THR_LIST_REMOVE(td); in _thr_gc() 140 if (td == _thr_initial) { in _thr_gc() 145 _thr_free(curthread, td); in _thr_gc() 283 pthread_t td; in _thr_hash_find() local [all …]
|
/dragonfly/sys/netproto/smb/ |
H A D | smb_trantcp.c | 81 u_int8_t *rpcodep, struct thread *td); 181 (error = nb_intr(nbp, td)) != 0) { in nb_connect_in() 196 smb_nbst_disconnect(nbp->nbp_vc, td); in nb_connect_in() 262 smb_nbst_disconnect(nbp->nbp_vc, td); in nbssn_rq_request() 265 error = nbssn_rq_request(nbp, td); in nbssn_rq_request() 294 auio.uio_td = td; in nbssn_recvhdr() 315 u_int8_t *rpcodep, struct thread *td) in nbssn_recv() argument 403 smb_nbst_disconnect(vcp, td); in smb_nbst_done() 472 error = nb_connect_in(nbp, &sin, td); in smb_nbst_connect() 484 error = nbssn_rq_request(nbp, td); in smb_nbst_connect() [all …]
|
/dragonfly/contrib/libedit/src/ |
H A D | tty.c | 455 #define tty__gettabs(td) ((((td)->c_oflag & TAB3) == TAB3) ? 0 : 1) argument 456 #define tty__geteightbit(td) (((td)->c_cflag & CSIZE) == CS8) argument 457 #define tty__cooked_mode(td) ((td)->c_lflag & ICANON) argument 616 spd = cfgetospeed(td); in tty__getspeed() 736 s[C_INTR] = td->c_cc[VINTR]; in tty__getchar() 748 s[C_EOF] = td->c_cc[VEOF]; in tty__getchar() 751 s[C_EOL] = td->c_cc[VEOL]; in tty__getchar() 802 s[C_MIN] = td->c_cc[VMIN]; in tty__getchar() 830 td->c_cc[VEOF] = s[C_EOF]; in tty__setchar() 833 td->c_cc[VEOL] = s[C_EOL]; in tty__setchar() [all …]
|