/dragonfly/sys/dev/disk/iscsi/initiator/ |
H A D | iscsi.c | 95 static int i_send(struct cdev *dev, caddr_t arg, struct thread *td); 96 static int i_recv(struct cdev *dev, caddr_t arg, struct thread *td); 97 static int i_setsoc(isc_session_t *sp, int fd, struct thread *td); 413 i_setsoc(isc_session_t *sp, int fd, thread_t td) in i_setsoc() argument 427 if ((error = holdsock(td, fd, &fp)) == 0) { in i_setsoc() 437 i_send(struct cdev *dev, caddr_t arg, struct thread *td) in i_send() argument 508 i_recv(struct cdev *dev, caddr_t arg, struct thread *td) in i_recv() argument
|
/dragonfly/sys/netgraph/ksocket/ |
H A D | ng_ksocket.c | 559 struct thread *td = curthread->td_proc ? curthread : &thread0; /* XXX broken */ in ng_ksocket_newhook() local 598 error = socreate(family, &priv->so, type, protocol, td); in ng_ksocket_newhook() 640 struct thread *td = curthread->td_proc ? curthread : &thread0; /* XXX broken */ in ng_ksocket_rcvmsg() local 662 error = sobind(so, sa, td); in ng_ksocket_rcvmsg() 674 error = solisten(so, *((int32_t *)msg->data), td); in ng_ksocket_rcvmsg() 726 if ((error = soconnect(so, sa, td, TRUE)) != 0) { in ng_ksocket_rcvmsg() 880 struct thread *td = curthread->td_proc ? curthread : &thread0; /* XXX broken */ in ng_ksocket_rcvdata() local 912 error = so_pru_sosend(so, sa, NULL, m, NULL, 0, td); in ng_ksocket_rcvdata()
|
/dragonfly/sys/netgraph7/ksocket/ |
H A D | ng_ksocket.c | 546 struct thread *td = curthread->td_proc ? curthread : &thread0; /* XXX broken */ in ng_ksocket_newhook() local 584 error = socreate(family, &priv->so, type, protocol, td); in ng_ksocket_newhook() 661 struct thread *td = curthread->td_proc ? curthread : &thread0; /* XXX broken */ in ng_ksocket_rcvmsg() local 685 error = sobind(so, sa, td); in ng_ksocket_rcvmsg() 697 error = solisten(so, *((int32_t *)msg->data), td); in ng_ksocket_rcvmsg() 748 if ((error = soconnect(so, sa, td, TRUE)) != 0) { in ng_ksocket_rcvmsg() 886 struct thread *td = curthread->td_proc ? curthread : &thread0; /* XXX broken */ in ng_ksocket_rcvdata() local 913 error = sosend(so, sa, 0, m, 0, 0, td); in ng_ksocket_rcvdata()
|
/dragonfly/sys/netproto/smb/ |
H A D | smb_subr.h | 111 void smb_makescred(struct smb_cred *scred, struct thread *td, struct ucred *cred); 112 int smb_proc_intr(struct thread *td);
|
/dragonfly/usr.bin/dsynth/ |
H A D | bulk.c | 40 pthread_t td; member 103 pthread_create(&JobsAry[i].td, NULL, bulkthread, &JobsAry[i]); in initbulk() 127 pthread_join(JobsAry[i].td, NULL); in donebulk()
|
/dragonfly/sys/kern/ |
H A D | vfs_mount.c | 521 struct thread *td = curthread; in vnlru_proc() local 523 EVENTHANDLER_REGISTER(shutdown_pre_sync, shutdown_kproc, td, in vnlru_proc() 1066 thread_t td; member 1072 struct thread *td = curthread; /* XXX */ in vflush() local 1096 vflush_info.td = td; in vflush()
|
H A D | subr_firmware.c | 256 struct thread *td = curthread; in loadimage() local 381 struct thread *td = curthread; in set_rootvnode() local 382 struct proc *p = td->td_proc; in set_rootvnode()
|
H A D | kern_exec.c | 205 struct thread *td = curthread; in kern_execve() local 206 struct lwp *lp = td->td_lwp; in kern_execve() 207 struct proc *p = td->td_proc; in kern_execve() 495 caps_priv_check_td(td, SYSCAP_RESTRICTEDROOT) != 0) in kern_execve() 585 vn_mark_atime(imgp->vp, td); in kern_execve() 710 struct thread *td = curthread; in sys_fexecve() local 725 if ((error = holdvnode2(td, uap->fd, &fp, &fileflags)) != 0) in sys_fexecve()
|
H A D | subr_taskqueue.c | 552 struct thread *td; in taskqueue_start_threads() local 599 td = tq->tq_threads[i]; in taskqueue_start_threads() 600 lwkt_setpri_initial(td, pri); in taskqueue_start_threads() 601 lwkt_schedule(td); in taskqueue_start_threads()
|
H A D | kern_collect.c | 268 thread_t td = NULL; in kcollect_thread_init() local 283 lwkt_create(kcollect_thread, NULL, &td, NULL, 0, 0, "kcollect"); in kcollect_thread_init()
|
H A D | kern_proc.c | 1642 sysctl_out_proc_kthread(struct thread *td, struct sysctl_req *req) in sysctl_out_proc_kthread() argument 1647 fill_kinfo_proc_kthread(td, &ki); in sysctl_out_proc_kthread() 1663 struct thread *td; in sysctl_kern_proc() local 1809 while ((td = TAILQ_PREV(marker, lwkt_queue, td_allq)) != NULL) { in sysctl_kern_proc() 1811 TAILQ_INSERT_BEFORE(td, marker, td_allq); in sysctl_kern_proc() 1812 if (td->td_flags & TDF_MARKER) in sysctl_kern_proc() 1814 if (td->td_proc) in sysctl_kern_proc() 1817 lwkt_hold(td); in sysctl_kern_proc() 1827 error = sysctl_out_proc_kthread(td, req); in sysctl_kern_proc() 1830 lwkt_rele(td); in sysctl_kern_proc()
|
/dragonfly/sys/net/ |
H A D | netisr.c | 322 thread_t td = curthread; in netmsg_service_loop() local 326 td->td_type = TD_TYPE_NETISR; in netmsg_service_loop() 328 while ((msg = lwkt_waitport(&td->td_msgport, 0))) { in netmsg_service_loop() 345 msg->nm_so->so_port != &td->td_msgport) { in netmsg_service_loop() 374 } while ((msg = lwkt_getport(&td->td_msgport)) != NULL); in netmsg_service_loop()
|
/dragonfly/test/stress/stress2/misc/ |
H A D | fpclone.sh | 120 fpclone_open(struct cdev *dev, int oflags, int devtype, d_thread_t *td) 134 fpclone_close(struct cdev *dev, int fflag, int devtype, d_thread_t *td)
|
H A D | cdevsw.sh | 134 tclone_open(struct cdev *dev, int oflags, int devtype, d_thread_t *td) 155 tclone_close(struct cdev *dev, int fflag, int devtype, d_thread_t *td)
|
/dragonfly/contrib/tcpdump/ |
H A D | print-ntp.c | 399 struct ntp_time_data td; member 415 status = GET_U_1(bp->td.status); in ntp_print() 445 ntp_time_print(ndo, &bp->td, length); in ntp_print()
|
/dragonfly/sys/dev/misc/tbridge/ |
H A D | tbridge.c | 243 struct thread *td; in tbridge_dev_ioctl() local 266 error = kthread_create(tbridge_curtest->tb_run, NULL, &td, in tbridge_dev_ioctl()
|
/dragonfly/sys/dev/sound/pcm/ |
H A D | sound.c | 1150 struct thread *td; in pcm_unregister() local 1152 td = curthread; in pcm_unregister() 1160 if (sndstat_acquire(td) != 0) { in pcm_unregister() 1171 sndstat_release(td); in pcm_unregister() 1186 sndstat_release(td); in pcm_unregister() 1196 sndstat_release(td); in pcm_unregister() 1212 sndstat_release(td); in pcm_unregister() 1252 sndstat_release(td); in pcm_unregister()
|
/dragonfly/sys/platform/pc64/x86_64/ |
H A D | machdep.c | 1169 KKASSERT(td->td_critcount == 0); in cpu_idle() 1473 struct thread *td = curthread; in exec_setregs() local 1474 struct lwp *lp = td->td_lwp; in exec_setregs() 1475 struct pcb *pcb = td->td_pcb; in exec_setregs() 1501 if (pcb == td->td_pcb) { in exec_setregs() 3619 thread_t td; in pcpu_timer_always() local 3635 td = gd->gd_curthread; in pcpu_timer_always() 3636 if (td == NULL) in pcpu_timer_always() 3639 top = (char *)td->td_kstack + td->td_kstack_size; in pcpu_timer_always() 3698 td->td_comm, in cpu_interrupt_running() [all …]
|
H A D | pmap.c | 2241 pmap_init_thread(thread_t td) in pmap_init_thread() argument 2244 td->td_pcb = (struct pcb *)(td->td_kstack + td->td_kstack_size) - 1; in pmap_init_thread() 2245 td->td_pcb = (struct pcb *)((intptr_t)td->td_pcb & ~(intptr_t)0xF); in pmap_init_thread() 2246 td->td_savefpu = &td->td_pcb->pcb_save; in pmap_init_thread() 2247 td->td_sp = (char *)td->td_pcb; /* no -16 */ in pmap_init_thread() 6272 thread_t td; in pmap_setlwpvm() local 6278 td = curthread; in pmap_setlwpvm() 6281 if (td->td_lwp == lp) { in pmap_setlwpvm() 6292 td->td_pcb->pcb_cr3_iso = in pmap_setlwpvm() 6296 td->td_pcb->pcb_cr3_iso = 0; in pmap_setlwpvm() [all …]
|
/dragonfly/sys/dev/disk/dm/delay/ |
H A D | dm_target_delay.c | 63 thread_t td; member 152 lwkt_create(_thread, di, &di->td, NULL, 0, -1, "dmdl%d", id); in _init() 374 di->td = NULL; in _thread()
|
/dragonfly/sys/vfs/procfs/ |
H A D | procfs_subr.c | 499 procfs_exit(struct thread *td) in procfs_exit() argument 506 KKASSERT(td->td_proc); in procfs_exit() 507 pid = td->td_proc->p_pid; in procfs_exit()
|
/dragonfly/sys/vfs/ext2fs/ |
H A D | ext2_vnops.c | 262 struct thread *td = curthread; in ext2_setattr() local 321 td)) != 0) in ext2_setattr() 373 error = ext2_chmod(vp, (int)vap->va_mode, cred, td); in ext2_setattr() 383 ext2_chmod(struct vnode *vp, int mode, struct ucred *cred, struct thread *td) in ext2_chmod() argument 411 struct thread *td) in ext2_chown() argument 1928 struct thread *td; in ext2_write() local 1974 td = uio->uio_td; in ext2_write() 1975 if (vp->v_type == VREG && td && td->td_proc && in ext2_write() 1977 td->td_proc->p_rlimit[RLIMIT_FSIZE].rlim_cur) { in ext2_write() 1978 lwpsignal(td->td_proc, td->td_lwp, SIGXFSZ); in ext2_write()
|
/dragonfly/sys/dev/netif/sis/ |
H A D | if_sis.c | 1435 struct sis_tx_data *td; in sis_txeof() local 1438 td = &cd->sis_tx_data[idx]; in sis_txeof() 1458 if (td->sis_mbuf != NULL) { in sis_txeof() 1459 bus_dmamap_unload(cd->sis_txbuf_tag, td->sis_map); in sis_txeof() 1460 m_freem(td->sis_mbuf); in sis_txeof() 1461 td->sis_mbuf = NULL; in sis_txeof() 2065 struct sis_tx_data *td = &cd->sis_tx_data[i]; in sis_stop() local 2067 if (td->sis_mbuf != NULL) { in sis_stop() 2068 bus_dmamap_unload(cd->sis_txbuf_tag, td->sis_map); in sis_stop() 2069 m_freem(td->sis_mbuf); in sis_stop() [all …]
|
/dragonfly/sys/netgraph7/socket/ |
H A D | ng_socket.c | 222 if (control && (error = ng_internalize(control, td))) { in ngc_send() 695 ng_internalize(struct mbuf *control, struct thread *td) in ng_internalize() argument 719 if ((error = fget(td, fd, &fp)) != 0) in ng_internalize() 734 fdrop(fp, td); in ng_internalize() 740 fdrop(fp, td); in ng_internalize() 744 fdrop(fp, td); in ng_internalize()
|
/dragonfly/sys/sys/ |
H A D | iosched.h | 38 void biosched_done(struct thread *td);
|