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

/illumos-gate/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) { \
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)
249 squeue_t *sqp = kmem_cache_alloc(squeue_cache, KM_SLEEP); local
275 squeue_bind(squeue_t *sqp, processorid_t bind) argument
299 squeue_unbind(squeue_t *sqp) argument
313 squeue_worker_wakeup(squeue_t *sqp) argument
425 squeue_enter(squeue_t *sqp, mblk_t *mp, mblk_t *tail, uint32_t cnt, ip_recv_attr_t *ira, int process_flag, uint8_t tag) argument
682 squeue_t *sqp = arg; local
711 squeue_drain(squeue_t *sqp, uint_t proc_type, hrtime_t expire) argument
965 squeue_poll_thr_control(squeue_t *sqp) argument
1031 squeue_polling_thread(squeue_t *sqp) argument
1202 squeue_worker_thr_control(squeue_t *sqp) argument
1307 squeue_worker(squeue_t *sqp) argument
1369 squeue_getprivate(squeue_t *sqp, sqprivate_t p) argument
1381 squeue_t *sqp = connp->conn_sqp; local
1411 squeue_t *sqp; local
1489 squeue_t *sqp = connp->conn_sqp; local
[all...]
/illumos-gate/usr/src/uts/common/inet/ip/
H A Dip_squeue.c164 squeue_t *sqp; local
166 sqp = squeue_create(ip_squeue_worker_wait, pri);
167 ASSERT(sqp != NULL);
169 ip_squeue_create_callback(sqp);
170 return (sqp);
555 squeue_t *sqp; local
567 sqp = rx_ring->rr_sqp;
569 mutex_enter(&sqp->sq_lock);
570 sqp->sq_state |= SQS_POLL_CLEANUP;
571 cv_signal(&sqp
616 squeue_t *sqp; local
638 squeue_t *sqp; local
686 squeue_t *sqp; local
702 squeue_t *sqp, *lastsqp = NULL; local
[all...]
/illumos-gate/usr/src/uts/common/sys/
H A Dsqueue.h50 #define SQUEUE_ENTER(sqp, head, tail, cnt, ira, flag, tag) { \
51 sqp->sq_enter(sqp, head, tail, cnt, ira, flag, tag); \
54 #define SQUEUE_ENTER_ONE(sqp, mp, proc, arg, ira, flag, tag) { \
58 SQUEUE_ENTER(sqp, mp, mp, 1, ira, flag, tag); \
/illumos-gate/usr/src/uts/common/syscall/
H A Dsignotify.c96 sigqueue_t *sqp; local
152 sqp = sigqalloc(cp->p_signhdr);
153 if (sqp == NULL) {
158 sqp->sq_info = info;
159 sqp->sq_info.si_pid = cp->p_pid;
160 sqp->sq_info.si_ctid = PRCTID(cp);
161 sqp->sq_info.si_zoneid = getzoneid();
162 sqp->sq_info.si_uid = crgetruid(cr);
165 ((signotifyq_t *)sqp)->sn_snid = sid;
170 id.sn_index = (signotifyq_t *)sqp
233 sigqueue_t *sqp = kmem_zalloc(sizeof (*sqp), KM_SLEEP); local
[all...]
H A Dlwpsys.c116 sigqueue_t *sqp; local
123 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
128 kmem_free(sqp, sizeof (sigqueue_t));
135 sqp->sq_info.si_signo = sig;
136 sqp->sq_info.si_code = SI_LWP;
137 sqp->sq_info.si_pid = p->p_pid;
138 sqp->sq_info.si_ctid = PRCTID(p);
139 sqp->sq_info.si_zoneid = getzoneid();
140 sqp->sq_info.si_uid = crgetruid(CRED());
141 sigaddqa(p, t, sqp);
[all...]
H A Dlwp_sobj.c2835 sleepq_t *sqp = t->t_sleepq; local
2837 if (sqp != NULL) {
2839 ASSERT(&sqh->sq_queue == sqp);
2863 sleepq_t *sqp = t->t_sleepq; local
2867 sleepq_insert(sqp, t);
/illumos-gate/usr/src/uts/sun4/os/
H A Ddtrace_subr.c103 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); local
106 sqp->sq_info.si_signo = SIGILL;
107 sqp->sq_info.si_code = ILL_ILLTRP;
108 sqp->sq_info.si_addr = (caddr_t)rp->r_pc;
109 sqp->sq_info.si_trapno = 0x38;
112 sigaddqa(p, curthread, sqp);
/illumos-gate/usr/src/uts/common/os/
H A Dsig.c383 sigqueue_t *sqp; local
387 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
393 siginfofree(sqp);
398 sigcld(p, sqp);
1028 sigqueue_t *sqp; local
1034 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
1044 sigcld(p, sqp);
1290 sigqueue_t *sqp = NULL; local
1351 sqp = lwp->lwp_curinfo;
1353 sqp
1698 sigcld(proc_t *cp, sigqueue_t *sqp) argument
1752 post_sigcld(proc_t *cp, sigqueue_t *sqp) argument
1803 sigqueue_t *sqp; local
1860 sigqueue_t *sqp; local
1920 sigqueue_t **psqp, *sqp; local
1968 sigqueue_t **psqp, *sqp; local
2019 sigqueue_t **psqp, *sqp; local
2132 sigqueue_t *sqp; local
2540 siginfofree(sigqueue_t *sqp) argument
2559 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); local
[all...]
H A Daio.c1213 sigqueue_t *sqp; local
1289 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_NOSLEEP);
1290 if (sqp == NULL) {
1294 sqp->sq_func = NULL;
1295 sqp->sq_next = NULL;
1296 sqp->sq_info.si_code = SI_ASYNCIO;
1297 sqp->sq_info.si_pid = curproc->p_pid;
1298 sqp->sq_info.si_ctid = PRCTID(curproc);
1299 sqp->sq_info.si_zoneid = getzoneid();
1300 sqp
2399 sigqueue_t *sqp = NULL; local
2918 sigqueue_t *sqp; local
3296 sigqueue_t *sqp = NULL; local
3397 sigqueue_t *sqp; local
[all...]
H A Dturnstile.c721 sleepq_t *sqp = &ts->ts_sleepq[qnum]; local
732 kthread_t *t = sqp->sq_first;
763 sleepq_t *sqp = t->t_sleepq; local
767 sleepq_insert(sqp, t);
H A Dwatchpoint.c689 register sigqueue_t *sqp; local
695 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
696 sqp->sq_info.si_signo = SIGTRAP;
697 sqp->sq_info.si_code = watchcode;
698 sqp->sq_info.si_addr = addr;
699 sqp->sq_info.si_trapafter = ta;
700 sqp->sq_info.si_pc = (caddr_t)getuserpc();
709 lwp->lwp_siginfo = sqp->sq_info;
713 kmem_free(sqp, sizeof (sigqueue_t));
727 kmem_free(sqp, sizeo
[all...]
H A Drctl.c2548 sigqueue_t *sqp = NULL; local
2573 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
2577 sqp->sq_info.si_signo = recip_signal;
2578 sqp->sq_info.si_code = SI_RCTL;
2579 sqp->sq_info.si_errno = 0;
2580 sqp->sq_info.si_entity = (int)rde->rcd_entity;
2586 if (sqp == NULL) {
2593 sigaddqa(curproc, curthread, sqp);
2595 sigaddqa(p, NULL, sqp);
2620 if (sqp
[all...]
H A Dcondvar.c93 sleepq_t *sqp = t->t_sleepq; local
96 ASSERT(&SQHASH(cvp)->sq_queue == sqp);
102 sleepq_insert(sqp, t);
H A Dexit.c339 sigqueue_t *sqp; local
424 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
851 sigcld(p, sqp);
H A Dstreamio.c8227 queue_t *sqp; local
8232 else if ((sqp = stp->sd_struiowrq) != NULL) {
8236 QLOCK(sqp)) != 0) {
8241 if (sqp->q_flag & QFULL)
8243 sqp->q_flag |= QWANTWSYNC;
8248 mutex_exit(QLOCK(sqp));
8252 mutex_exit(QLOCK(sqp));
H A Dstrsubr.c5156 sqlist_insert(sqlist_t *sqlist, syncq_t *sqp) argument
5162 if (sqlp->sql_sq >= sqp) {
5163 if (sqlp->sql_sq == sqp) /* duplicate */
5172 new_sqlp->sql_sq = sqp;
/illumos-gate/usr/src/uts/common/inet/tcp/
H A Dtcp_time_wait.c132 squeue_t *sqp = tcp->tcp_connp->conn_sqp; local
134 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP));
230 tcp_time_wait_collector, sqp,
255 tcp_time_wait_collector, sqp,
406 squeue_t *sqp = (squeue_t *)arg; local
408 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP));
582 tcp_time_wait_collector, sqp,
H A Dtcp_input.c1847 squeue_t *sqp = (squeue_t *)arg2; local
1891 (void) atomic_cas_ptr(&connp->conn_sqp, sqp,
1915 if (connp->conn_sqp != sqp) {
1920 tcp_input_listener(connp, mp, sqp, ira);
2304 * sqp: NULL = recursive, sqp != NULL means called from squeue
2331 squeue_t *sqp = (squeue_t *)arg2; local
2404 if (sqp != NULL) {
2420 if ((flags & TH_URG) && sqp != NULL) {
2468 tcp_outbound_squeue_switch && sqp !
[all...]
H A Dtcp.c1476 squeue_t *sqp = (squeue_t *)arg; local
1482 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP));
2604 squeue_t *sqp; local
2645 sqp = IP_SQUEUE_GET((uint_t)gethrtime());
2646 connp = (conn_t *)tcp_get_conn(sqp, tcps);
2658 connp->conn_sqp = sqp;
4027 tcp_squeue_add(squeue_t *sqp) argument
4032 *squeue_getprivate(sqp, SQPRIVATE_TCP) = (intptr_t)tcp_time_wait;
/illumos-gate/usr/src/uts/common/inet/nca/
H A Dnca.h203 #define SQ_STATE_IS(sqp, flags) ((sqp)->sq_state & (flags))
204 #define SQ_TYPE_IS(sqp, flags) ((sqp)->sq_type & (flags))
396 nca_squeue_t *sqp; /* squeue node_t is being processed from */ member in struct:node_s
/illumos-gate/usr/src/uts/intel/dtrace/
H A Dfasttrap_isa.c710 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); local
712 sqp->sq_info.si_signo = SIGSEGV;
713 sqp->sq_info.si_code = SEGV_MAPERR;
714 sqp->sq_info.si_addr = (caddr_t)addr;
717 sigaddqa(p, t, sqp);
/illumos-gate/usr/src/uts/common/dtrace/
H A Dfasttrap.c234 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); local
236 sqp->sq_info.si_signo = SIGTRAP;
237 sqp->sq_info.si_code = TRAP_DTRACE;
238 sqp->sq_info.si_addr = (caddr_t)pc;
241 sigaddqa(p, t, sqp);
/illumos-gate/usr/src/uts/common/fs/proc/
H A Dprcontrol.c1411 sigqueue_t *sqp; local
1415 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
1419 lwp->lwp_curinfo = sqp;
1421 kmem_free(sqp, sizeof (sigqueue_t));
/illumos-gate/usr/src/cmd/mdb/common/modules/nca/
H A Dnca.c555 node.datasz, NCA_ADDR_WIDTH, node.sqp, NCA_ADDR_WIDTH,

Completed in 209 milliseconds