Home
last modified time | relevance | path

Searched refs:q (Results 1 – 25 of 1369) sorted by relevance

12345678910>>...55

/illumos-gate/usr/src/uts/common/gssapi/mechs/krb5/mech/
H A Dutil_ordering.c63 #define QSIZE(q) (sizeof((q)->elem)/sizeof((q)->elem[0])) argument
64 #define QELEM(q,i) ((q)->elem[(i)%QSIZE(q)]) argument
150 if (q->length == QSIZE(q)) { in queue_insert()
152 if (q->start == QSIZE(q)) in queue_insert()
175 q->elem[q->start] = ((gssint_uint64)0 - 1) & q->mask; in g_order_init()
206 expected = (QELEM(q,q->start+q->length-1)+1) & q->mask; in g_order_check()
208 queue_insert(q, q->start+q->length-1, seqnum); in g_order_check()
214 queue_insert(q, q->start+q->length-1, seqnum); in g_order_check()
222 if (after(QELEM(q,q->start), seqnum, q->mask)) { in g_order_check()
232 if (seqnum == QELEM(q,q->start+q->length-1)) in g_order_check()
[all …]
/illumos-gate/usr/src/uts/common/io/1394/targets/av1394/
H A Dav1394_queue.c49 AV1394_ENTERQ(q); in av1394_initq()
51 q->q_max = max; in av1394_initq()
52 AV1394_LEAVEQ(q); in av1394_initq()
58 av1394_flushq(q); in av1394_destroyq()
66 AV1394_ENTERQ(q); in av1394_setmaxq()
67 q->q_max = max; in av1394_setmaxq()
68 AV1394_LEAVEQ(q); in av1394_setmaxq()
76 AV1394_ENTERQ(q); in av1394_getmaxq()
77 max = q->q_max; in av1394_getmaxq()
147 if ((ret = cv_wait_sig(&q->q_cv, &q->q_mutex)) <= 0) { in av1394_qwait_sig()
[all …]
/illumos-gate/usr/src/lib/libdtrace/common/
H A Ddt_string.c69 *q++ = c; in stresc2chr()
111 *q++ = c; in stresc2chr()
115 *q++ = c; in stresc2chr()
122 *q++ = c; in stresc2chr()
126 *q = '\0'; in stresc2chr()
171 *q++ = '0'; in strchr2esc()
210 *q++ = c; in strchr2esc()
219 *q++ = c; in strchr2esc()
226 *q = '\0'; in strchr2esc()
299 char *p, *q; in strhyphenate() local
[all …]
/illumos-gate/usr/src/uts/common/fs/zfs/
H A Dbqueue.c43 q->bq_size = 0; in bqueue_init()
44 q->bq_maxsize = size; in bqueue_init()
56 ASSERT0(q->bq_size); in bqueue_destroy()
75 while (q->bq_size + item_size > q->bq_maxsize) { in bqueue_enqueue()
76 cv_wait(&q->bq_add_cv, &q->bq_lock); in bqueue_enqueue()
78 q->bq_size += item_size; in bqueue_enqueue()
81 mutex_exit(&q->bq_lock); in bqueue_enqueue()
94 cv_wait(&q->bq_pop_cv, &q->bq_lock); in bqueue_dequeue()
98 q->bq_size -= item_size; in bqueue_dequeue()
99 mutex_exit(&q->bq_lock); in bqueue_dequeue()
[all …]
/illumos-gate/usr/src/cmd/auditd/
H A Dqueue.c46 q->auq_head = NULL; in audit_queue_init()
47 q->auq_tail = NULL; in audit_queue_init()
49 q->auq_count = 0; in audit_queue_init()
67 (void *)q, (void *)p, (void *)q->auq_head, (void *)q->auq_tail, in audit_enqueue()
71 q->auq_head = p; in audit_enqueue()
78 q->auq_tail = p; in audit_enqueue()
80 q->auq_count++; in audit_enqueue()
84 (void *)q->auq_tail, q->auq_count, in audit_enqueue()
102 (void *)q->auq_head, (void *)q->auq_tail, q->auq_count)); in audit_dequeue()
107 q->auq_count--; in audit_dequeue()
[all …]
/illumos-gate/usr/src/uts/common/io/
H A Drlmod.c239 qprocson(q); in rlmodopen()
292 qprocsoff(q); in rlmodopen()
327 qprocsoff(q); in rlmodclose()
354 q->q_ptr = WR(q)->q_ptr = NULL; in rlmodclose()
437 if (canputnext(q) && q->q_first == NULL) { in rlmodrput()
1282 enableok(q); in rlmod_timer()
1283 qenable(q); in rlmod_timer()
1300 enableok(q); in rlmod_buffer()
1301 qenable(q); in rlmod_buffer()
1312 noenable(q); in recover()
[all …]
H A Dtelmod.c231 noenable(q); in telmodopen()
233 qprocson(q); in telmodopen()
286 qprocsoff(q); in telmodopen()
320 qprocsoff(q); in telmodclose()
342 q->q_ptr = WR(q)->q_ptr = NULL; in telmodclose()
838 if (!canputnext(q) || q->q_first != NULL) in telmodwput()
1213 enableok(q); in telmod_timer()
1214 qenable(q); in telmod_timer()
1232 enableok(q); in telmod_buffer()
1233 qenable(q); in telmod_buffer()
[all …]
H A Dtirdwr.c158 queue_t *q, in tirdwropen() argument
167 if (q->q_ptr) { in tirdwropen()
181 qprocson(q); in tirdwropen()
183 freezestr(q); in tirdwropen()
186 (void) strqset(q, QMAXPSZ, 0, (uintptr_t)q->q_next->q_maxpsz); in tirdwropen()
189 unfreezestr(q); in tirdwropen()
190 qprocsoff(q); in tirdwropen()
195 unfreezestr(q); in tirdwropen()
213 qprocsoff(q); in tirdwrclose()
374 qreply(q, mp); in send_fatal()
[all …]
H A Dptem.c209 ntp->q_ptr = q; in ptemopen()
210 q->q_ptr = ntp; in ptemopen()
239 qprocson(q); in ptemopen()
240 putnext(q, mop); in ptemopen()
256 qprocsoff(q); in ptemclose()
260 q->q_ptr = WR(q)->q_ptr = NULL; in ptemclose()
313 qreply(q, mp); in ptemrput()
392 qreply(q, mp); in ptemrput()
512 qenable(q); in ptemwput()
524 if (q->q_first != NULL || !bcanputnext(q, mp->b_band)) { in ptemwput()
[all …]
H A Dpckt.c235 q->q_ptr = pip; in pcktopen()
238 qprocson(q); in pcktopen()
251 qprocsoff(q); in pcktopen()
292 qprocsoff(q); in pcktclose()
305 q->q_ptr = WR(q)->q_ptr = NULL; in pcktclose()
372 if (!canputnext(q) || (qsize(q) > 0)) { in pcktrput()
437 noenable(q); in pcktrsrv()
519 noenable(q); in pckt_reallocb()
577 noenable(q); in add_ctl_info()
692 enableok(q); in add_ctl_wkup()
[all …]
H A Dstream.c2038 if (q->q_mblkcnt == 0 || ((q->q_count < q->q_hiwat) && in getq_noenab()
2118 if (q->q_lowat == 0 || (q->q_count < q->q_lowat && in qbackenable()
2255 if (q->q_mblkcnt == 0 || ((q->q_count < q->q_hiwat) && in rmvq_noenab()
2345 (q->q_mblkcnt < q->q_lowat)) || q->q_lowat == 0)) { in flushq_common()
2495 q = q->q_nfsrv; in canput()
2529 q = q->q_nfsrv; in bcanput()
3166 q = _OTHERQ(q); in backq()
3168 q = q->q_next; in backq()
4083 q = _OTHERQ(q); in create_syncq_putlocks()
4126 q = _WR(q); in create_putlocks()
[all …]
H A Dtimod.c352 queue_t *q, in timodopen() argument
459 qenable(q); in tim_timer()
478 qenable(q); in tim_buffer()
488 queue_t *q, in timodclose() argument
551 q->q_ptr = WR(q)->q_ptr = NULL; in timodclose()
2569 tid = qtimeout(RD(q), tim_timer, q, TIMWAIT); in tim_recover()
2615 q = rq; in ti_expind_on_rdqueues()
2800 q = RD(q); in tim_send_ioc_error_ack()
2865 ASSERT(q == RD(q)); in tim_send_reply()
2891 ASSERT(q != NULL && q == WR(q) && ackmp != NULL); in tim_answer_ti_sync()
[all …]
H A Dlogindmux.c315 tmxp->rdq = q; in logdmuxopen()
325 qprocson(q); in logdmuxopen()
342 qprocsoff(q); in logdmuxclose()
1043 tmxp->utimoutid = qtimeout(q, logdmux_unlink_timer, q, in logdmuxunlink()
1117 tmxp->utimoutid = qtimeout(q, logdmux_unlink_timer, q, in logdmux_unlink_timer()
1147 enableok(q); in logdmux_timer()
1148 qenable(q); in logdmux_timer()
1166 enableok(q); in logdmux_buffer()
1167 qenable(q); in logdmux_buffer()
1182 noenable(q); in recover()
[all …]
/illumos-gate/usr/src/lib/libslp/clib/
H A Dslp_queue.c97 if ((q = malloc(sizeof (*q))) == NULL) { in slp_new_queue()
106 q->count = 0; in slp_new_queue()
108 return (q); in slp_new_queue()
132 q->head = q->tail = qe; in slp_enqueue()
134 q->count++; in slp_enqueue()
159 q->count++; in slp_enqueue_at_head()
177 q->head = q->tail = NULL; in dequeue_nolock()
181 q->count--; in dequeue_nolock()
208 err = cond_timedwait(q->wait, q->lock, to); in slp_dequeue_timed()
210 err = cond_wait(q->wait, q->lock); in slp_dequeue_timed()
[all …]
/illumos-gate/usr/src/cmd/sendmail/src/
H A Darpadate.c84 q = b;
87 *q++ = *p++;
88 *q++ = *p++;
89 *q++ = *p++;
90 *q++ = ',';
91 *q++ = ' ';
99 *q++ = ' ';
105 *q++ = ' ';
112 *q++ = ' ';
140 *q++ = ' ';
[all …]
/illumos-gate/usr/src/cmd/idmap/idmapd/
H A Dnldaputils.c317 q->rc = rc; in idmap_nldap_bywinname_batch_add()
319 q->dn = dn; in idmap_nldap_bywinname_batch_add()
421 &q->errorp, &q->lrc, NULL, q->udata); in idmap_nldap_bywinname_batch_add()
457 q->rc = rc; in idmap_nldap_bypid_batch_add()
459 q->dn = dn; in idmap_nldap_bypid_batch_add()
495 &q->errorp, &q->lrc, NULL, q->udata); in idmap_nldap_bypid_batch_add()
524 q->rc = rc; in idmap_nldap_byunixname_batch_add()
526 q->dn = dn; in idmap_nldap_byunixname_batch_add()
575 &q->errorp, &q->lrc, NULL, q->udata); in idmap_nldap_byunixname_batch_add()
625 *q->rc = nldaprc2retcode(q->lrc); in idmap_nldap_lookup_batch_end()
[all …]
/illumos-gate/usr/src/cmd/isns/isnsd/
H A Dmsgq.c43 msg_queue_t *q; in queue_calloc() local
47 if (q) { in queue_calloc()
50 free(q); in queue_calloc()
51 q = NULL; in queue_calloc()
55 return (q); in queue_calloc()
60 msg_queue_t *q, in queue_msg_set() argument
80 q->q_head = msg; in queue_msg_set()
81 q->q_tail = msg; in queue_msg_set()
86 q->q_tail = msg; in queue_msg_set()
98 msg_queue_t *q in queue_msg_get() argument
[all …]
/illumos-gate/usr/src/uts/common/rpc/
H A Drpcmod.c506 qprocson(q); in rmm_open()
536 qprocsoff(q); in rmm_open()
548 (*((struct temp_slot *)q->q_ptr)->ops->xo_rput)(q, mp); in rmm_rput()
555 (*((struct temp_slot *)q->q_ptr)->ops->xo_rsrv)(q); in rmm_rsrv()
562 (*((struct temp_slot *)q->q_ptr)->ops->xo_wput)(q, mp); in rmm_wput()
569 (*((struct temp_slot *)q->q_ptr)->ops->xo_wsrv)(q); in rmm_wsrv()
671 qprocsoff(q); in rpcmodclose()
677 qprocsoff(q); in rpcmodclose()
1318 noenable(q); in mir_open()
1320 qprocson(q); in mir_open()
[all …]
/illumos-gate/usr/src/uts/common/os/
H A Dddi.c263 RD(queue_t *q) in RD() argument
282 WR(queue_t *q) in WR() argument
485 claimstr(q); in bcanputnext()
487 releasestr(q); in bcanputnext()
509 q = q->q_next->q_nfsrv; in canputnext()
513 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(qofsq)); in canputnext()
573 if ((q->q_next == NULL && WR(q)->q_next == NULL) || in qprocson()
575 insertq(STREAM(q), q); in qprocson()
604 removeq(q); in qprocsoff()
636 strblock(q); in freezestr()
[all …]
/illumos-gate/usr/src/cmd/sh/
H A Dblok.c80 struct blk *q; in alloc() local
100 q = p; in alloc()
222 if (q < (struct blk *)brkbegin || q > bloktop) in chkbptr()
233 if (p >= q) in chkbptr()
236 p = q; in chkbptr()
252 if (q < (struct blk *)brkbegin || q > bloktop) in chkmem()
263 if (p >= q) in chkmem()
266 p = q; in chkmem()
282 blklen(q) in blklen() argument
283 char *q; in blklen()
[all …]
/illumos-gate/usr/src/cmd/mdb/common/mdb/
H A Dmdb_string.c320 *q++ = c; in stresc2chr()
346 *q++ = c; in stresc2chr()
350 *q++ = c; in stresc2chr()
357 *q++ = c; in stresc2chr()
361 *q = '\0'; in stresc2chr()
405 *q++ = '0'; in strchr2esc()
444 *q++ = c; in strchr2esc()
453 *q++ = c; in strchr2esc()
457 *q = '\0'; in strchr2esc()
492 *q++ = c; in strchr2adb()
[all …]
/illumos-gate/usr/src/lib/libipmi/common/
H A Dipmi_list.c46 lp->l_prev = q; in ipmi_list_append()
47 q->l_prev = p; in ipmi_list_append()
52 p->l_next = q; in ipmi_list_append()
67 p->l_next = q; in ipmi_list_prepend()
71 q->l_prev = p; in ipmi_list_prepend()
90 q->l_next = p; in ipmi_list_insert_before()
91 p->l_prev = q; in ipmi_list_insert_before()
92 q->l_prev->l_next = q; in ipmi_list_insert_before()
107 q->l_prev = p; in ipmi_list_insert_after()
108 p->l_next = q; in ipmi_list_insert_after()
[all …]
/illumos-gate/usr/src/cmd/fm/fmd/common/
H A Dfmd_list.c53 lp->l_prev = q; in fmd_list_append()
54 q->l_prev = p; in fmd_list_append()
59 p->l_next = q; in fmd_list_append()
74 p->l_next = q; in fmd_list_prepend()
78 q->l_prev = p; in fmd_list_prepend()
97 q->l_next = p; in fmd_list_insert_before()
98 p->l_prev = q; in fmd_list_insert_before()
99 q->l_prev->l_next = q; in fmd_list_insert_before()
114 q->l_prev = p; in fmd_list_insert_after()
115 p->l_next = q; in fmd_list_insert_after()
[all …]
/illumos-gate/usr/src/uts/common/inet/dlpistub/
H A Ddlpistub.c140 if (q->q_ptr != NULL) in ds_open()
159 q->q_ptr = WR(q)->q_ptr = dsp; in ds_open()
160 qprocson(q); in ds_open()
169 dlpistub_t *dsp = q->q_ptr; in ds_close()
171 qprocsoff(q); in ds_close()
172 q->q_ptr = WR(q)->q_ptr = NULL; in ds_close()
195 ds_wput(queue_t *q, mblk_t *mp) in ds_wput() argument
199 dlpistub_t *dsp = q->q_ptr; in ds_wput()
246 qreply(q, mp); in ds_wput()
291 miocnak(q, mp, 0, EINVAL); in ds_wput()
[all …]
/illumos-gate/usr/src/lib/libadm/common/
H A Ddgrpent.c154 char *p, *q; in getfld() local
175 q = p; in getfld()
176 while (*q && !strchr(delims, *q)) q++; in getfld()
177 if (*q) { in getfld()
519 for (q = ent->membership; q; q = r) { in _getdgrptabent()
522 free(q); in _getdgrptabent()
530 for (q = ent->membership; q; q = r) { in _getdgrptabent()
533 free(q); in _getdgrptabent()
543 q = r; in _getdgrptabent()
597 p = q; in _freedgrptabent()
[all …]

12345678910>>...55