Home
last modified time | relevance | path

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

12345678910>>...53

/titanic_52/usr/src/uts/common/avs/ns/rdc/
H A Drdc_diskq.h58 #define RDC_IOHDR_DONE 0xDEADCAFE /* this q entry has been flushed */
59 #define RDC_IOHDR_WAITING 0xBEEFCAFE /* this q entry is waiting for ack */
135 #define RDC_MAX_DISKQREAD 0x1000 /* max 2 mb q read */
155 rdc_aio_t *lastio; /* cached copy of the last write on q */
163 #define QHEAD(q) q->disk_hdr.h.head_offset argument
164 #define QNXTIO(q) q->nxt_io argument
165 #define QTAIL(q) q argument
166 QNITEMS(q) global() argument
167 QBLOCKS(q) global() argument
168 QSTATE(q) global() argument
169 IS_QSTATE(q,s) global() argument
170 QSIZE(q) global() argument
171 QMAGIC(q) global() argument
172 QVERS(q) global() argument
173 QSEQ(q) global() argument
174 QACK(q) global() argument
175 QEMPTY(q) global() argument
176 QWRAP(q) global() argument
177 AUXQWRAP(q) global() argument
178 LASTQTAIL(q) global() argument
179 QCOALBOUNDS(q) global() argument
183 INC_QHEAD(q,n) global() argument
184 INC_QNXTIO(q,n) global() argument
185 DEC_QNXTIO(q,n) global() argument
186 DEC_QHEAD(q,n) global() argument
187 INC_QTAIL(q,n) global() argument
188 DEC_QTAIL(q,n) global() argument
189 INC_QNITEMS(q,n) global() argument
190 DEC_QNITEMS(q,n) global() argument
191 INC_QBLOCKS(q,n) global() argument
192 DEC_QBLOCKS(q,n) global() argument
194 SET_QMAGIC(q,n) global() argument
195 SET_QSTATE(q,n) global() argument
196 CLR_QSTATE(q,n) global() argument
197 SET_QHEAD(q,n) global() argument
198 SET_QNXTIO(q,n) global() argument
199 SET_QHDRCNT(q,n) global() argument
200 SET_QTAIL(q,n) global() argument
201 SET_LASTQTAIL(q,n) global() argument
202 SET_LASTQWRITE(q,w) global() argument
203 SET_QSIZE(q,n) global() argument
204 SET_QNITEMS(q,n) global() argument
205 SET_QBLOCKS(q,n) global() argument
207 SET_QWRAP(q,n) global() argument
208 CLR_QWRAP(q) global() argument
209 SET_AUXQWRAP(q,n) global() argument
210 CLR_AUXQWRAP(q) global() argument
211 SET_QCOALBOUNDS(q,n) global() argument
213 WRAPQTAIL(q) global() argument
223 DO_AUXQWRAP(q) global() argument
230 WRAPQHEAD(q) global() argument
245 WRAPQNXTIO(q) global() argument
260 DQEND(q) global() argument
262 FITSONQ(q,n) global() argument
282 QHEADSHLDWRAP(q) global() argument
283 QNXTIOSHLDWRAP(q) global() argument
284 QTAILSHLDWRAP(q,size) global() argument
285 QCOALESCEOK(q,dec) global() argument
291 QLOCK(q) global() argument
292 QTAILLOCK(q) global() argument
293 QHEADLOCK(q) global() argument
295 QDISPLAY(q) global() argument
302 QDISPLAYND(q) global() argument
[all...]
H A Drdc_diskq.c90 rdc_wait_qbusy(disk_queue *q) in rdc_wait_qbusy() argument
92 ASSERT(MUTEX_HELD(QLOCK(q))); in rdc_wait_qbusy()
93 while (q->busycnt > 0) in rdc_wait_qbusy()
94 cv_wait(&q->busycv, QLOCK(q)); in rdc_wait_qbusy()
98 rdc_set_qbusy(disk_queue *q) in rdc_set_qbusy() argument
100 ASSERT(MUTEX_HELD(QLOCK(q))); in rdc_set_qbusy()
101 q->busycnt++; in rdc_set_qbusy()
105 rdc_clr_qbusy(disk_queue *q) in rdc_clr_qbusy() argument
107 ASSERT(MUTEX_HELD(QLOCK(q))); in rdc_clr_qbusy()
319 rdc_dump_iohdrs(disk_queue * q) rdc_dump_iohdrs() argument
350 rdc_u_info_t *q = &rdc_u_info[krdc->index]; rdc_fail_diskq() local
432 disk_queue *q; rdc_stamp_diskq() local
504 disk_queue *q = &grp->diskq; rdc_init_diskq_header() local
544 rdc_u_info_t *q = &rdc_u_info[krdc->index]; rdc_unfail_diskq() local
641 disk_queue q, *qp; rdc_stop_diskq_flusher() local
683 disk_queue *q; rdc_enable_diskq() local
722 disk_queue *q; rdc_resume_diskq() local
846 disk_queue *q; rdc_suspend_diskq() local
1020 disk_queue *q; rdc_diskq_enqueue() local
1361 disk_queue *q = NULL; rdc_add_iohdr() local
1410 disk_queue *q = NULL; rdc_clr_iohdr() local
1547 rdc_netqueue_insert(rdc_aio_t * aio,net_queue * q) rdc_netqueue_insert() argument
1641 rdc_discard_tmpq(net_queue * q) rdc_discard_tmpq() argument
1912 disk_queue *q = NULL; rdc_diskq_unqueue() local
2280 rdc_trim_buf(nsc_buf_t * buf,net_queue * q) rdc_trim_buf() argument
2516 net_queue *q = &krdc->group->ra_queue; rdc_dequeue() local
2670 rdc_join_netqueues(net_queue * q,net_queue * tmpq) rdc_join_netqueues() argument
2712 net_queue *q = &grp->ra_queue; rdc_qfiller_thr() local
2956 disk_queue *q = &group->diskq; _rdc_init_diskq() local
3061 disk_queue *q = &group->diskq; _rdc_kill_diskq() local
[all...]
/titanic_52/usr/src/uts/common/gssapi/mechs/krb5/mech/
H A Dutil_ordering.c59 * - the queue is a circular queue. The first element (q->elem[q->start])
63 #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
135 /* common case: at end, after == q in queue_insert()
163 queue *q; g_order_init() local
184 queue *q; g_order_check() local
256 queue *q; g_order_free() local
290 void *q; g_queue_internalize() local
[all...]
/titanic_52/usr/src/uts/common/io/1394/targets/av1394/
H A Dav1394_queue.c44 av1394_initq(av1394_queue_t *q, ddi_iblock_cookie_t ibc, int max) in av1394_initq() argument
46 bzero(q, sizeof (av1394_queue_t)); in av1394_initq()
48 mutex_init(&q->q_mutex, NULL, MUTEX_DRIVER, ibc); in av1394_initq()
49 cv_init(&q->q_cv, NULL, CV_DRIVER, NULL); in av1394_initq()
51 AV1394_ENTERQ(q); in av1394_initq()
52 av1394_list_init(&q->q_list); in av1394_initq()
53 q->q_max = max; in av1394_initq()
54 AV1394_LEAVEQ(q); in av1394_initq()
58 av1394_destroyq(av1394_queue_t *q) in av1394_destroyq() argument
60 av1394_flushq(q); in av1394_destroyq()
66 av1394_setmaxq(av1394_queue_t * q,int max) av1394_setmaxq() argument
74 av1394_getmaxq(av1394_queue_t * q) av1394_getmaxq() argument
85 av1394_flushq(av1394_queue_t * q) av1394_flushq() argument
98 av1394_putq(av1394_queue_t * q,mblk_t * bp) av1394_putq() argument
104 av1394_putbq(av1394_queue_t * q,mblk_t * bp) av1394_putbq() argument
110 av1394_getq(av1394_queue_t * q) av1394_getq() argument
122 av1394_peekq(av1394_queue_t * q) av1394_peekq() argument
133 av1394_peekq_locked(av1394_queue_t * q) av1394_peekq_locked() argument
143 av1394_qwait_sig(av1394_queue_t * q) av1394_qwait_sig() argument
159 av1394_put_common(av1394_queue_t * q,mblk_t * bp,putfunc_t put) av1394_put_common() argument
179 av1394_getq_locked(av1394_queue_t * q) av1394_getq_locked() argument
[all...]
/titanic_52/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 in stresc2chr()
139 char *q, *s2, c; strchr2esc() local
299 char *p, *q; strhyphenate() local
[all...]
/titanic_52/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 in bqueue_init()
54 bqueue_destroy(bqueue_t * q) bqueue_destroy() argument
69 bqueue_enqueue(bqueue_t * q,void * data,uint64_t item_size) bqueue_enqueue() argument
88 bqueue_dequeue(bqueue_t * q) bqueue_dequeue() argument
108 bqueue_empty(bqueue_t * q) bqueue_empty() argument
[all...]
/titanic_52/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 in audit_enqueue()
95 audit_dequeue(au_queue_t * q,void ** p) audit_dequeue() argument
157 audit_queue_size(au_queue_t * q) audit_queue_size() argument
170 audit_queue_destroy(au_queue_t * q) audit_queue_destroy() argument
[all...]
/titanic_52/usr/src/cmd/tnf/prex/
H A Dqueue.c41 queue_init(queue_node_t * q) in queue_init() argument
43 q->next_p = q->prev_p = q; in queue_init()
53 queue_prepend(queue_node_t * h, queue_node_t * q) in queue_prepend() argument
56 return ((q) ? q : NULL); in queue_prepend()
58 if (q) { in queue_prepend()
59 queue_node_t *qtail_p = q->prev_p; in queue_prepend()
63 h->next_p = q; in queue_prepend()
78 queue_append(queue_node_t * h,queue_node_t * q) queue_append() argument
104 queue_remove(queue_node_t * q) queue_remove() argument
128 queue_isempty(queue_node_t * q) queue_isempty() argument
141 queue_next(queue_node_t * h,queue_node_t * q) queue_next() argument
[all...]
/titanic_52/usr/src/lib/libslp/clib/
H A Dslp_queue.c79 struct queue *q; in slp_new_queue() local
99 if ((q = malloc(sizeof (*q))) == NULL) { in slp_new_queue()
105 q->head = NULL; in slp_new_queue()
106 q->lock = lock; in slp_new_queue()
107 q->wait = wait; in slp_new_queue()
108 q->count = 0; in slp_new_queue()
110 return (q); in slp_new_queue()
114 * Adds msg to the tail of queue q.
120 struct queue *q in slp_enqueue() local
149 struct queue *q = qa; slp_enqueue_at_head() local
171 dequeue_nolock(struct queue * q) dequeue_nolock() argument
196 struct queue *q = qa; slp_dequeue_timed() local
241 struct queue *q = qa; slp_flush_queue() local
255 struct queue *q = qa; slp_destroy_queue() local
[all...]
/titanic_52/usr/src/uts/common/io/
H A Drlmod.c203 rlmodopen(queue_t *q, dev_t *devp, int oflag, int sflag, cred_t *cred) in rlmodopen() argument
213 if (q->q_ptr != NULL) { in rlmodopen()
226 q->q_ptr = rmip; in rlmodopen()
227 WR(q)->q_ptr = rmip; in rlmodopen()
230 rmip->startc = CTRL('q'); in rlmodopen()
240 qprocson(q); in rlmodopen()
253 bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), in rlmodopen()
255 if (!qwait_sig(q)) { in rlmodopen()
256 qunbufcall(q, id); in rlmodopen()
260 qunbufcall(q, i in rlmodopen()
311 rlmodclose(queue_t * q,int flag,cred_t * credp) rlmodclose() argument
366 rlmodrput(queue_t * q,mblk_t * mp) rlmodrput() argument
485 rlmodrsrv(queue_t * q) rlmodrsrv() argument
596 rlmodwput(queue_t * q,mblk_t * mp) rlmodwput() argument
743 rlmodwsrv(queue_t * q) rlmodwsrv() argument
841 rlmodrmsg(queue_t * q,mblk_t * mp) rlmodrmsg() argument
994 rlwinctl(queue_t * q,mblk_t * mp) rlwinctl() argument
1031 rlwinsetup(queue_t * q,mblk_t * mp,unsigned char * blk) rlwinsetup() argument
1084 tty_flow(queue_t * q,struct rlmod_info * rmip,mblk_t * mp) tty_flow() argument
1183 rlmodwioctl(queue_t * q,mblk_t * mp) rlmodwioctl() argument
1272 queue_t *q = arg; rlmod_timer() local
1290 queue_t *q = arg; rlmod_buffer() local
1306 recover(queue_t * q,mblk_t * mp,size_t size) recover() argument
1319 recover1(queue_t * q,size_t size) recover1() argument
[all...]
H A Dtelmod.c134 static int rcv_parse(queue_t *q, mblk_t *mp);
135 static int snd_parse(queue_t *q, mblk_t *mp);
208 telmodopen(queue_t *q, dev_t *devp, int oflag, int sflag, cred_t *credp) in telmodopen() argument
218 if (q->q_ptr != NULL) { in telmodopen()
230 q->q_ptr = tmip; in telmodopen()
231 WR(q)->q_ptr = tmip; in telmodopen()
233 noenable(q); in telmodopen()
235 qprocson(q); in telmodopen()
248 bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), in telmodopen()
250 if (!qwait_sig(q)) { in telmodopen()
305 telmodclose(queue_t * q,int flag,cred_t * credp) telmodclose() argument
356 telmodrput(queue_t * q,mblk_t * mp) telmodrput() argument
511 telmodrsrv(queue_t * q) telmodrsrv() argument
652 telmodwput(queue_t * q,mblk_t * mp) telmodwput() argument
859 telmodwsrv(queue_t * q) telmodwsrv() argument
940 rcv_parse(queue_t * q,mblk_t * mp) rcv_parse() argument
1127 snd_parse(queue_t * q,mblk_t * mp) snd_parse() argument
1199 queue_t *q = arg; telmod_timer() local
1218 queue_t *q = arg; telmod_buffer() local
1235 recover(queue_t * q,mblk_t * mp,size_t size) recover() argument
[all...]
H A Dtirdwr.c68 static int tirdwropen(queue_t *q, dev_t *dev,
71 static int tirdwrclose(queue_t *q, int flag, cred_t *cr);
73 static int check_strhead(queue_t *q);
79 static void tirdwrrput(queue_t *q, mblk_t *mp);
80 static void tirdwrwput(queue_t *q, mblk_t *mp);
150 static void send_fatal(queue_t *q, mblk_t *mp);
151 static void strip_strhead(queue_t *q);
161 queue_t *q, in tirdwropen() argument
170 if (q->q_ptr) { in tirdwropen()
181 trwptr->trw_rdq = q; in tirdwropen()
210 tirdwrclose(queue_t * q,int flag,cred_t * cr) tirdwrclose() argument
245 tirdwrrput(queue_t * q,mblk_t * mp) tirdwrrput() argument
329 tirdwrwput(queue_t * q,mblk_t * mp) tirdwrwput() argument
360 send_fatal(queue_t * q,mblk_t * mp) send_fatal() argument
379 check_strhead(queue_t * q) check_strhead() argument
419 strip_strhead(queue_t * q) strip_strhead() argument
[all...]
H A Dptem.c151 queue_t *q, /* pointer to the read side queue */ in ptemopen() argument
166 if (q->q_ptr != NULL) { in ptemopen()
210 ntp->q_ptr = q; in ptemopen()
211 q->q_ptr = ntp; in ptemopen()
212 WR(q)->q_ptr = ntp; in ptemopen()
240 qprocson(q); in ptemopen()
241 putnext(q, mop); in ptemopen()
253 ptemclose(queue_t *q, int flag, cred_t *credp) in ptemclose() argument
257 qprocsoff(q); in ptemclose()
258 ntp = (struct ptem *)q in ptemclose()
272 ptemrput(queue_t * q,mblk_t * mp) ptemrput() argument
441 ptemwput(queue_t * q,mblk_t * mp) ptemwput() argument
584 ptemwsrv(queue_t * q) ptemwsrv() argument
605 ptemwmsg(queue_t * q,mblk_t * mp) ptemwmsg() argument
883 ptioc(queue_t * q,mblk_t * mp,int qside) ptioc() argument
[all...]
H A Dpckt.c112 * the read q due to allocb failures, these failures must get
176 queue_t *pi_qptr; /* back pointer to q */
204 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()
286 pcktclose(queue_t * q,int flag,cred_t * credp) pcktclose() argument
316 pcktrput(queue_t * q,mblk_t * mp) pcktrput() argument
420 pcktrsrv(queue_t * q) pcktrsrv() argument
481 pcktwput(queue_t * q,mblk_t * mp) pcktwput() argument
499 pckt_reallocb(queue_t * q,mblk_t * mp) pckt_reallocb() argument
546 add_ctl_info(queue_t * q,mblk_t * mp) add_ctl_info() argument
678 queue_t *q = arg; /* ptr to the read queue */ add_ctl_wkup() local
[all...]
H A Dtimod.c131 * q->q_ptr, then it's stable.
352 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()
446 queue_t *q = arg; tim_timer() local
465 queue_t *q = arg; tim_buffer() local
488 timodclose(queue_t * q,int flag,cred_t * crp) timodclose() argument
571 timodrput(queue_t * q,mblk_t * mp) timodrput() argument
640 timodrsrv(queue_t * q) timodrsrv() argument
668 timodprocessinfo(queue_t * q,struct tim_tim * tp,struct T_info_ack * tia) timodprocessinfo() argument
681 timodrproc(queue_t * q,mblk_t * mp) timodrproc() argument
1450 timodwput(queue_t * q,mblk_t * mp) timodwput() argument
1556 timodwsrv(queue_t * q) timodwsrv() argument
1580 timodwproc(queue_t * q,mblk_t * mp) timodwproc() argument
2214 ti_doname(queue_t * q,mblk_t * mp) ti_doname() argument
2410 tim_filladdr(queue_t * q,mblk_t * mp,boolean_t dorecover) tim_filladdr() argument
2538 tim_recover(queue_t * q,mblk_t * mp,t_scalar_t size) tim_recover() argument
2584 tim_ioctl_retry(queue_t * q) tim_ioctl_retry() argument
2609 queue_t *q; ti_expind_on_rdqueues() local
2650 queue_t *q = (queue_t *)q_ptr; tim_tcap_timer() local
2667 tim_tcap_genreply(queue_t * q,struct tim_tim * tp) tim_tcap_genreply() argument
2743 tim_ioctl_send_reply(queue_t * q,mblk_t * ioc_mp,mblk_t * mp) tim_ioctl_send_reply() argument
2783 tim_send_ioc_error_ack(queue_t * q,struct tim_tim * tp,mblk_t * mp) tim_send_ioc_error_ack() argument
2858 tim_send_reply(queue_t * q,mblk_t * mp,struct tim_tim * tp,t_scalar_t prim) tim_send_reply() argument
2882 tim_answer_ti_sync(queue_t * q,mblk_t * mp,struct tim_tim * tp,mblk_t * ackmp,uint32_t tsr_flags) tim_answer_ti_sync() argument
2930 tim_send_ioctl_tpi_msg(queue_t * q,mblk_t * mp,struct tim_tim * tp,struct iocblk * iocb) tim_send_ioctl_tpi_msg() argument
[all...]
H A Dstream.c1857 getq(queue_t *q) in getq() argument
1862 bp = getq_noenab(q, 0); in getq()
1870 if (band == 0 && (q->q_flag & (QWANTW|QWANTWSYNC)) == 0) in getq()
1873 qbackenable(q, band); in getq()
1926 getq_noenab(queue_t *q, ssize_t rbytes) in getq_noenab() argument
1935 freezer = STREAM(q)->sd_freezer; in getq_noenab()
1937 ASSERT(frozenstr(q)); in getq_noenab()
1938 ASSERT(MUTEX_HELD(QLOCK(q))); in getq_noenab()
1940 mutex_enter(QLOCK(q)); in getq_noenab()
1942 if ((bp = q in getq_noenab()
2108 qbackenable(queue_t * q,uchar_t band) qbackenable() argument
2193 rmvq(queue_t * q,mblk_t * mp) rmvq() argument
2216 rmvq_noenab(queue_t * q,mblk_t * mp) rmvq_noenab() argument
2307 flushq_common(queue_t * q,int flag,int pcproto_flag) flushq_common() argument
2392 flushq(queue_t * q,int flag) flushq() argument
2411 flushband(queue_t * q,unsigned char pri,int flag) flushband() argument
2506 canput(queue_t * q) canput() argument
2539 bcanput(queue_t * q,unsigned char pri) bcanput() argument
2604 putq(queue_t * q,mblk_t * bp) putq() argument
2793 putbq(queue_t * q,mblk_t * bp) putbq() argument
2984 insq(queue_t * q,mblk_t * emp,mblk_t * mp) insq() argument
3114 putctl(queue_t * q,int type) putctl() argument
3132 putctl1(queue_t * q,int type,int param) putctl1() argument
3148 putnextctl1(queue_t * q,int type,int param) putnextctl1() argument
3165 putnextctl(queue_t * q,int type) putnextctl() argument
3183 backq(queue_t * q) backq() argument
3198 qreply(queue_t * q,mblk_t * bp) qreply() argument
3227 qenable(queue_t * q) qenable() argument
3254 noenable(queue_t * q) noenable() argument
3262 enableok(queue_t * q) enableok() argument
3273 strqset(queue_t * q,qfields_t what,unsigned char pri,intptr_t val) strqset() argument
3434 strqget(queue_t * q,qfields_t what,unsigned char pri,void * valp) strqget() argument
3557 strwakeq(queue_t * q,int flag) strwakeq() argument
3614 struioget(queue_t * q,mblk_t * mp,struiod_t * dp,int noblock) struioget() argument
4044 isuioq(queue_t * q) isuioq() argument
4062 create_syncq_putlocks(queue_t * q) create_syncq_putlocks() argument
4140 create_putlocks(queue_t * q,int stream) create_putlocks() argument
[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, tmx in logdmuxclose()
384 logdmuxursrv(queue_t * q) logdmuxursrv() argument
398 logdmuxuwput(queue_t * q,mblk_t * mp) logdmuxuwput() argument
577 logdmuxuwsrv(queue_t * q) logdmuxuwsrv() argument
630 logdmuxlrput(queue_t * q,mblk_t * mp) logdmuxlrput() argument
835 logdmuxlrsrv(queue_t * q) logdmuxlrsrv() argument
925 logdmuxlwsrv(queue_t * q) logdmuxlwsrv() argument
949 logdmuxlink(queue_t * q,mblk_t * mp) logdmuxlink() argument
978 logdmuxunlink(queue_t * q,mblk_t * mp) logdmuxunlink() argument
1071 logdmux_finish_unlink(queue_t * q,mblk_t * unlink_mp) logdmux_finish_unlink() argument
1103 queue_t *q = arg; logdmux_unlink_timer() local
1135 queue_t *q = arg; logdmux_timer() local
1154 queue_t *q = arg; logdmux_buffer() local
1171 recover(queue_t * q,mblk_t * mp,size_t size) recover() argument
1210 flushq_dataonly(queue_t * q) flushq_dataonly() argument
[all...]
/titanic_52/usr/src/cmd/sendmail/src/
H A Darpadate.c62 register char *q; variable
86 q = b;
89 *q++ = *p++;
90 *q++ = *p++;
91 *q++ = *p++;
92 *q++ = ',';
93 *q++ = ' ';
99 *q++ = *p++;
100 *q++ = *p++;
101 *q
[all...]
/titanic_52/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 in idmap_nldap_bywinname_batch_add()
446 idmap_nldap_q_t *q; idmap_nldap_bypid_batch_add() local
512 idmap_nldap_q_t *q; idmap_nldap_byunixname_batch_add() local
589 idmap_nldap_q_t *q; idmap_nldap_lookup_batch_release() local
615 idmap_nldap_q_t *q; idmap_nldap_lookup_batch_end() local
[all...]
/titanic_52/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 in queue_msg_set()
98 queue_msg_get(msg_queue_t * q) queue_msg_get() argument
[all...]
/titanic_52/usr/src/uts/common/fs/zev/
H A Dzev.c124 zev_queue_t *q; in zev_update_blockflag() local
133 q = zev_queues[i - ZEV_MINOR_MIN]; in zev_update_blockflag()
134 if (!q) in zev_update_blockflag()
136 if (q->zq_flags & ZEV_FL_BLOCK_WHILE_QUEUE_FULL) { in zev_update_blockflag()
164 zev_queue_t *q; in zev_queue_trim() local
172 q = zev_queues[i - ZEV_MINOR_MIN]; in zev_queue_trim()
173 if (q == NULL) in zev_queue_trim()
175 if (!q->zq_oldest) in zev_queue_trim()
177 if (oldest_message > q->zq_oldest->seq) in zev_queue_trim()
178 oldest_message = q in zev_queue_trim()
202 zev_queue_hold(zev_queue_t * q) zev_queue_hold() argument
209 zev_queue_release(zev_queue_t * q) zev_queue_release() argument
244 zev_queue_t *q; zev_queue_new() local
363 zev_queue_t *q; zev_poll_wakeup() local
550 zev_queue_t *q; zev_queue_message() local
761 zev_queue_t *q; zev_find_queue() local
801 zev_queue_t *q; zev_ioc_get_queue_statistics() local
833 zev_queue_t *q; zev_ioc_set_queue_properties() local
886 zev_queue_t *q; zev_ioc_get_queue_properties() local
934 zev_queue_t *q; zev_ioc_remove_queue() local
1003 zev_queue_t *q; zev_ioc_get_queue_list() local
1032 zev_queue_t *q; zev_ioc_set_max_queue_len() local
1213 zev_queue_t *q; zev_chpoll() local
1248 zev_queue_t *q; zev_read() local
1310 zev_queue_t *q; zev_close() local
1336 zev_queue_t *q; zev_open() local
1414 zev_queue_t *q; zev_free_instance() local
1463 zev_queue_t *q; zev_detach() local
1532 zev_queue_t *q; zev_attach() local
1631 zev_queue_t *q; zev_getinfo() local
[all...]
/titanic_52/usr/src/uts/common/avs/ns/sdbc/
H A Dsafestore_impl.h53 int wq_inq; /* number of write blocks available in q */
54 int wq_nentries; /* total Number of write blocks in q */
61 #define WQ_SET_NEED(q, need, i) { \ argument
62 (q->wq_slp[i].slp_wqneed = need); \
65 #define WQ_SVWAIT_BOTTOM(q, need) \ argument
67 int ix = q->wq_slp_index; \
68 INCX(q->wq_slp_index); \
69 WQ_SET_NEED(q, need, ix); \
70 cv_wait(&q->wq_slp[ix].slp_wqcv, &q
74 WQ_SVWAIT_TOP(q,need) global() argument
82 WQ_NEED_SIG(q) global() argument
85 WQ_SVSIG(q) global() argument
[all...]
/titanic_52/usr/src/uts/common/rpc/
H A Drpcmod.c226 static int mir_close(queue_t *q);
227 static int mir_open(queue_t *q, dev_t *devp, int flag, int sflag,
229 static void mir_rput(queue_t *q, mblk_t *mp);
230 static void mir_rsrv(queue_t *q);
231 static void mir_wput(queue_t *q, mblk_t *mp);
232 static void mir_wsrv(queue_t *q);
294 * Per rpcmod "slot" data structure. q->q_ptr points to one of these.
426 void tmp_rput(queue_t *q, mblk_t *mp);
438 tmp_rput(queue_t *q, mblk_t *mp) in tmp_rput() argument
440 struct temp_slot *t = (struct temp_slot *)(q in tmp_rput()
469 rmm_open(queue_t * q,dev_t * devp,int flag,int sflag,cred_t * crp) rmm_open() argument
544 rmm_rput(queue_t * q,mblk_t * mp) rmm_rput() argument
550 rmm_rsrv(queue_t * q) rmm_rsrv() argument
556 rmm_wput(queue_t * q,mblk_t * mp) rmm_wput() argument
562 rmm_wsrv(queue_t * q) rmm_wsrv() argument
568 rmm_close(queue_t * q,int flag,cred_t * crp) rmm_close() argument
580 rpcmodopen(queue_t * q,dev_t * devp,int flag,int sflag,cred_t * crp) rpcmodopen() argument
630 rpcmodclose(queue_t * q,int flag,cred_t * crp) rpcmodclose() argument
698 rpcmodrput(queue_t * q,mblk_t * mp) rpcmodrput() argument
836 rpcmodwput(queue_t * q,mblk_t * mp) rpcmodwput() argument
884 rpcmodwput_other(queue_t * q,mblk_t * mp) rpcmodwput_other() argument
928 rpcmodwsrv(queue_t * q) rpcmodwsrv() argument
955 rpcmod_release(queue_t * q,mblk_t * bp,bool_t enable) rpcmod_release() argument
1073 mir_timer_start(queue_t * q,mir_t * mir,clock_t intrvl) mir_timer_start() argument
1098 mir_clnt_dup_request(queue_t * q,mblk_t * mp) mir_clnt_dup_request() argument
1121 mir_close(queue_t * q) mir_close() argument
1200 mir_svc_idle_stop(queue_t * q,mir_t * mir) mir_svc_idle_stop() argument
1217 mir_svc_idle_start(queue_t * q,mir_t * mir) mir_svc_idle_start() argument
1256 mir_open(queue_t * q,dev_t * devp,int flag,int sflag,cred_t * credp) mir_open() argument
1330 mir_rput(queue_t * q,mblk_t * mp) mir_rput() argument
1644 mir_rput_proto(queue_t * q,mblk_t * mp) mir_rput_proto() argument
1858 mir_rsrv(queue_t * q) mir_rsrv() argument
1961 mir_svc_policy_notify(queue_t * q,int event) mir_svc_policy_notify() argument
2285 mir_wput(queue_t * q,mblk_t * mp) mir_wput() argument
2393 mir_wput_other(queue_t * q,mblk_t * mp) mir_wput_other() argument
2650 mir_wsrv(queue_t * q) mir_wsrv() argument
2771 mir_disconnect(queue_t * q,mir_t * mir) mir_disconnect() argument
2818 mir_check_len(queue_t * q,mblk_t * head_mp) mir_check_len() argument
[all...]
/titanic_52/usr/src/cmd/spell/
H A Dmalloc.c84 register union store *p, *q; local
96 while(!testbusy((q=p->ptr)->ptr)) {
97 ASSERT(q>p);
98 p->ptr = q->ptr;
101 if(q>=p+nw && p+nw>=p)
105 q = p;
107 if(p <= q) {
123 q = (union store *)sbrk(temp*WORD);
124 if((INT)q != -1)
130 ialloc((char *)q, (unsigne
168 register union store *p, *q, *s; global() local
206 register union store *q; global() local
236 union store *q; global() variable
[all...]
/titanic_52/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()
492 canputnext(queue_t * q) canputnext() argument
566 qprocson(queue_t * q) qprocson() argument
596 qprocsoff(queue_t * q) qprocsoff() argument
626 freezestr(queue_t * q) freezestr() argument
651 unfreezestr(queue_t * q) unfreezestr() argument
690 qwait_sig(queue_t * q) qwait_sig() argument
803 qwait(queue_t * q) qwait() argument
905 qwait_rw(queue_t * q) qwait_rw() argument
980 qwriter(queue_t * q,mblk_t * mp,void (* func)(),int perim) qwriter() argument
994 qtimeout(queue_t * q,void (* func)(void *),void * arg,clock_t tim) qtimeout() argument
1023 qbufcall(queue_t * q,size_t size,uint_t pri,void (* func)(void *),void * arg) qbufcall() argument
1065 quntimeout(queue_t * q,timeout_id_t id) quntimeout() argument
1103 qunbufcall(queue_t * q,bufcall_id_t id) qunbufcall() argument
1177 qassociate(queue_t * q,int instance) qassociate() argument
[all...]

12345678910>>...53