Searched refs:tq (Results 1 - 25 of 48) sorted by relevance

12

/netbsd-current/external/cddl/osnet/dist/lib/libzpool/common/
H A Dtaskq.c59 task_alloc(taskq_t *tq, int tqflags) argument
64 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) {
65 tq->tq_freelist = t->tqent_next;
67 if (tq->tq_nalloc >= tq->tq_maxalloc) {
81 tq->tq_maxalloc_wait++;
82 rv = cv_timedwait(&tq->tq_maxalloc_cv,
83 &tq
100 task_free(taskq_t *tq, taskq_ent_t *t) argument
117 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) argument
150 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument
182 taskq_wait(taskq_t *tq) argument
193 taskq_t *tq = arg; local
232 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); local
278 taskq_destroy(taskq_t *tq) argument
316 taskq_member(taskq_t *tq, void *t) argument
[all...]
/netbsd-current/external/cddl/osnet/sys/kern/
H A Dtaskq.c76 taskq_t *tq = state->te_self; local
81 lwp_setspecific(taskq_lwp_key, tq);
83 mutex_enter(&tq->tq_lock);
84 while (!tq->tq_destroyed) {
85 if (SIMPLEQ_EMPTY(&tq->tq_list)) {
86 if (ISSET(tq->tq_flags, TASKQ_DYNAMIC))
88 tq->tq_waiting++;
89 error = cv_timedwait(&tq->tq_cv, &tq->tq_lock,
91 tq
142 taskq_dispatch_common(taskq_t *tq, taskq_ent_t *tqe, uint_t flags) argument
177 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument
212 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *tqe) argument
228 taskq_wait(taskq_t *tq) argument
243 taskq_member(taskq_t *tq, kthread_t *thread) argument
261 taskq_t *tq; local
304 taskq_destroy(taskq_t *tq) argument
[all...]
/netbsd-current/sys/external/bsd/common/linux/
H A Dlinux_tasklet.c140 * tasklet_queue_init(tq, prio)
142 * Initialize the tasklet queue tq for running tasklets at softint
146 tasklet_queue_init(struct tasklet_queue *tq, unsigned prio) argument
151 tq->tq_percpu = percpu_create(sizeof(struct tasklet_cpu),
153 KASSERT(tq->tq_percpu != NULL);
156 tq->tq_sih = softint_establish(prio|SOFTINT_MPSAFE, &tasklet_softintr,
157 tq);
158 if (tq->tq_sih == NULL) {
167 softint_disestablish(tq->tq_sih);
168 tq
183 tasklet_queue_fini(struct tasklet_queue *tq) argument
201 struct tasklet_queue *const tq = cookie; local
279 tasklet_queue_schedule(struct tasklet_queue *tq, struct tasklet_struct *tasklet) argument
307 tasklet_queue_enqueue(struct tasklet_queue *tq, struct tasklet_struct *tasklet) argument
[all...]
/netbsd-current/external/gpl3/gcc.old/dist/libgfortran/io/
H A Dasync.c267 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
268 tq->arg = *arg;
269 tq->type = type;
270 tq->has_id = 0;
273 au->head = tq;
275 au->tail->next = tq;
276 au->tail = tq;
289 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
291 tq->type = type;
292 tq
313 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
333 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
355 transfer_queue *tq = xmalloc (sizeof (transfer_queue)); local
[all...]
/netbsd-current/external/gpl3/gcc/dist/libgfortran/io/
H A Dasync.c267 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
268 tq->arg = *arg;
269 tq->type = type;
270 tq->has_id = 0;
273 au->head = tq;
275 au->tail->next = tq;
276 au->tail = tq;
289 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
291 tq->type = type;
292 tq
313 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
333 transfer_queue *tq = calloc (sizeof (transfer_queue), 1); local
355 transfer_queue *tq = xmalloc (sizeof (transfer_queue)); local
[all...]
/netbsd-current/external/lgpl3/gmp/dist/mini-gmp/tests/
H A Dt-mpq_muldiv_2exp.c54 mpq_t aq, rq, tq; local
63 mpq_init (tq);
78 mpq_neg (tq, rq);
79 mpq_div (tq, aq, tq);
80 mpq_get_den (t, tq);
83 || mpz_sizeinbase (t, 2) - 1 != e || mpz_cmp_si (mpq_numref (tq), -1) != 0)
113 mpq_set (tq, aq);
116 if (!mpq_equal (tq, rq))
125 if (!mpq_equal (rq, tq))
[all...]
/netbsd-current/crypto/external/bsd/heimdal/dist/lib/hcrypto/libtommath/
H A Dbn_mp_div.c25 mp_int ta, tb, tq, q; local
47 if ((res = mp_init_multi(&ta, &tb, &tq, &q, NULL) != MP_OKAY)) {
52 mp_set(&tq, 1);
57 ((res = mp_mul_2d(&tq, n, &tq)) != MP_OKAY)) {
64 ((res = mp_add(&q, &tq, &q)) != MP_OKAY)) {
69 ((res = mp_div_2d(&tq, 1, &tq, NULL)) != MP_OKAY)) {
86 mp_clear_multi(&ta, &tb, &tq, &q, NULL);
/netbsd-current/external/lgpl3/mpfr/dist/src/
H A Dsum.c680 mpfr_prec_t tq; local
684 tq = u - minexp;
685 MPFR_ASSERTD (tq > 0); /* number of trailing bits */
686 MPFR_LOG_MSG (("tq=%Pd\n", tq));
688 wi = tq / GMP_NUMB_BITS;
689 td = tq % GMP_NUMB_BITS;
701 mpfr_prec_t tq; local
705 tq = u - minexp;
706 MPFR_ASSERTD (tq >
959 mpfr_prec_t tq; local
[all...]
/netbsd-current/external/bsd/nvi/dist/ex/
H A Dex_tag.c192 if ((tqp = TAILQ_FIRST(&exp->tq)) == NULL) {
232 if ((tqp = TAILQ_FIRST(&exp->tq)) == NULL) {
364 if (TAILQ_EMPTY(&exp->tq)) {
372 dtqp = TAILQ_FIRST(&exp->tq);
384 TAILQ_FOREACH(tqp, &exp->tq, q)
398 for (tqp = TAILQ_FIRST(&exp->tq);
402 if (tqp == TAILQ_FIRST(&exp->tq))
440 if (TAILQ_EMPTY(&exp->tq)) {
446 tqp = TAILQ_LAST(&exp->tq, _tqh);
487 tqp = TAILQ_FIRST(&exp->tq);
[all...]
H A Dex.h164 TAILQ_HEAD(_tqh, _tagq) tq; /* Tag queue. */ member in struct:_ex_private
H A Dex_cscope.c472 if (TAILQ_EMPTY(&exp->tq)) {
544 if (TAILQ_EMPTY(&exp->tq)) {
545 TAILQ_INSERT_HEAD(&exp->tq, rtqp, q);
549 rtqp = TAILQ_FIRST(&exp->tq);
553 TAILQ_INSERT_HEAD(&exp->tq, tqp, q);
H A Dex_init.c60 TAILQ_INIT(&nexp->tq);
/netbsd-current/crypto/external/bsd/openssh/dist/
H A Dssh-keyscan.c124 TAILQ_HEAD(conlist, Connection) tq; /* Timeout Queue */
413 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link);
437 TAILQ_REMOVE(&tq, &fdcon[s], c_link);
446 TAILQ_REMOVE(&tq, &fdcon[s], c_link);
449 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link);
595 c = TAILQ_FIRST(&tq);
615 c = TAILQ_FIRST(&tq);
710 TAILQ_INIT(&tq);
/netbsd-current/sbin/canconfig/
H A Dcanconfig.c389 uint32_t tq, ntq, bps; local
390 tq = ((uint64_t)clt.clt_brp * (uint64_t)1000000000) /
394 1 + clt.clt_prop + clt.clt_ps1 + clt.clt_ps2, tq);
395 bps = 1000000000 / (tq * ntq);
/netbsd-current/libexec/ftpd/
H A Dcmds.c852 char tq[MAXPATHLEN + 1] = ""; local
887 sz2 = readlink(tp, tq, MAXPATHLEN);
904 tq[sz2] = 0;
905 sz2 = strlen(tq);
906 if (tq[sz2 - 1] == '/')
907 tq[--sz2] = 0;
912 if (tq[0] == '/') {
917 memcpy(tp, tq, sz2);
927 (void)memcpy(cq + 1, tq, sz2);
/netbsd-current/sys/external/bsd/drm2/dist/drm/i915/gem/selftests/
H A Di915_gem_context.c655 struct i915_request *tq[5] = {}; local
713 err = throttle(ce, tq, ARRAY_SIZE(tq));
748 throttle_release(tq, ARRAY_SIZE(tq));
765 struct i915_request *tq[5] = {}; local
851 err = throttle(ce, tq, ARRAY_SIZE(tq));
887 throttle_release(tq, ARRAY_SIZE(tq));
1352 struct i915_request *tq[5] = {}; local
[all...]
/netbsd-current/usr.bin/xlint/lint1/
H A Ddebug.c341 type_qualifiers_string(type_qualifiers tq) argument
346 tq.tq_const ? " const" : "",
347 tq.tq_restrict ? " restrict" : "",
348 tq.tq_volatile ? " volatile" : "",
349 tq.tq_atomic ? " atomic" : "");
/netbsd-current/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/
H A Dtsan_libdispatch_mac.cc78 dispatch_queue_t tq = *( local
80 return tq;
84 dispatch_queue_t tq = GetTargetQueueFromQueue((dispatch_queue_t)source); local
85 CHECK_NE(tq, 0);
86 return tq;
/netbsd-current/external/gpl3/gcc.old/dist/libsanitizer/tsan/
H A Dtsan_libdispatch_mac.cc76 dispatch_queue_t tq = *( local
78 return tq;
82 dispatch_queue_t tq = GetTargetQueueFromQueue((dispatch_queue_t)source); local
83 CHECK_NE(tq, 0);
84 return tq;
/netbsd-current/external/gpl3/gcc/dist/libsanitizer/tsan/
H A Dtsan_interceptors_libdispatch.cpp70 dispatch_queue_t tq = *( local
72 return tq;
76 dispatch_queue_t tq = GetTargetQueueFromQueue((dispatch_queue_t)source); local
77 CHECK_NE(tq, 0);
78 return tq;
/netbsd-current/external/cddl/osnet/dist/uts/common/fs/zfs/
H A Ddmu_objset.c1846 taskq_t *tq = NULL; local
1885 tq = taskq_create("dmu_objset_find", ntasks, minclsyspri, ntasks,
1887 if (tq == NULL) {
1893 dcp->dc_tq = tq;
1896 (void) taskq_dispatch(tq, dmu_objset_find_dp_cb, dcp, TQ_SLEEP);
1907 taskq_wait(tq);
1908 taskq_destroy(tq);
/netbsd-current/external/bsd/wpa/dist/src/tls/
H A Dlibtommath.c1611 mp_int ta, tb, tq, q; local
1633 if ((res = mp_init_multi(&ta, &tb, &tq, &q, NULL)) != MP_OKAY) {
1638 mp_set(&tq, 1);
1643 ((res = mp_mul_2d(&tq, n, &tq)) != MP_OKAY)) {
1650 ((res = mp_add(&q, &tq, &q)) != MP_OKAY)) {
1655 ((res = mp_div_2d(&tq, 1, &tq, NULL)) != MP_OKAY)) {
1672 mp_clear_multi(&ta, &tb, &tq, &q, NULL);
/netbsd-current/usr.sbin/mtrace/
H A Dmtrace.c394 struct timeval tq, tr, tv; local
453 gettimeofday(&tq, 0);
463 tv.tv_sec = tq.tv_sec + timeout - tv.tv_sec;
464 tv.tv_usec = tq.tv_usec - tv.tv_usec;
595 save->qtime = ((tq.tv_sec + JAN_1970) << 16) +
596 (tq.tv_usec << 10) / 15625;
/netbsd-current/external/lgpl3/gmp/dist/mini-gmp/
H A Dmini-gmp.c2220 mpz_t tq, tr;
2229 mpz_init2 (tq, qn * GMP_LIMB_BITS);
2230 qp = tq->_mp_d;
2241 tq->_mp_size = qs < 0 ? -qn : qn;
2249 mpz_sub_ui (tq, tq, 1);
2256 mpz_add_ui (tq, tq, 1);
2263 mpz_swap (tq, q);
2264 mpz_clear (tq);
2208 mpz_t tq, tr; local
[all...]
/netbsd-current/sys/kern/
H A Dtty.c1288 struct clist tq; local
1291 tq = tp->t_rawq;
1293 tp->t_canq = tq;
1942 struct clist tq; local
1949 tq = tp->t_rawq;
1952 while ((c = getc(&tq)) >= 0)

Completed in 577 milliseconds

12