/illumos-gate/usr/src/uts/common/inet/ |
H A D | squeue.c | 260 return (sqp); in squeue_create() 290 thread_affinity_set(sqp->sq_worker, sqp->sq_bind); in squeue_bind() 469 sqp->sq_drain(sqp, SQS_ENTER, now + squeue_drain_ns); in squeue_enter() 1000 sqp->sq_drain(sqp, SQS_POLL_PROC, now + in squeue_polling_thread() 1096 cv_wait(&sqp->sq_worker_cv, &sqp->sq_lock); in squeue_worker_thr_control() 1125 cv_wait(&sqp->sq_worker_cv, &sqp->sq_lock); in squeue_worker_thr_control() 1138 SQS_POLLING_OFF(sqp, (sqp->sq_state & SQS_POLL_CAPAB) != 0, in squeue_worker_thr_control() 1175 cv_wait(&sqp->sq_worker_cv, &sqp->sq_lock); in squeue_worker_thr_control() 1237 sqp->sq_drain(sqp, SQS_WORKER, now + squeue_drain_ns); in squeue_worker() 1277 cv_wait(&sqp->sq_synch_cv, &sqp->sq_lock); in squeue_wakeup_conn() [all …]
|
/illumos-gate/usr/src/uts/common/inet/ip/ |
H A D | ip_squeue.c | 154 squeue_t *sqp; in ip_squeue_create() local 160 return (sqp); in ip_squeue_create() 545 squeue_t *sqp; in ip_squeue_clean_ring() local 564 cv_wait(&sqp->sq_ctrlop_done_cv, &sqp->sq_lock); in ip_squeue_clean_ring() 606 squeue_t *sqp; in ip_squeue_quiesce_ring() local 616 cv_wait(&sqp->sq_ctrlop_done_cv, &sqp->sq_lock); in ip_squeue_quiesce_ring() 628 squeue_t *sqp; in ip_squeue_restart_ring() local 647 cv_wait(&sqp->sq_ctrlop_done_cv, &sqp->sq_lock); in ip_squeue_restart_ring() 676 squeue_t *sqp; in ip_squeue_get() local 681 return (sqp); in ip_squeue_get() [all …]
|
/illumos-gate/usr/src/uts/common/syscall/ |
H A D | signotify.c | 96 sigqueue_t *sqp; in signotify() local 152 sqp = sigqalloc(cp->p_signhdr); in signotify() 153 if (sqp == NULL) { in signotify() 158 sqp->sq_info = info; in signotify() 159 sqp->sq_info.si_pid = cp->p_pid; in signotify() 160 sqp->sq_info.si_ctid = PRCTID(cp); in signotify() 233 sigqueue_t *sqp = kmem_zalloc(sizeof (*sqp), KM_SLEEP); in sigresend() local 244 sqp->sq_info.si_signo = sig; in sigresend() 245 sqp->sq_info.si_code = SI_NOINFO; in sigresend() 273 lwp->lwp_curinfo = sqp; in sigresend() [all …]
|
H A D | lwpsys.c | 117 sigqueue_t *sqp; in lwp_kill() local 124 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in lwp_kill() 129 kmem_free(sqp, sizeof (sigqueue_t)); in lwp_kill() 136 sqp->sq_info.si_signo = sig; in lwp_kill() 137 sqp->sq_info.si_code = SI_LWP; in lwp_kill() 138 sqp->sq_info.si_pid = p->p_pid; in lwp_kill() 139 sqp->sq_info.si_ctid = PRCTID(p); in lwp_kill() 140 sqp->sq_info.si_zoneid = getzoneid(); in lwp_kill() 141 sqp->sq_info.si_uid = crgetruid(CRED()); in lwp_kill() 142 sigaddqa(p, t, sqp); in lwp_kill()
|
H A D | lwp_sobj.c | 2834 sleepq_t *sqp = t->t_sleepq; in lwp_unsleep() local 2836 if (sqp != NULL) { in lwp_unsleep() 2838 ASSERT(&sqh->sq_queue == sqp); in lwp_unsleep() 2862 sleepq_t *sqp = t->t_sleepq; in lwp_change_pri() local 2866 sleepq_insert(sqp, t); in lwp_change_pri()
|
/illumos-gate/usr/src/uts/common/os/ |
H A D | sig.c | 1399 if (sqp) { in psig() 1727 sqp = NULL; in sigcld() 1736 sqp = NULL; in sigcld() 1741 if (sqp) in sigcld() 1782 sqp = NULL; in post_sigcld() 1788 if (sqp) in post_sigcld() 1944 *qpp = sqp; in sigdeq() 1946 for (sqp = *psqp; sqp; sqp = sqp->sq_next) { in sigdeq() 1998 for (sqp = *psqp; !another_sigcld && sqp; sqp = sqp->sq_next) { in sigcld_delete() 2034 sqp = *psqp; in sigdelq() [all …]
|
H A D | aio.c | 1209 sigqueue_t *sqp; in alio() local 1286 if (sqp == NULL) { in alio() 2396 if (sqp == NULL) in aio_req_setup() 2413 if (sqp) in aio_req_setup() 2423 if (sqp) in aio_req_setup() 2905 sigqueue_t *sqp; in alioLF() local 2985 if (sqp == NULL) { in alioLF() 3293 if (sqp == NULL) in aio_req_setupLF() 3310 if (sqp) in aio_req_setupLF() 3320 if (sqp) in aio_req_setupLF() [all …]
|
H A D | watchpoint.c | 689 register sigqueue_t *sqp; in sys_watchpoint() local 695 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in sys_watchpoint() 696 sqp->sq_info.si_signo = SIGTRAP; in sys_watchpoint() 697 sqp->sq_info.si_code = watchcode; in sys_watchpoint() 698 sqp->sq_info.si_addr = addr; in sys_watchpoint() 699 sqp->sq_info.si_trapafter = ta; in sys_watchpoint() 700 sqp->sq_info.si_pc = (caddr_t)getuserpc(); in sys_watchpoint() 709 lwp->lwp_siginfo = sqp->sq_info; in sys_watchpoint() 713 kmem_free(sqp, sizeof (sigqueue_t)); in sys_watchpoint() 727 kmem_free(sqp, sizeof (sigqueue_t)); in sys_watchpoint() [all …]
|
H A D | rctl.c | 2546 sigqueue_t *sqp = NULL; in rctl_local_action() local 2576 sqp->sq_info.si_code = SI_RCTL; in rctl_local_action() 2577 sqp->sq_info.si_errno = 0; in rctl_local_action() 2584 if (sqp == NULL) { in rctl_local_action() 2591 sigaddqa(curproc, curthread, sqp); in rctl_local_action() 2593 sigaddqa(p, NULL, sqp); in rctl_local_action() 2618 if (sqp == NULL) in rctl_local_action() 2622 sigaddqa(rp, NULL, sqp); in rctl_local_action() 2623 } else if (sqp) { in rctl_local_action() 2629 if (sqp) in rctl_local_action() [all …]
|
H A D | turnstile.c | 721 sleepq_t *sqp = &ts->ts_sleepq[qnum]; in turnstile_wakeup() local 732 kthread_t *t = sqp->sq_first; in turnstile_wakeup() 763 sleepq_t *sqp = t->t_sleepq; in turnstile_change_pri() local 767 sleepq_insert(sqp, t); in turnstile_change_pri()
|
H A D | condvar.c | 94 sleepq_t *sqp = t->t_sleepq; in cv_change_pri() local 97 ASSERT(&SQHASH(cvp)->sq_queue == sqp); in cv_change_pri() 103 sleepq_insert(sqp, t); in cv_change_pri()
|
H A D | exit.c | 474 sigqueue_t *sqp; in proc_exit() local 544 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in proc_exit() 979 sigcld(p, sqp); in proc_exit()
|
H A D | streamio.c | 8348 queue_t *sqp; in strpoll() local 8353 else if ((sqp = stp->sd_struiowrq) != NULL) { in strpoll() 8357 QLOCK(sqp)) != 0) { in strpoll() 8362 if (sqp->q_flag & QFULL) in strpoll() 8364 sqp->q_flag |= QWANTWSYNC; in strpoll() 8369 mutex_exit(QLOCK(sqp)); in strpoll() 8373 mutex_exit(QLOCK(sqp)); in strpoll()
|
H A D | strsubr.c | 5181 sqlist_insert(sqlist_t *sqlist, syncq_t *sqp) in sqlist_insert() argument 5187 if (sqlp->sql_sq >= sqp) { in sqlist_insert() 5188 if (sqlp->sql_sq == sqp) /* duplicate */ in sqlist_insert() 5197 new_sqlp->sql_sq = sqp; in sqlist_insert()
|
/illumos-gate/usr/src/uts/common/sys/ |
H A D | squeue.h | 51 #define SQUEUE_ENTER(sqp, head, tail, cnt, ira, flag, tag) { \ argument 52 sqp->sq_enter(sqp, head, tail, cnt, ira, flag, tag); \ 55 #define SQUEUE_ENTER_ONE(sqp, mp, proc, arg, ira, flag, tag) { \ argument 59 SQUEUE_ENTER(sqp, mp, mp, 1, ira, flag, tag); \
|
/illumos-gate/usr/src/uts/sun4/os/ |
H A D | dtrace_subr.c | 103 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in dtrace_pid_probe() local 106 sqp->sq_info.si_signo = SIGILL; in dtrace_pid_probe() 107 sqp->sq_info.si_code = ILL_ILLTRP; in dtrace_pid_probe() 108 sqp->sq_info.si_addr = (caddr_t)rp->r_pc; in dtrace_pid_probe() 109 sqp->sq_info.si_trapno = 0x38; in dtrace_pid_probe() 112 sigaddqa(p, curthread, sqp); in dtrace_pid_probe()
|
/illumos-gate/usr/src/uts/common/inet/tcp/ |
H A D | tcp_time_wait.c | 133 squeue_t *sqp = tcp->tcp_connp->conn_sqp; in tcp_time_wait_append() local 135 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP)); in tcp_time_wait_append() 231 tcp_time_wait_collector, sqp, in tcp_time_wait_append() 256 tcp_time_wait_collector, sqp, in tcp_time_wait_append() 407 squeue_t *sqp = (squeue_t *)arg; in tcp_time_wait_collector() local 409 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP)); in tcp_time_wait_collector() 583 tcp_time_wait_collector, sqp, in tcp_time_wait_collector()
|
H A D | tcp.c | 1495 squeue_t *sqp = (squeue_t *)arg; in tcp_get_conn() local 1501 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP)); in tcp_get_conn() 2625 squeue_t *sqp; in tcp_create_common() local 2666 sqp = IP_SQUEUE_GET((uint_t)gethrtime()); in tcp_create_common() 2667 connp = tcp_get_conn(sqp, tcps); in tcp_create_common() 2679 connp->conn_sqp = sqp; in tcp_create_common() 4054 tcp_squeue_add(squeue_t *sqp) in tcp_squeue_add() argument 4059 *squeue_getprivate(sqp, SQPRIVATE_TCP) = (intptr_t)tcp_time_wait; in tcp_squeue_add()
|
H A D | tcp_input.c | 1979 squeue_t *sqp = (squeue_t *)arg2; in tcp_input_listener_unbound() local 2023 (void) atomic_cas_ptr(&connp->conn_sqp, sqp, in tcp_input_listener_unbound() 2047 if (connp->conn_sqp != sqp) { in tcp_input_listener_unbound() 2052 tcp_input_listener(connp, mp, sqp, ira); in tcp_input_listener_unbound() 2461 squeue_t *sqp = (squeue_t *)arg2; in tcp_input_data() local 2535 if (sqp != NULL) { in tcp_input_data() 2551 if ((flags & TH_URG) && sqp != NULL) { in tcp_input_data() 2599 tcp_outbound_squeue_switch && sqp != NULL) { in tcp_input_data() 2601 connp->conn_final_sqp = sqp; in tcp_input_data()
|
/illumos-gate/usr/src/uts/intel/dtrace/ |
H A D | fasttrap_isa.c | 688 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in fasttrap_sigsegv() local 690 sqp->sq_info.si_signo = SIGSEGV; in fasttrap_sigsegv() 691 sqp->sq_info.si_code = SEGV_MAPERR; in fasttrap_sigsegv() 692 sqp->sq_info.si_addr = (caddr_t)addr; in fasttrap_sigsegv() 695 sigaddqa(p, t, sqp); in fasttrap_sigsegv()
|
/illumos-gate/usr/src/uts/common/dtrace/ |
H A D | fasttrap.c | 234 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in fasttrap_sigtrap() local 236 sqp->sq_info.si_signo = SIGTRAP; in fasttrap_sigtrap() 237 sqp->sq_info.si_code = TRAP_DTRACE; in fasttrap_sigtrap() 238 sqp->sq_info.si_addr = (caddr_t)pc; in fasttrap_sigtrap() 241 sigaddqa(p, t, sqp); in fasttrap_sigtrap()
|
/illumos-gate/usr/src/uts/common/fs/proc/ |
H A D | prcontrol.c | 1550 sigqueue_t *sqp; in pr_setsig() local 1554 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in pr_setsig() 1558 lwp->lwp_curinfo = sqp; in pr_setsig() 1560 kmem_free(sqp, sizeof (sigqueue_t)); in pr_setsig()
|