Home
last modified time | relevance | path

Searched refs:sqp (Results 1 – 22 of 22) sorted by relevance

/illumos-gate/usr/src/uts/common/inet/
H A Dsqueue.c260 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 Dip_squeue.c154 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 Dsignotify.c96 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 Dlwpsys.c117 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 Dlwp_sobj.c2834 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 Dsig.c1399 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 Daio.c1209 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 Dwatchpoint.c689 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 Drctl.c2546 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 Dturnstile.c721 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 Dcondvar.c94 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 Dexit.c474 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 Dstreamio.c8348 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 Dstrsubr.c5181 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 Dsqueue.h51 #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 Ddtrace_subr.c103 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 Dtcp_time_wait.c133 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 Dtcp.c1495 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 Dtcp_input.c1979 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 Dfasttrap_isa.c688 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 Dfasttrap.c234 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 Dprcontrol.c1550 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()