Home
last modified time | relevance | path

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

12345678910>>...52

/titanic_41/usr/src/uts/common/avs/ns/rdc/
H A Drdc_diskq.h163 #define QHEAD(q) q->disk_hdr.h.head_offset argument
164 #define QNXTIO(q) q->nxt_io argument
165 #define QTAIL(q) q->disk_hdr.h.tail_offset argument
166 #define QNITEMS(q) q->disk_hdr.h.nitems argument
167 #define QBLOCKS(q) q->disk_hdr.h.blocks argument
168 #define QSTATE(q) q->disk_hdr.h.state argument
169 #define IS_QSTATE(q, s) (q->disk_hdr.h.state & s) argument
170 #define QSIZE(q) q->disk_hdr.h.disk_size argument
171 #define QMAGIC(q) q->disk_hdr.h.magic argument
172 #define QVERS(q) q->disk_hdr.h.vers 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()
108 q->busycnt--; in rdc_clr_qbusy()
[all …]
/titanic_41/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 …]
/titanic_41/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()
[all …]
/titanic_41/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 …]
/titanic_41/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 …]
/titanic_41/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 …]
/titanic_41/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()
65 q->prev_p = h; in queue_prepend()
78 queue_append(queue_node_t * h, queue_node_t * q) in queue_append() argument
81 return ((q) ? q : NULL); in queue_append()
[all …]
/titanic_41/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()
120 struct queue *q = qa; in slp_enqueue() local
127 (void) mutex_lock(q->lock); in slp_enqueue()
130 if (q->head != NULL) { /* queue is not emptry */ in slp_enqueue()
[all …]
/titanic_41/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()
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, id); in rlmodopen()
275 bufcall_id_t id = qbufcall(q, sizeof (union T_primitives), in rlmodopen()
[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()
[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()
[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->q_ptr; in ptemclose()
[all …]
H A Dpckt.c206 queue_t *q, /* pointer to the read side queue */ in pcktopen() argument
219 if (q->q_ptr != NULL) { in pcktopen()
237 pip->pi_qptr = q; in pcktopen()
238 q->q_ptr = pip; in pcktopen()
239 WR(q)->q_ptr = pip; in pcktopen()
241 qprocson(q); in pcktopen()
249 bufcall_id_t id = qbufcall(q, sizeof (struct stroptions), in pcktopen()
251 if (!qwait_sig(q)) { in pcktopen()
252 qunbufcall(q, id); in pcktopen()
254 qprocsoff(q); in pcktopen()
[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 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->q_first) == 0) { in getq_noenab()
[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 …]
/titanic_41/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_41/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 …]
/titanic_41/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 …]
/titanic_41/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->zq_oldest->seq; in zev_queue_trim()
[all …]
/titanic_41/usr/src/uts/common/avs/ns/sdbc/
H A Dsafestore_impl.h61 #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->wq_qlock); \
71 mutex_exit(&q->wq_qlock); \
74 #define WQ_SVWAIT_TOP(q, need) \ argument
76 DECX(q->wq_slp_top); \
[all …]
/titanic_41/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);
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->q_ptr); in tmp_rput()
469 rmm_open(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *crp) in rmm_open() argument
[all …]
/titanic_41/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, (unsigned)temp*WORD);
[all …]
/titanic_41/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 …]

12345678910>>...52