Home
last modified time | relevance | path

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

/titanic_44/usr/src/uts/common/inet/
H A Dsqueue.c137 static void squeue_worker(squeue_t *sqp);
138 static void squeue_polling_thread(squeue_t *sqp);
156 #define ENQUEUE_CHAIN(sqp, mp, tail, cnt) { \ argument
160 ASSERT(MUTEX_HELD(&(sqp)->sq_lock)); \
162 if ((sqp)->sq_last != NULL) \
163 (sqp)->sq_last->b_next = (mp); \
165 (sqp)->sq_first = (mp); \
166 (sqp)->sq_last = (tail); \
167 (sqp)->sq_count += (cnt); \
168 ASSERT((sqp)->sq_count > 0); \
[all …]
/titanic_44/usr/src/uts/common/inet/ip/
H A Dip_squeue.c164 squeue_t *sqp; in ip_squeue_create() local
166 sqp = squeue_create(ip_squeue_worker_wait, pri); in ip_squeue_create()
167 ASSERT(sqp != NULL); in ip_squeue_create()
169 ip_squeue_create_callback(sqp); in ip_squeue_create()
170 return (sqp); in ip_squeue_create()
555 squeue_t *sqp; in ip_squeue_clean_ring() local
567 sqp = rx_ring->rr_sqp; in ip_squeue_clean_ring()
569 mutex_enter(&sqp->sq_lock); in ip_squeue_clean_ring()
570 sqp->sq_state |= SQS_POLL_CLEANUP; in ip_squeue_clean_ring()
571 cv_signal(&sqp->sq_worker_cv); in ip_squeue_clean_ring()
[all …]
/titanic_44/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()
161 sqp->sq_info.si_zoneid = getzoneid(); in signotify()
162 sqp->sq_info.si_uid = crgetruid(cr); in signotify()
165 ((signotifyq_t *)sqp)->sn_snid = sid; in signotify()
170 id.sn_index = (signotifyq_t *)sqp - SIGN_PTR(cp, 0); in signotify()
[all …]
H A Dlwpsys.c116 sigqueue_t *sqp; in lwp_kill() local
123 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in lwp_kill()
128 kmem_free(sqp, sizeof (sigqueue_t)); in lwp_kill()
135 sqp->sq_info.si_signo = sig; in lwp_kill()
136 sqp->sq_info.si_code = SI_LWP; in lwp_kill()
137 sqp->sq_info.si_pid = p->p_pid; in lwp_kill()
138 sqp->sq_info.si_ctid = PRCTID(p); in lwp_kill()
139 sqp->sq_info.si_zoneid = getzoneid(); in lwp_kill()
140 sqp->sq_info.si_uid = crgetruid(CRED()); in lwp_kill()
141 sigaddqa(p, t, sqp); in lwp_kill()
H A Dlwp_sobj.c2819 sleepq_t *sqp = t->t_sleepq; in lwp_unsleep() local
2821 if (sqp != NULL) { in lwp_unsleep()
2823 ASSERT(&sqh->sq_queue == sqp); in lwp_unsleep()
2847 sleepq_t *sqp = t->t_sleepq; in lwp_change_pri() local
2851 sleepq_insert(sqp, t); in lwp_change_pri()
/titanic_44/usr/src/uts/common/os/
H A Dsig.c367 sigqueue_t *sqp; in isjobstop() local
371 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in isjobstop()
377 siginfofree(sqp); in isjobstop()
382 sigcld(p, sqp); in isjobstop()
1012 sigqueue_t *sqp; in stop() local
1018 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in stop()
1028 sigcld(p, sqp); in stop()
1274 sigqueue_t *sqp = NULL; in psig() local
1335 sqp = lwp->lwp_curinfo; in psig()
1337 sqp = p->p_killsqp; in psig()
[all …]
H A Daio.c1213 sigqueue_t *sqp; in alio() local
1289 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_NOSLEEP); in alio()
1290 if (sqp == NULL) { in alio()
1294 sqp->sq_func = NULL; in alio()
1295 sqp->sq_next = NULL; in alio()
1296 sqp->sq_info.si_code = SI_ASYNCIO; in alio()
1297 sqp->sq_info.si_pid = curproc->p_pid; in alio()
1298 sqp->sq_info.si_ctid = PRCTID(curproc); in alio()
1299 sqp->sq_info.si_zoneid = getzoneid(); in alio()
1300 sqp->sq_info.si_uid = crgetuid(curproc->p_cred); in alio()
[all …]
H A Dwatchpoint.c712 register sigqueue_t *sqp; in sys_watchpoint() local
718 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in sys_watchpoint()
719 sqp->sq_info.si_signo = SIGTRAP; in sys_watchpoint()
720 sqp->sq_info.si_code = watchcode; in sys_watchpoint()
721 sqp->sq_info.si_addr = addr; in sys_watchpoint()
722 sqp->sq_info.si_trapafter = ta; in sys_watchpoint()
723 sqp->sq_info.si_pc = (caddr_t)getuserpc(); in sys_watchpoint()
732 lwp->lwp_siginfo = sqp->sq_info; in sys_watchpoint()
736 kmem_free(sqp, sizeof (sigqueue_t)); in sys_watchpoint()
750 kmem_free(sqp, sizeof (sigqueue_t)); in sys_watchpoint()
[all …]
H A Drctl.c2548 sigqueue_t *sqp = NULL; in rctl_local_action() local
2573 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in rctl_local_action()
2577 sqp->sq_info.si_signo = recip_signal; in rctl_local_action()
2578 sqp->sq_info.si_code = SI_RCTL; in rctl_local_action()
2579 sqp->sq_info.si_errno = 0; in rctl_local_action()
2580 sqp->sq_info.si_entity = (int)rde->rcd_entity; in rctl_local_action()
2586 if (sqp == NULL) { in rctl_local_action()
2593 sigaddqa(curproc, curthread, sqp); in rctl_local_action()
2595 sigaddqa(p, NULL, sqp); in rctl_local_action()
2620 if (sqp == NULL) 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.c93 sleepq_t *sqp = t->t_sleepq; in cv_change_pri() local
96 ASSERT(&SQHASH(cvp)->sq_queue == sqp); in cv_change_pri()
102 sleepq_insert(sqp, t); in cv_change_pri()
H A Dexit.c339 sigqueue_t *sqp; in proc_exit() local
424 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in proc_exit()
843 sigcld(p, sqp); in proc_exit()
H A Dstreamio.c8222 queue_t *sqp; in strpoll() local
8227 else if ((sqp = stp->sd_struiowrq) != NULL) { in strpoll()
8230 polllock(&stp->sd_pollist, QLOCK(sqp)); in strpoll()
8231 if (sqp->q_flag & QFULL) in strpoll()
8233 sqp->q_flag |= QWANTWSYNC; in strpoll()
8238 mutex_exit(QLOCK(sqp)); in strpoll()
8242 mutex_exit(QLOCK(sqp)); in strpoll()
H A Dstrsubr.c5156 sqlist_insert(sqlist_t *sqlist, syncq_t *sqp) in sqlist_insert() argument
5162 if (sqlp->sql_sq >= sqp) { in sqlist_insert()
5163 if (sqlp->sql_sq == sqp) /* duplicate */ in sqlist_insert()
5172 new_sqlp->sql_sq = sqp; in sqlist_insert()
/titanic_44/usr/src/uts/common/sys/
H A Dsqueue.h50 #define SQUEUE_ENTER(sqp, head, tail, cnt, ira, flag, tag) { \ argument
51 sqp->sq_enter(sqp, head, tail, cnt, ira, flag, tag); \
54 #define SQUEUE_ENTER_ONE(sqp, mp, proc, arg, ira, flag, tag) { \ argument
58 SQUEUE_ENTER(sqp, mp, mp, 1, ira, flag, tag); \
/titanic_44/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()
/titanic_44/usr/src/uts/common/inet/tcp/
H A Dtcp_time_wait.c137 squeue_t *sqp = tcp->tcp_connp->conn_sqp; in tcp_time_wait_append() local
139 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP)); in tcp_time_wait_append()
214 tcp_time_wait_collector, sqp, firetime, in tcp_time_wait_append()
300 squeue_t *sqp = (squeue_t *)arg; in tcp_time_wait_collector() local
302 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP)); in tcp_time_wait_collector()
484 sqp, firetime, CALLOUT_TCP_RESOLUTION, in tcp_time_wait_collector()
H A Dtcp.c1476 squeue_t *sqp = (squeue_t *)arg; in tcp_get_conn() local
1482 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP)); in tcp_get_conn()
2604 squeue_t *sqp; in tcp_create_common() local
2645 sqp = IP_SQUEUE_GET((uint_t)gethrtime()); in tcp_create_common()
2646 connp = (conn_t *)tcp_get_conn(sqp, tcps); in tcp_create_common()
2658 connp->conn_sqp = sqp; in tcp_create_common()
4027 tcp_squeue_add(squeue_t *sqp) in tcp_squeue_add() argument
4032 *squeue_getprivate(sqp, SQPRIVATE_TCP) = (intptr_t)tcp_time_wait; in tcp_squeue_add()
H A Dtcp_input.c1899 squeue_t *sqp = (squeue_t *)arg2; in tcp_input_listener_unbound() local
1943 (void) atomic_cas_ptr(&connp->conn_sqp, sqp, in tcp_input_listener_unbound()
1967 if (connp->conn_sqp != sqp) { in tcp_input_listener_unbound()
1972 tcp_input_listener(connp, mp, sqp, ira); in tcp_input_listener_unbound()
2383 squeue_t *sqp = (squeue_t *)arg2; in tcp_input_data() local
2456 if (sqp != NULL) { in tcp_input_data()
2472 if ((flags & TH_URG) && sqp != NULL) { in tcp_input_data()
2520 tcp_outbound_squeue_switch && sqp != NULL) { in tcp_input_data()
2522 connp->conn_final_sqp = sqp; in tcp_input_data()
/titanic_44/usr/src/uts/intel/dtrace/
H A Dfasttrap_isa.c710 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in fasttrap_sigsegv() local
712 sqp->sq_info.si_signo = SIGSEGV; in fasttrap_sigsegv()
713 sqp->sq_info.si_code = SEGV_MAPERR; in fasttrap_sigsegv()
714 sqp->sq_info.si_addr = (caddr_t)addr; in fasttrap_sigsegv()
717 sigaddqa(p, t, sqp); in fasttrap_sigsegv()
/titanic_44/usr/src/uts/common/inet/nca/
H A Dnca.h203 #define SQ_STATE_IS(sqp, flags) ((sqp)->sq_state & (flags)) argument
204 #define SQ_TYPE_IS(sqp, flags) ((sqp)->sq_type & (flags)) argument
396 nca_squeue_t *sqp; /* squeue node_t is being processed from */ member
/titanic_44/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()
/titanic_44/usr/src/uts/common/fs/proc/
H A Dprcontrol.c1411 sigqueue_t *sqp; in pr_setsig() local
1415 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); in pr_setsig()
1419 lwp->lwp_curinfo = sqp; in pr_setsig()
1421 kmem_free(sqp, sizeof (sigqueue_t)); in pr_setsig()
/titanic_44/usr/src/cmd/mdb/common/modules/nca/
H A Dnca.c555 node.datasz, NCA_ADDR_WIDTH, node.sqp, NCA_ADDR_WIDTH, in nca_node()