Home
last modified time | relevance | path

Searched refs:q (Results 1 – 25 of 1371) 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
129 queue_insert(queue *q, int after, gssint_uint64 seqnum) in queue_insert() argument
139 for (i=q->start+q->length-1; i>after; i--) in queue_insert()
140 QELEM(q,i+1) = QELEM(q,i); in queue_insert()
144 QELEM(q,after+1) = seqnum; in queue_insert()
150 if (q->length == QSIZE(q)) { in queue_insert()
151 q->start++; in queue_insert()
152 if (q->start == QSIZE(q)) in queue_insert()
153 q->start = 0; in queue_insert()
[all …]
/illumos-gate/usr/src/uts/common/io/1394/targets/av1394/
H A Dav1394_queue.c42 av1394_initq(av1394_queue_t *q, ddi_iblock_cookie_t ibc, int max) in av1394_initq() argument
44 bzero(q, sizeof (av1394_queue_t)); in av1394_initq()
46 mutex_init(&q->q_mutex, NULL, MUTEX_DRIVER, ibc); in av1394_initq()
47 cv_init(&q->q_cv, NULL, CV_DRIVER, NULL); in av1394_initq()
49 AV1394_ENTERQ(q); in av1394_initq()
50 av1394_list_init(&q->q_list); in av1394_initq()
51 q->q_max = max; in av1394_initq()
52 AV1394_LEAVEQ(q); in av1394_initq()
56 av1394_destroyq(av1394_queue_t *q) in av1394_destroyq() argument
58 av1394_flushq(q); in av1394_destroyq()
[all …]
/illumos-gate/usr/src/lib/libdtrace/common/
H A Ddt_string.c41 char *p, *q, c; in stresc2chr() local
45 for (p = q = s; (c = *p) != '\0'; p++) { in stresc2chr()
69 *q++ = c; in stresc2chr()
73 *q++ = '\a'; in stresc2chr()
76 *q++ = '\b'; in stresc2chr()
79 *q++ = '\f'; in stresc2chr()
82 *q++ = '\n'; in stresc2chr()
85 *q++ = '\r'; in stresc2chr()
88 *q++ = '\t'; in stresc2chr()
91 *q++ = '\v'; in stresc2chr()
[all …]
/illumos-gate/usr/src/uts/common/fs/zfs/
H A Dbqueue.c23 obj2node(bqueue_t *q, void *data) in obj2node() argument
25 return ((bqueue_node_t *)((char *)data + q->bq_node_offset)); in obj2node()
35 bqueue_init(bqueue_t *q, uint64_t size, size_t node_offset) in bqueue_init() argument
37 list_create(&q->bq_list, node_offset + sizeof (bqueue_node_t), in bqueue_init()
39 cv_init(&q->bq_add_cv, NULL, CV_DEFAULT, NULL); in bqueue_init()
40 cv_init(&q->bq_pop_cv, NULL, CV_DEFAULT, NULL); in bqueue_init()
41 mutex_init(&q->bq_lock, NULL, MUTEX_DEFAULT, NULL); in bqueue_init()
42 q->bq_node_offset = node_offset; in bqueue_init()
43 q->bq_size = 0; in bqueue_init()
44 q->bq_maxsize = size; in bqueue_init()
[all …]
/illumos-gate/usr/src/cmd/auditd/
H A Dqueue.c44 audit_queue_init(au_queue_t *q) in audit_queue_init() argument
46 q->auq_head = NULL; in audit_queue_init()
47 q->auq_tail = NULL; in audit_queue_init()
48 (void) pthread_mutex_init(&q->auq_lock, NULL); in audit_queue_init()
49 q->auq_count = 0; in audit_queue_init()
62 audit_enqueue(au_queue_t *q, void *p) in audit_enqueue() argument
64 (void) pthread_mutex_lock(&q->auq_lock); in audit_enqueue()
67 (void *)q, (void *)p, (void *)q->auq_head, (void *)q->auq_tail, in audit_enqueue()
68 q->auq_count)); in audit_enqueue()
70 if (q->auq_head == NULL) in audit_enqueue()
[all …]
/illumos-gate/usr/src/uts/common/io/
H A Drlmod.c202 rlmodopen(queue_t *q, dev_t *devp, int oflag, int sflag, cred_t *cred) in rlmodopen() argument
212 if (q->q_ptr != NULL) { in rlmodopen()
225 q->q_ptr = rmip; in rlmodopen()
226 WR(q)->q_ptr = rmip; in rlmodopen()
239 qprocson(q); in rlmodopen()
252 bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), in rlmodopen()
254 if (!qwait_sig(q)) { in rlmodopen()
255 qunbufcall(q, id); in rlmodopen()
259 qunbufcall(q, id); in rlmodopen()
274 bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), in rlmodopen()
[all …]
H A Dtelmod.c132 static int rcv_parse(queue_t *q, mblk_t *mp);
133 static int snd_parse(queue_t *q, mblk_t *mp);
206 telmodopen(queue_t *q, dev_t *devp, int oflag, int sflag, cred_t *credp) in telmodopen() argument
216 if (q->q_ptr != NULL) { in telmodopen()
228 q->q_ptr = tmip; in telmodopen()
229 WR(q)->q_ptr = tmip; in telmodopen()
231 noenable(q); in telmodopen()
233 qprocson(q); in telmodopen()
246 bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), in telmodopen()
248 if (!qwait_sig(q)) { in telmodopen()
[all …]
H A Dtirdwr.c65 static int tirdwropen(queue_t *q, dev_t *dev,
68 static int tirdwrclose(queue_t *q, int flag, cred_t *cr);
70 static int check_strhead(queue_t *q);
76 static int tirdwrrput(queue_t *q, mblk_t *mp);
77 static int tirdwrwput(queue_t *q, mblk_t *mp);
147 static void send_fatal(queue_t *q, mblk_t *mp);
148 static void strip_strhead(queue_t *q);
158 queue_t *q, in tirdwropen() argument
167 if (q->q_ptr) { in tirdwropen()
178 trwptr->trw_rdq = q; in tirdwropen()
[all …]
H A Dptem.c150 queue_t *q, /* pointer to the read side queue */ in ptemopen() argument
165 if (q->q_ptr != NULL) { in ptemopen()
209 ntp->q_ptr = q; in ptemopen()
210 q->q_ptr = ntp; in ptemopen()
211 WR(q)->q_ptr = ntp; in ptemopen()
239 qprocson(q); in ptemopen()
240 putnext(q, mop); in ptemopen()
252 ptemclose(queue_t *q, int flag, cred_t *credp) in ptemclose() argument
256 qprocsoff(q); in ptemclose()
257 ntp = (struct ptem *)q->q_ptr; in ptemclose()
[all …]
H A Dpckt.c204 queue_t *q, /* pointer to the read side queue */ in pcktopen() argument
217 if (q->q_ptr != NULL) { in pcktopen()
234 pip->pi_qptr = q; in pcktopen()
235 q->q_ptr = pip; in pcktopen()
236 WR(q)->q_ptr = pip; in pcktopen()
238 qprocson(q); in pcktopen()
246 bufcall_id_t id = qbufcall(q, sizeof (struct stroptions), in pcktopen()
248 if (!qwait_sig(q)) { in pcktopen()
249 qunbufcall(q, id); in pcktopen()
251 qprocsoff(q); in pcktopen()
[all …]
H A Dstream.c1859 getq(queue_t *q) in getq() argument
1864 bp = getq_noenab(q, 0); in getq()
1872 if (band == 0 && (q->q_flag & (QWANTW|QWANTWSYNC)) == 0) in getq()
1875 qbackenable(q, band); in getq()
1913 getq_noenab(queue_t *q, ssize_t rbytes) in getq_noenab() argument
1922 freezer = STREAM(q)->sd_freezer; in getq_noenab()
1924 ASSERT(frozenstr(q)); in getq_noenab()
1925 ASSERT(MUTEX_HELD(QLOCK(q))); in getq_noenab()
1927 mutex_enter(QLOCK(q)); in getq_noenab()
1929 if ((bp = q->q_first) == 0) { in getq_noenab()
[all …]
H A Dtimod.c352 queue_t *q, in timodopen() argument
362 ASSERT(q != NULL); in timodopen()
364 if (q->q_ptr) { in timodopen()
378 q->q_ptr = (caddr_t)tp; in timodopen()
379 WR(q)->q_ptr = (caddr_t)tp; in timodopen()
382 tilogp("timodopen: Allocated for q %lx\n", (uintptr_t)q); in timodopen()
385 qprocson(q); in timodopen()
387 tp->tim_provinfo = tpi_findprov(q); in timodopen()
413 driverq = WR(q); in timodopen()
438 putnext(q, bp); in timodopen()
[all …]
H A Dlogindmux.c279 logdmuxopen(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *crp) in logdmuxopen() argument
315 tmxp->rdq = q; in logdmuxopen()
322 q->q_ptr = tmxp; in logdmuxopen()
323 WR(q)->q_ptr = tmxp; in logdmuxopen()
325 qprocson(q); in logdmuxopen()
334 logdmuxclose(queue_t *q, int flag, cred_t *crp) in logdmuxclose() argument
336 struct tmx *tmxp = q->q_ptr; in logdmuxclose()
342 qprocsoff(q); in logdmuxclose()
344 qunbufcall(q, tmxp->wbufcid); in logdmuxclose()
348 qunbufcall(q, tmxp->rbufcid); in logdmuxclose()
[all …]
/illumos-gate/usr/src/lib/libslp/clib/
H A Dslp_queue.c77 struct queue *q; in slp_new_queue() local
97 if ((q = malloc(sizeof (*q))) == NULL) { in slp_new_queue()
103 q->head = NULL; in slp_new_queue()
104 q->lock = lock; in slp_new_queue()
105 q->wait = wait; in slp_new_queue()
106 q->count = 0; in slp_new_queue()
108 return (q); in slp_new_queue()
118 struct queue *q = qa; in slp_enqueue() local
125 (void) mutex_lock(q->lock); in slp_enqueue()
128 if (q->head != NULL) { /* queue is not emptry */ in slp_enqueue()
[all …]
/illumos-gate/usr/src/cmd/sendmail/src/
H A Darpadate.c60 register char *q; variable
84 q = b;
87 *q++ = *p++;
88 *q++ = *p++;
89 *q++ = *p++;
90 *q++ = ',';
91 *q++ = ' ';
97 *q++ = *p++;
98 *q++ = *p++;
99 *q++ = ' ';
[all …]
/illumos-gate/usr/src/cmd/idmap/idmapd/
H A Dnldaputils.c214 char *q, *s_str = NULL; in sanitize_for_ldap_filter() local
229 for (p = str, q = s_str; *p; p++) { in sanitize_for_ldap_filter()
232 *q++ = '\\'; in sanitize_for_ldap_filter()
233 *q++ = hex_char(*p >> 4); in sanitize_for_ldap_filter()
234 *q++ = hex_char(*p & 0xf); in sanitize_for_ldap_filter()
236 *q++ = *p; in sanitize_for_ldap_filter()
305 idmap_nldap_q_t *q; in idmap_nldap_bywinname_batch_add() local
314 q = &(qs->queries[qs->qid++]); in idmap_nldap_bywinname_batch_add()
315 q->unixname = unixname; in idmap_nldap_bywinname_batch_add()
316 q->pid = pid; in idmap_nldap_bywinname_batch_add()
[all …]
/illumos-gate/usr/src/cmd/isns/isnsd/
H A Dmsgq.c43 msg_queue_t *q; in queue_calloc() local
45 q = (msg_queue_t *)calloc(1, sizeof (msg_queue_t)); in queue_calloc()
47 if (q) { in queue_calloc()
48 if (sema_init(&q->q_sema, 0, USYNC_THREAD, NULL) || in queue_calloc()
49 pthread_mutex_init(&q->q_mutex, NULL)) { 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
76 (void) pthread_mutex_lock(&q->q_mutex); in queue_msg_set()
[all …]
/illumos-gate/usr/src/uts/common/rpc/
H A Drpcmod.c228 static int mir_close(queue_t *q);
229 static int mir_open(queue_t *q, dev_t *devp, int flag, int sflag,
231 static void mir_rput(queue_t *q, mblk_t *mp);
232 static void mir_rsrv(queue_t *q);
233 static void mir_wput(queue_t *q, mblk_t *mp);
234 static void mir_wsrv(queue_t *q);
428 void tmp_rput(queue_t *q, mblk_t *mp);
440 tmp_rput(queue_t *q, mblk_t *mp) in tmp_rput() argument
442 struct temp_slot *t = (struct temp_slot *)(q->q_ptr); in tmp_rput()
471 rmm_open(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *crp) in rmm_open() argument
[all …]
/illumos-gate/usr/src/uts/common/os/
H A Dddi.c254 OTHERQ(queue_t *q) in OTHERQ() argument
256 return (_OTHERQ(q)); in OTHERQ()
263 RD(queue_t *q) in RD() argument
265 return (_RD(q)); in RD()
273 SAMESTR(queue_t *q) in SAMESTR() argument
275 return (_SAMESTR(q)); in SAMESTR()
282 WR(queue_t *q) in WR() argument
284 return (_WR(q)); in WR()
481 bcanputnext(queue_t *q, unsigned char band) in bcanputnext() argument
485 claimstr(q); in bcanputnext()
[all …]
/illumos-gate/usr/src/cmd/mdb/common/mdb/
H A Dmdb_string.c293 char *p, *q, c; in stresc2chr() local
296 for (p = q = s; (c = *p) != '\0'; p++) { in stresc2chr()
320 *q++ = c; in stresc2chr()
324 *q++ = '\a'; in stresc2chr()
327 *q++ = '\b'; in stresc2chr()
330 *q++ = '\f'; in stresc2chr()
333 *q++ = '\n'; in stresc2chr()
336 *q++ = '\r'; in stresc2chr()
339 *q++ = '\t'; in stresc2chr()
342 *q++ = '\v'; in stresc2chr()
[all …]
/illumos-gate/usr/src/cmd/sh/
H A Dblok.c80 struct blk *q; in alloc() local
85 while (!busy(q = p->word)) in alloc()
86 p->word = q->word; in alloc()
87 if ((char *)q - (char *)p >= rbytes) { in alloc()
90 if (q > blokp) in alloc()
100 q = p; in alloc()
102 } while (p > q || (c++) == 0); in alloc()
213 struct blk *q; in chkbptr() local
217 q = (struct blk *)(Rcheat(p->word) & ~BUSY); in chkbptr()
222 if (q < (struct blk *)brkbegin || q > bloktop) in chkbptr()
[all …]
/illumos-gate/usr/src/cmd/fm/fmd/common/
H A Dfmd_list.c51 fmd_list_t *q = new; /* q = new list element */ in fmd_list_append() local
53 lp->l_prev = q; in fmd_list_append()
54 q->l_prev = p; in fmd_list_append()
55 q->l_next = NULL; in fmd_list_append()
59 p->l_next = q; in fmd_list_append()
62 lp->l_next = q; in fmd_list_append()
70 fmd_list_t *q = lp->l_next; /* q = head list element */ in fmd_list_prepend() local
74 p->l_next = q; in fmd_list_prepend()
76 if (q != NULL) { in fmd_list_prepend()
77 ASSERT(q->l_prev == NULL); in fmd_list_prepend()
[all …]
/illumos-gate/usr/src/lib/libipmi/common/
H A Dipmi_list.c44 ipmi_list_t *q = new; /* q = new list element */ in ipmi_list_append() local
46 lp->l_prev = q; in ipmi_list_append()
47 q->l_prev = p; in ipmi_list_append()
48 q->l_next = NULL; in ipmi_list_append()
52 p->l_next = q; in ipmi_list_append()
55 lp->l_next = q; in ipmi_list_append()
63 ipmi_list_t *q = lp->l_next; /* q = head list element */ in ipmi_list_prepend() local
67 p->l_next = q; in ipmi_list_prepend()
69 if (q != NULL) { in ipmi_list_prepend()
70 assert(q->l_prev == NULL); in ipmi_list_prepend()
[all …]
/illumos-gate/usr/src/uts/common/inet/dlpistub/
H A Ddlpistub.c132 ds_open(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp) in ds_open() argument
140 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()
167 ds_close(queue_t *q, int flag, cred_t *credp) in ds_close() argument
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()
181 ds_badprim(queue_t *q, mblk_t *mp, t_scalar_t prim) in ds_badprim() argument
183 dlerrorack(q, mp, prim, DL_BADPRIM, 0); in ds_badprim()
[all …]
/illumos-gate/usr/src/contrib/mDNSResponder/mDNSCore/
H A DuDNS.c238 mDNSexport void PenalizeDNSServer(mDNS *const m, DNSQuestion *q, mDNSOpaque16 responseFlags) in PenalizeDNSServer() argument
241 DNSServer *orig = q->qDNSServer; in PenalizeDNSServer()
248 …(q->qDNSServer ? &q->qDNSServer->addr : mDNSNULL), q, DM_NAME_PARAM(&q->qname), DNSTypeName(q->qty… in PenalizeDNSServer()
252 if (mDNSOpaque16IsZero(q->responseFlags)) in PenalizeDNSServer()
253 q->responseFlags = responseFlags; in PenalizeDNSServer()
259 if (!q->qDNSServer) in PenalizeDNSServer()
275 if (q->qtype == kDNSType_PTR) in PenalizeDNSServer()
292 q->qtype, reason); in PenalizeDNSServer()
293 q->qDNSServer->penaltyTime = NonZeroTime(m->timenow + DNSSERVER_PENALTY_TIME); in PenalizeDNSServer()
302 new = GetServerForQuestion(m, q); in PenalizeDNSServer()
[all …]

12345678910>>...55