/opensolaris-onvv-gate/usr/src/uts/common/inet/ |
H A D | squeue.c | 131 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 D | ip_squeue.c | 164 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 D | squeue.h | 50 #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 D | signotify.c | 96 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 D | lwpsys.c | 116 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 D | lwp_sobj.c | 2819 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 D | dtrace_subr.c | 103 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 D | sig.c | 366 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 D | aio.c | 1213 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 D | turnstile.c | 721 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 D | watchpoint.c | 714 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 D | rctl.c | 2548 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 D | condvar.c | 91 sleepq_t *sqp = t->t_sleepq; local 94 ASSERT(&SQHASH(cvp)->sq_queue == sqp); 100 sleepq_insert(sqp, t);
|
H A D | exit.c | 338 sigqueue_t *sqp; local 417 sqp = kmem_zalloc(sizeof (sigqueue_t), KM_SLEEP); 836 sigcld(p, sqp);
|
H A D | streamio.c | 8222 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 D | strsubr.c | 5156 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 D | tcp_time_wait.c | 121 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 D | tcp_input.c | 1896 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 D | tcp.c | 1477 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 D | nca.h | 203 #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 D | fasttrap_isa.c | 710 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 D | fasttrap.c | 231 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 D | prcontrol.c | 1407 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 D | nca.c | 555 node.datasz, NCA_ADDR_WIDTH, node.sqp, NCA_ADDR_WIDTH,
|