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

/opensolaris-onvv-gate/usr/src/uts/common/inet/
H A Dsqueue.c131 static void squeue_worker(squeue_t *sqp);
132 static void squeue_polling_thread(squeue_t *sqp);
147 #define ENQUEUE_CHAIN(sqp, mp, tail, cnt) { \
151 ASSERT(MUTEX_HELD(&(sqp)->sq_lock)); \
153 if ((sqp)->sq_last != NULL) \
154 (sqp)->sq_last->b_next = (mp); \
156 (sqp)->sq_first = (mp); \
157 (sqp)->sq_last = (tail); \
158 (sqp)->sq_count += (cnt); \
159 ASSERT((sqp)
240 squeue_t *sqp = kmem_cache_alloc(squeue_cache, KM_SLEEP); local
266 squeue_bind(squeue_t *sqp, processorid_t bind) argument
290 squeue_unbind(squeue_t *sqp) argument
304 squeue_worker_wakeup(squeue_t *sqp) argument
416 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
672 squeue_t *sqp = arg; local
701 squeue_drain(squeue_t *sqp, uint_t proc_type, hrtime_t expire) argument
941 squeue_poll_thr_control(squeue_t *sqp) argument
1007 squeue_polling_thread(squeue_t *sqp) argument
1178 squeue_worker_thr_control(squeue_t *sqp) argument
1283 squeue_worker(squeue_t *sqp) argument
1345 squeue_getprivate(squeue_t *sqp, sqprivate_t p) argument
1357 squeue_t *sqp = connp->conn_sqp; local
1387 squeue_t *sqp; local
1465 squeue_t *sqp = connp->conn_sqp; local
[all...]
/opensolaris-onvv-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...]
/opensolaris-onvv-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); \
/opensolaris-onvv-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.c2819 sleepq_t *sqp = t->t_sleepq; local
2821 if (sqp != NULL) {
2823 ASSERT(&sqh->sq_queue == sqp);
2847 sleepq_t *sqp = t->t_sleepq; local
2851 sleepq_insert(sqp, t);
/opensolaris-onvv-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);
/opensolaris-onvv-gate/usr/src/uts/common/os/
H A Dsig.c366 sigqueue_t *sqp; local
370 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
376 siginfofree(sqp);
381 sigcld(p, sqp);
1011 sigqueue_t *sqp; local
1017 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
1027 sigcld(p, sqp);
1273 sigqueue_t *sqp = NULL; local
1334 sqp = lwp->lwp_curinfo;
1336 sqp
1681 sigcld(proc_t *cp, sigqueue_t *sqp) argument
1735 post_sigcld(proc_t *cp, sigqueue_t *sqp) argument
1786 sigqueue_t *sqp; local
1843 sigqueue_t *sqp; local
1903 sigqueue_t **psqp, *sqp; local
1951 sigqueue_t **psqp, *sqp; local
2002 sigqueue_t **psqp, *sqp; local
2115 sigqueue_t *sqp; local
2514 siginfofree(sigqueue_t *sqp) argument
2533 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.c714 register sigqueue_t *sqp; local
720 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
721 sqp->sq_info.si_signo = SIGTRAP;
722 sqp->sq_info.si_code = watchcode;
723 sqp->sq_info.si_addr = addr;
724 sqp->sq_info.si_trapafter = ta;
725 sqp->sq_info.si_pc = (caddr_t)getuserpc();
734 lwp->lwp_siginfo = sqp->sq_info;
738 kmem_free(sqp, sizeof (sigqueue_t));
752 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.c91 sleepq_t *sqp = t->t_sleepq; local
94 ASSERT(&SQHASH(cvp)->sq_queue == sqp);
100 sleepq_insert(sqp, t);
H A Dexit.c338 sigqueue_t *sqp; local
417 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
836 sigcld(p, sqp);
H A Dstreamio.c8222 queue_t *sqp; local
8227 else if ((sqp = stp->sd_struiowrq) != NULL) {
8230 polllock(&stp->sd_pollist, QLOCK(sqp));
8231 if (sqp->q_flag & QFULL)
8233 sqp->q_flag |= QWANTWSYNC;
8238 mutex_exit(QLOCK(sqp));
8242 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;
/opensolaris-onvv-gate/usr/src/uts/common/inet/tcp/
H A Dtcp_time_wait.c121 squeue_t *sqp = tcp->tcp_connp->conn_sqp; local
123 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP));
168 tcp_time_wait_collector, sqp,
243 squeue_t *sqp = (squeue_t *)arg; local
245 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP));
423 sqp, firetime, CALLOUT_TCP_RESOLUTION,
H A Dtcp_input.c1896 squeue_t *sqp = (squeue_t *)arg2; local
1940 (void) casptr(&connp->conn_sqp, sqp, new_sqp);
1963 if (connp->conn_sqp != sqp) {
1968 tcp_input_listener(connp, mp, sqp, ira);
2244 * sqp: NULL = recursive, sqp != NULL means called from squeue
2271 squeue_t *sqp = (squeue_t *)arg2; local
2343 if (sqp != NULL) {
2359 if ((flags & TH_URG) && sqp != NULL) {
2402 tcp_outbound_squeue_switch && sqp !
[all...]
H A Dtcp.c1477 squeue_t *sqp = (squeue_t *)arg; local
1483 *((tcp_squeue_priv_t **)squeue_getprivate(sqp, SQPRIVATE_TCP));
2592 squeue_t *sqp; local
2633 sqp = IP_SQUEUE_GET((uint_t)gethrtime());
2634 connp = (conn_t *)tcp_get_conn(sqp, tcps);
2646 connp->conn_sqp = sqp;
4007 tcp_squeue_add(squeue_t *sqp) argument
4012 *squeue_getprivate(sqp, SQPRIVATE_TCP) = (intptr_t)tcp_time_wait;
/opensolaris-onvv-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
/opensolaris-onvv-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);
/opensolaris-onvv-gate/usr/src/uts/common/dtrace/
H A Dfasttrap.c231 sigqueue_t *sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); local
233 sqp->sq_info.si_signo = SIGTRAP;
234 sqp->sq_info.si_code = TRAP_DTRACE;
235 sqp->sq_info.si_addr = (caddr_t)pc;
238 sigaddqa(p, t, sqp);
/opensolaris-onvv-gate/usr/src/uts/common/fs/proc/
H A Dprcontrol.c1407 sigqueue_t *sqp; local
1411 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP);
1415 lwp->lwp_curinfo = sqp;
1417 kmem_free(sqp, sizeof (sigqueue_t));
/opensolaris-onvv-gate/usr/src/cmd/mdb/common/modules/nca/
H A Dnca.c555 node.datasz, NCA_ADDR_WIDTH, node.sqp, NCA_ADDR_WIDTH,

Completed in 341 milliseconds