| /netbsd/src/sys/dev/raidframe/ |
| D | rf_fifo.c | 59 RF_FifoHeader_t *q; in rf_FifoCreate() local
61 q = RF_MallocAndAdd(sizeof(*q), clList); in rf_FifoCreate()
62 q->hq_count = q->lq_count = 0; in rf_FifoCreate()
63 return ((void *) q); in rf_FifoCreate()
69 RF_FifoHeader_t *q = (RF_FifoHeader_t *) q_in; in rf_FifoEnqueue() local
75 if (!q->hq_tail) { in rf_FifoEnqueue()
76 RF_ASSERT(q->hq_count == 0 && q->hq_head == NULL); in rf_FifoEnqueue()
77 q->hq_head = q->hq_tail = elem; in rf_FifoEnqueue()
79 RF_ASSERT(q->hq_count != 0 && q->hq_head != NULL); in rf_FifoEnqueue()
80 q->hq_tail->next = elem; in rf_FifoEnqueue()
[all …]
|
| /netbsd/src/external/cddl/osnet/dist/lib/libdtrace/common/ |
| D | dt_string.c | 41 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 …]
|
| /netbsd/src/sys/altq/ |
| D | altq_fifoq.c | 107 fifoq_state_t *q; in fifoqclose() local
110 while ((q = fifoq_list) != NULL) { in fifoqclose()
112 err = fifoq_detach(q); in fifoqclose()
124 fifoq_state_t *q; in fifoqioctl() local
144 if ((q = altq_lookup(ifacep->fifoq_ifname, ALTQT_FIFOQ)) in fifoqioctl()
149 error = altq_enable(q->q_ifq); in fifoqioctl()
154 if ((q = altq_lookup(ifacep->fifoq_ifname, ALTQT_FIFOQ)) in fifoqioctl()
159 error = altq_disable(q->q_ifq); in fifoqioctl()
170 q = malloc(sizeof(fifoq_state_t), M_DEVBUF, M_WAITOK|M_ZERO); in fifoqioctl()
171 if (q == NULL) { in fifoqioctl()
[all …]
|
| D | altq_classq.h | 70 #define qtype(q) (q)->qtype_ /* Get queue type */ argument
71 #define qlimit(q) (q)->qlim_ /* Max packets to be queued */ argument
72 #define qlen(q) (q)->qlen_ /* Current queue length. */ argument
73 #define qtail(q) (q)->tail_ /* Tail of the queue */ argument
74 #define qhead(q) ((q)->tail_ ? (q)->tail_->m_nextpkt : NULL) argument
76 #define qempty(q) ((q)->qlen_ == 0) /* Is the queue empty?? */ argument
77 #define q_is_red(q) ((q)->qtype_ == Q_RED) /* Is the queue a red queue */ argument
78 #define q_is_rio(q) ((q)->qtype_ == Q_RIO) /* Is the queue a rio queue */ argument
79 #define q_is_red_or_rio(q) ((q)->qtype_ == Q_RED || (q)->qtype_ == Q_RIO) argument
95 _addq(class_queue_t *q, struct mbuf *m) in _addq() argument
[all …]
|
| /netbsd/src/external/bsd/libarchive/dist/libarchive/test/ |
| D | test_write_format_zip_compression_store.c | 136 const char *p, *q, *local_header, *extra_start; in verify_uncompressed_contents() local
207 local_header = q = buff; in verify_uncompressed_contents()
208 assertEqualMem(q, "PK\003\004", 4); /* Signature */ in verify_uncompressed_contents()
209 assertEqualInt(i2(q + 4), 10); /* Version needed to extract */ in verify_uncompressed_contents()
210 …assertEqualInt(i2(q + 6), 8); /* Flags: bit 3 = length-at-end. Required because CRC32 is unknown … in verify_uncompressed_contents()
211 assertEqualInt(i2(q + 8), 0); /* Compression method */ in verify_uncompressed_contents()
212 …assertEqualInt(i2(q + 10), (tm->tm_hour * 2048) + (tm->tm_min * 32) + (tm->tm_sec / 2)); /* File t… in verify_uncompressed_contents()
213 …assertEqualInt(i2(q + 12), ((tm->tm_year - 80) * 512) + ((tm->tm_mon + 1) * 32) + tm->tm_mday); /*… in verify_uncompressed_contents()
214 assertEqualInt(i4(q + 14), 0); /* CRC-32 */ in verify_uncompressed_contents()
215 … assertEqualInt(i4(q + 18), 0); /* Compressed size, must be zero because of length-at-end */ in verify_uncompressed_contents()
[all …]
|
| /netbsd/src/external/cddl/osnet/dist/uts/common/fs/zfs/ |
| D | bqueue.c | 23 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 …]
|
| /netbsd/src/external/bsd/ntp/dist/tests/ntpd/ |
| D | ntp_prio_q.c | 51 queue* q = create_queue(); in test_EmptyQueue() local
53 TEST_ASSERT_NOT_NULL(q); in test_EmptyQueue()
54 TEST_ASSERT_TRUE(empty(q)); in test_EmptyQueue()
55 TEST_ASSERT_NULL(queue_head(q)); in test_EmptyQueue()
56 TEST_ASSERT_NULL(dequeue(q)); in test_EmptyQueue()
57 TEST_ASSERT_EQUAL(0, get_no_of_elements(q)); in test_EmptyQueue()
59 destroy_queue(q); in test_EmptyQueue()
66 queue* q = create_queue(); in test_OneElementQueue() local
68 TEST_ASSERT_NOT_NULL(q); in test_OneElementQueue()
72 enqueue(q, e_ptr); in test_OneElementQueue()
[all …]
|
| /netbsd/src/sys/dev/marvell/ |
| D | mvgbereg.h | 66 #define MVGBE_PRXC(q) (0x1400 + ((q) << 2)) /*Port RX queues Config*/ argument
67 #define MVGBE_PRXSNP(q) (0x1420 + ((q) << 2)) /* Port RX queues Snoop */ argument
68 #define MVGBE_PRXF01(q) (0x1440 + ((q) << 2)) /* Port RX Prefetch 0_1 */ argument
69 #define MVGBE_PRXF23(q) (0x1460 + ((q) << 2)) /* Port RX Prefetch 2_3 */ argument
70 #define MVGBE_PRXDQA(q) (0x1480 + ((q) << 2)) /*P RXqueues desc Q Addr*/ argument
71 #define MVGBE_PRXDQS(q) (0x14a0 + ((q) << 2)) /*P RXqueues desc Q Size*/ argument
72 #define MVGBE_PRXDQTH(q) (0x14c0 + ((q) << 2)) /*P RXqueues desc Q Thrs*/ argument
73 #define MVGBE_PRXS(q) (0x14e0 + ((q) << 2)) /*Port RX queues Status */ argument
74 #define MVGBE_PRXSU(q) (0x1500 + ((q) << 2)) /*P RXqueues Stat Update*/ argument
75 #define MVGBE_PPLBSZ(q) (0x1700 + ((q) << 2)) /* P Pool n Buffer Size */ argument
[all …]
|
| D | if_mvxpereg.h | 100 #define MVXPE_PRXC(q) (0x1400 + ((q) << 2)) /*Port RX queues Config*/ argument
101 #define MVXPE_PRXSNP(q) (0x1420 + ((q) << 2)) /* Port RX queues Snoop */ argument
102 #define MVXPE_PRXDQA(q) (0x1480 + ((q) << 2)) /*P RXqueues desc Q Addr*/ argument
103 #define MVXPE_PRXDQS(q) (0x14a0 + ((q) << 2)) /*P RXqueues desc Q Size*/ argument
104 #define MVXPE_PRXDQTH(q) (0x14c0 + ((q) << 2)) /*P RXqueues desc Q Thrs*/ argument
105 #define MVXPE_PRXS(q) (0x14e0 + ((q) << 2)) /*Port RX queues Status */ argument
106 #define MVXPE_PRXSU(q) (0x1500 + ((q) << 2)) /*P RXqueues Stat Update*/ argument
107 #define MVXPE_PRXDI(q) (0x1520 + ((q) << 2)) /*P RXqueues Stat Update*/ argument
119 #define MVXPE_PTXDQA(q) (0x3c00 + ((q) << 2)) /*P TXqueues desc Q Addr*/ argument
120 #define MVXPE_PTXDQS(q) (0x3c20 + ((q) << 2)) /*P TXqueues desc Q Size*/ argument
[all …]
|
| /netbsd/src/external/lgpl3/mpfr/dist/tests/ |
| D | tremquo.c | 58 long q[1]; in main() local
70 mpfr_remquo (r, q, x, y, MPFR_RNDN); in main()
73 printf (" q=%ld\n", q[0]); in main()
89 mpfr_remquo (r, q, x, y, MPFR_RNDN); in main()
91 mpfr_fmodquo (r, q, x, y, MPFR_RNDN); in main()
96 mpfr_remquo (r, q, x, y, MPFR_RNDN); in main()
98 mpfr_fmodquo (r, q, x, y, MPFR_RNDN); in main()
103 mpfr_remquo (r, q, x, y, MPFR_RNDN); in main()
105 mpfr_fmodquo (r, q, x, y, MPFR_RNDN); in main()
110 mpfr_remquo (r, q, x, y, MPFR_RNDN); in main()
[all …]
|
| D | tget_q.c | 31 mpq_t q; in special() local
34 mpq_init (q); in special()
39 mpfr_get_q (q, f); in special()
40 MPFR_ASSERTN(mpq_cmp_ui (q, 0, 1) == 0); in special()
46 mpfr_get_q (q, f); in special()
47 MPFR_ASSERTN(mpq_cmp_ui (q, 0, 1) == 0); in special()
53 mpfr_get_q (q, f); in special()
54 MPFR_ASSERTN(mpq_cmp_ui (q, 0, 1) == 0); in special()
60 mpfr_get_q (q, f); in special()
61 MPFR_ASSERTN(mpq_cmp_ui (q, 0, 1) == 0); in special()
[all …]
|
| /netbsd/src/sys/kern/ |
| D | subr_workqueue.c | 165 struct workqueue_queue *q; in workqueue_worker() local
169 q = workqueue_queue_lookup(wq, curlwp->l_cpu); in workqueue_worker()
173 mutex_enter(&q->q_mutex); in workqueue_worker()
179 while (SIMPLEQ_EMPTY(&q->q_queue_pending)) in workqueue_worker()
180 cv_wait(&q->q_cv, &q->q_mutex); in workqueue_worker()
181 SIMPLEQ_CONCAT(&tmp, &q->q_queue_pending); in workqueue_worker()
182 SIMPLEQ_INIT(&q->q_queue_pending); in workqueue_worker()
188 q->q_gen |= 1; in workqueue_worker()
189 mutex_exit(&q->q_mutex); in workqueue_worker()
197 mutex_enter(&q->q_mutex); in workqueue_worker()
[all …]
|
| /netbsd/src/usr.bin/mail/ |
| D | mime_header.c | 59 char *q; in grab_charset() local
60 q = from_cs; in grab_charset()
62 if (*p == '\0' || q >= from_cs + from_cs_len - 1) in grab_charset()
64 *q++ = *p; in grab_charset()
66 *q = '\0'; in grab_charset()
193 char *q, *qend; in copy_skipped_FWS() local
196 q = *dst; in copy_skipped_FWS()
201 while (p < pend && q < qend) in copy_skipped_FWS()
202 *q++ = *p++; in copy_skipped_FWS()
203 *dst = q; in copy_skipped_FWS()
[all …]
|
| /netbsd/src/tests/fs/ffs/ |
| D | t_quotalimit.sh | 30 for q in "user" "group"; do
31 test_case_root limit_${e}_${v}_${q} limit_quota \
32 "hit hard limit quota with ${q} enabled" -b ${e} ${v} ${q}
33 test_case_root limit_${e}_${v}_${q}_log limit_quota \
34 "hit hard limit quota with ${q} enabled, WAPBL" -bl ${e} ${v} ${q}
35 test_case_root slimit_${e}_${v}_${q} limit_softquota \
36 "hit soft limit quota with ${q} enabled after grace time" \
37 -b ${e} ${v} ${q}
38 test_case_root inolimit_${e}_${v}_${q} limit_iquota \
39 "hit hard limit ino quota with ${q} enabled" -b ${e} ${v} ${q}
[all …]
|
| /netbsd/src/crypto/external/bsd/heimdal/dist/lib/asn1/ |
| D | der_cmp.c | 39 der_heim_oid_cmp(const heim_oid *p, const heim_oid *q) in der_heim_oid_cmp() argument
41 if (p->length != q->length) in der_heim_oid_cmp()
42 return (int)(p->length - q->length); in der_heim_oid_cmp()
44 q->components, in der_heim_oid_cmp()
50 const heim_octet_string *q) in der_heim_octet_string_cmp() argument
52 if (p->length != q->length) in der_heim_octet_string_cmp()
53 return (int)(p->length - q->length); in der_heim_octet_string_cmp()
54 return memcmp(p->data, q->data, p->length); in der_heim_octet_string_cmp()
59 const heim_printable_string *q) in der_printable_string_cmp() argument
61 return der_heim_octet_string_cmp(p, q); in der_printable_string_cmp()
[all …]
|
| /netbsd/src/sys/external/isc/atheros_hal/dist/ar5211/ |
| D | ar5211_xmit.c | 80 ar5211SetTxQueueProps(struct ath_hal *ah, int q, const HAL_TXQ_INFO *qInfo) in ar5211SetTxQueueProps() argument
84 if (q >= HAL_NUM_TX_QUEUES) { in ar5211SetTxQueueProps()
86 __func__, q); in ar5211SetTxQueueProps()
89 return ath_hal_setTxQProps(ah, &ahp->ah_txq[q], qInfo); in ar5211SetTxQueueProps()
96 ar5211GetTxQueueProps(struct ath_hal *ah, int q, HAL_TXQ_INFO *qInfo) in ar5211GetTxQueueProps() argument
100 if (q >= HAL_NUM_TX_QUEUES) { in ar5211GetTxQueueProps()
102 __func__, q); in ar5211GetTxQueueProps()
105 return ath_hal_getTxQProps(ah, qInfo, &ahp->ah_txq[q]); in ar5211GetTxQueueProps()
117 int q; in ar5211SetupTxQueue() local
121 q = 9; in ar5211SetupTxQueue()
[all …]
|
| /netbsd/src/sys/dev/pci/cxgb/ |
| D | cxgb_sge.c | 170 static void t3_free_qset(adapter_t *sc, struct sge_qset *q);
174 static int free_tx_desc(struct sge_txq *q, int n, struct mbuf **m_vec);
186 reclaim_completed_tx(struct sge_txq *q, int nbufs, struct mbuf **mvec) in reclaim_completed_tx() argument
188 int reclaimed, reclaim = desc_reclaimable(q); in reclaim_completed_tx()
191 mtx_assert(&q->lock, MA_OWNED); in reclaim_completed_tx()
193 n = free_tx_desc(q, uimin(reclaim, nbufs), mvec); in reclaim_completed_tx()
195 q->cleaned += reclaimed; in reclaim_completed_tx()
196 q->in_use -= reclaimed; in reclaim_completed_tx()
208 should_restart_tx(const struct sge_txq *q) in should_restart_tx() argument
210 unsigned int r = q->processed - q->cleaned; in should_restart_tx()
[all …]
|
| /netbsd/src/external/lgpl3/gmp/dist/tests/devel/ |
| D | sqrtrem_1_2.c | 56 MPN_SIZEINBASE_2EXP (spinner_count, q, v, 1); \
70 mp_limb_t es, mer, er, s[1], r[2], q[2]; in check_all_values() local
81 *q = es * es; in check_all_values()
84 x = mpn_sqrtrem (s, r, q, 1); in check_all_values()
97 ++*q; in check_all_values()
98 } while (*q != 0); in check_all_values()
99 q[1] = 1; in check_all_values()
105 x = mpn_sqrtrem (s, r, q, 2); in check_all_values()
120 q[1] += (++*q == 0); in check_all_values()
155 mp_limb_t es, her, er, k, s[1], r[2], q[2]; in check_some_values() local
[all …]
|
| /netbsd/src/sys/arch/amiga/amiga/ |
| D | busfuncs.c | 140 volatile u_int16_t *q = (volatile u_int16_t *)(h + o); in amiga_contiguous_read_multi_2() local
143 *p++ = *q; in amiga_contiguous_read_multi_2()
152 volatile u_int16_t *q = (volatile u_int16_t *)(h + o); in amiga_contiguous_write_multi_2() local
155 *q = *p++; in amiga_contiguous_write_multi_2()
164 volatile u_int16_t *q = (volatile u_int16_t *)(h + o); in amiga_contiguous_read_region_2() local
167 *p++ = *q++; in amiga_contiguous_read_region_2()
176 volatile u_int16_t *q = (volatile u_int16_t *)(h + o); in amiga_contiguous_write_region_2() local
179 *q++ = *p++; in amiga_contiguous_write_region_2()
188 volatile u_int16_t *q = (volatile u_int16_t *)(h + o); in amiga_contiguous_set_region_2() local
191 *q++ = v; in amiga_contiguous_set_region_2()
[all …]
|
| /netbsd/src/external/bsd/openldap/dist/libraries/libldap/ |
| D | tavl.c | 70 TAvlnode *t, *p, *s, *q, *r; in ldap_tavl_insert() local
96 q = ldap_avl_child( p, cmp ); in ldap_tavl_insert()
97 if (q == NULL) { in ldap_tavl_insert()
99 if (( q = (TAvlnode *) ber_memalloc( sizeof( TAvlnode ))) == NULL ) { in ldap_tavl_insert()
102 q->avl_link[cmp] = p->avl_link[cmp]; in ldap_tavl_insert()
103 q->avl_link[!cmp] = p; in ldap_tavl_insert()
104 q->avl_data = data; in ldap_tavl_insert()
105 q->avl_bf = EH; in ldap_tavl_insert()
106 q->avl_bits[0] = q->avl_bits[1] = AVL_THREAD; in ldap_tavl_insert()
108 p->avl_link[cmp] = q; in ldap_tavl_insert()
[all …]
|
| /netbsd/src/external/lgpl3/gmp/dist/tests/mpf/ |
| D | t-set_q.c | 27 check_one (mpf_ptr got, mpq_srcptr q) in check_one() argument
31 mpf_set_q (got, q); in check_one()
33 PTR(n) = PTR(&q->_mp_num); in check_one()
34 SIZ(n) = SIZ(&q->_mp_num); in check_one()
35 EXP(n) = ABSIZ(&q->_mp_num); in check_one()
37 PTR(d) = PTR(&q->_mp_den); in check_one()
38 SIZ(d) = SIZ(&q->_mp_den); in check_one()
39 EXP(d) = ABSIZ(&q->_mp_den); in check_one()
44 mpq_trace (" q", q); in check_one()
56 mpq_t q; in check_rand() local
[all …]
|
| /netbsd/src/external/bsd/pcc/dist/pcc/arch/arm/ |
| D | code.c | 113 NODE *p, *q; in param_64bit() local
129 p = q = NULL; in param_64bit()
131 q = block(REG, NIL, NIL, INT, 0, 0); in param_64bit()
132 regno(q) = R0 + argofs; in param_64bit()
134 q = block(SCONV, q, NIL, in param_64bit()
141 q = block(PLUS, p, q, ULONGLONG, 0, 0); in param_64bit()
153 p = buildtree(ASSIGN, p, q); in param_64bit()
159 q = block(REG, NIL, NIL, sym->stype, sym->sdf, sym->sap); in param_64bit()
160 regno(q) = R0R1 + argofs; in param_64bit()
168 p = buildtree(ASSIGN, p, q); in param_64bit()
[all …]
|
| /netbsd/src/external/bsd/pcc/dist/pcc/f77/fcom/ |
| D | equiv.c | 57 register chainp q; in doequiv() local
71 for(q = p->equivs ; q ; q = q->eqvchain.nextp) in doequiv()
73 itemp = q->eqvchain.eqvitem; in doequiv()
92 offset = q->eqvchain.eqvoffset = offp->b_const.fconst.ci; in doequiv()
126 q->eqvchain.eqvitem = np; in doequiv()
131 else for(q = p->equivs ; q ; q = q->eqvchain.nextp) in doequiv()
133 if((np = q->eqvchain.eqvitem)) in doequiv()
139 … if(np->b_name.voffset + q->eqvchain.eqvoffset != 0) in doequiv()
149 np->b_name.voffset = - q->eqvchain.eqvoffset; in doequiv()
152 eqveqv(i, ovarno, q->eqvchain.eqvoffset + offset); in doequiv()
[all …]
|
| /netbsd/src/external/bsd/ntp/dist/libparse/ |
| D | parsesolaris.c | 286 queue_t *q, in setup_stream() argument
292 pprintf(DD_OPEN,"parse: SETUP_STREAM - setting up stream for q=%x\n", q); in setup_stream()
305 if (!q) in setup_stream()
307 putnext(q, mp); in setup_stream()
308 return putctl1(WR(q)->q_next, M_CTL, (mode == M_PARSE) ? MC_SERVICEIMM : in setup_stream()
321 queue_t *q, in parseopen() argument
331 pprintf(DD_OPEN, "parse: OPEN - q=%x\n", q); in parseopen()
339 if (q->q_ptr != (caddr_t)NULL) in parseopen()
345 q->q_ptr = (caddr_t)kmem_alloc(sizeof(parsestream_t), KM_SLEEP); in parseopen()
346 if (q->q_ptr == (caddr_t)0) in parseopen()
[all …]
|
| /netbsd/src/external/lgpl3/gmp/dist/tests/mpq/ |
| D | t-set_str.c | 61 mpq_t q; in check_samples() local
63 mpq_init (q); in check_samples()
65 mpq_set_ui (q, 0L, 1L); in check_samples()
66 check_one (q, 10, "0"); in check_samples()
67 check_one (q, 10, "0/1"); in check_samples()
68 check_one (q, 10, "0 / 1"); in check_samples()
69 check_one (q, 0, "0x0/ 1"); in check_samples()
70 check_one (q, 0, "0x0/ 0x1"); in check_samples()
71 check_one (q, 0, "0 / 0x1"); in check_samples()
73 check_one (q, 10, "-0"); in check_samples()
[all …]
|