Home
last modified time | relevance | path

Searched refs:tq (Results 1 – 25 of 105) sorted by relevance

12345

/NextBSD/cddl/contrib/opensolaris/lib/libzpool/common/
HDtaskq.c59 task_alloc(taskq_t *tq, int tqflags) in task_alloc() argument
64 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { in task_alloc()
65 tq->tq_freelist = t->tqent_next; in task_alloc()
67 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
81 tq->tq_maxalloc_wait++; in task_alloc()
82 rv = cv_timedwait(&tq->tq_maxalloc_cv, in task_alloc()
83 &tq->tq_lock, ddi_get_lbolt() + hz); in task_alloc()
84 tq->tq_maxalloc_wait--; in task_alloc()
88 mutex_exit(&tq->tq_lock); in task_alloc()
92 mutex_enter(&tq->tq_lock); in task_alloc()
[all …]
/NextBSD/sys/cddl/compat/opensolaris/kern/
HDopensolaris_taskq.c68 taskq_t *tq; in taskq_create() local
73 tq = kmem_alloc(sizeof(*tq), KM_SLEEP); in taskq_create()
74 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, in taskq_create()
75 &tq->tq_queue); in taskq_create()
76 (void) taskqueue_start_threads(&tq->tq_queue, nthreads, pri, "%s", name); in taskq_create()
78 return ((taskq_t *)tq); in taskq_create()
90 taskq_destroy(taskq_t *tq) in taskq_destroy() argument
93 taskqueue_free(tq->tq_queue); in taskq_destroy()
94 kmem_free(tq, sizeof(*tq)); in taskq_destroy()
98 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member() argument
[all …]
/NextBSD/sys/kern/
HDsubr_taskqueue.c85 #define TQ_LOCK(tq) \ argument
87 if ((tq)->tq_spin) \
88 mtx_lock_spin(&(tq)->tq_mutex); \
90 mtx_lock(&(tq)->tq_mutex); \
92 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument
94 #define TQ_UNLOCK(tq) \ argument
96 if ((tq)->tq_spin) \
97 mtx_unlock_spin(&(tq)->tq_mutex); \
99 mtx_unlock(&(tq)->tq_mutex); \
101 #define TQ_ASSERT_UNLOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_NOTOWNED) argument
[all …]
/NextBSD/usr.sbin/jail/
HDconfig.c151 TAILQ_FOREACH_SAFE(j, &cfjails, tq, tj) { in load_config()
157 TAILQ_FOREACH(j, &cfjails, tq) { in load_config()
160 TAILQ_CONCAT(&opp, &j->params, tq); in load_config()
173 TAILQ_FOREACH(wj, &wild, tq) { in load_config()
175 TAILQ_FOREACH(p, &opp, tq) in load_config()
180 TAILQ_FOREACH(p, &wj->params, tq) in load_config()
184 TAILQ_FOREACH(p, &opp, tq) in load_config()
189 TAILQ_FOREACH(p, &j->params, tq) { in load_config()
192 TAILQ_FOREACH(s, &p->val, tq) { in load_config()
194 TAILQ_FOREACH(vp, &j->params, tq) in load_config()
[all …]
HDjailparse.y78 TAILQ_INSERT_TAIL(&j->params, $2, tq);
86 TAILQ_CONCAT(&$$->params, $3, tq);
99 TAILQ_INSERT_TAIL($$, $2, tq);
115 TAILQ_CONCAT(&$$->val, $3, tq);
121 TAILQ_CONCAT(&$$->val, $3, tq);
128 TAILQ_CONCAT(&$$->val, $2, tq);
160 TAILQ_INSERT_TAIL($$, $1, tq);
165 TAILQ_INSERT_TAIL($$, $3, tq);
191 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
212 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
HDstate.c72 TAILQ_FOREACH(s, &p->val, tq) { in dep_setup()
84 TAILQ_FOREACH(j, &cfjails, tq) in dep_setup()
88 TAILQ_FOREACH(j, &cfjails, tq) in dep_setup()
95 TAILQ_FOREACH(j, &cfjails, tq) { in dep_setup()
99 TAILQ_FOREACH(s, &p->val, tq) { in dep_setup()
143 TAILQ_FOREACH(j, &cfjails, tq) in dep_setup()
144 STAILQ_FOREACH(d, &j->dep[DEP_FROM], tq[DEP_FROM]) in dep_setup()
173 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfrom]) { in dep_check()
245 STAILQ_FOREACH(d, &j->dep[depto], tq[depto]) { in dep_done()
274 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfrom]) in dep_reset()
[all …]
HDjailp.h139 STAILQ_ENTRY(cfvar) tq;
147 TAILQ_ENTRY(cfstring) tq;
156 TAILQ_ENTRY(cfparam) tq;
167 TAILQ_ENTRY(cfjail) tq;
188 STAILQ_ENTRY(cfdepend) tq[2];
/NextBSD/sys/dev/netmap/
HDif_em_netmap.h52 taskqueue_block(txr->tq); in em_netmap_block_tasks()
53 taskqueue_drain(txr->tq, &txr->tx_task); in em_netmap_block_tasks()
54 taskqueue_block(rxr->tq); in em_netmap_block_tasks()
55 taskqueue_drain(rxr->tq, &rxr->rx_task); in em_netmap_block_tasks()
58 taskqueue_block(adapter->tq); in em_netmap_block_tasks()
59 taskqueue_drain(adapter->tq, &adapter->link_task); in em_netmap_block_tasks()
60 taskqueue_drain(adapter->tq, &adapter->que_task); in em_netmap_block_tasks()
74 taskqueue_unblock(txr->tq); in em_netmap_unblock_tasks()
75 taskqueue_unblock(rxr->tq); in em_netmap_unblock_tasks()
78 taskqueue_unblock(adapter->tq); in em_netmap_unblock_tasks()
/NextBSD/sys/dev/wtap/
HDif_medium.c45 eh->tq = taskqueue_create("wtap_tx_taskq", M_NOWAIT | M_ZERO, in init_medium()
46 taskqueue_thread_enqueue, &eh->tq); in init_medium()
47 taskqueue_start_threads(&eh->tq, 1, PI_NET, "%s taskq", "wtap_medium"); in init_medium()
58 taskqueue_free(md->tx_handler->tq); in deinit_medium()
81 taskqueue_enqueue(md->tx_handler->tq, &md->tx_handler->proc); in medium_transmit()
/NextBSD/contrib/nvi/ex/
HDex_tag.c152 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) { in ex_tag_next()
192 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) { in ex_tag_prev()
322 if (TAILQ_EMPTY(exp->tq)) { in ex_tag_pop()
330 dtqp = TAILQ_FIRST(exp->tq); in ex_tag_pop()
342 TAILQ_FOREACH(tqp, exp->tq, q) in ex_tag_pop()
355 for (tqp = TAILQ_FIRST(exp->tq); tqp; in ex_tag_pop()
358 if (tqp == TAILQ_FIRST(exp->tq)) in ex_tag_pop()
373 if (tqp == TAILQ_FIRST(exp->tq)) in ex_tag_pop()
397 if (TAILQ_EMPTY(exp->tq)) { in ex_tag_top()
403 return (tag_pop(sp, TAILQ_PREV(TAILQ_LAST(exp->tq, _tqh), _tqh, q), in ex_tag_top()
[all …]
/NextBSD/sys/dev/ifmlx4/
HDen_cq.c68 cq->tq = taskqueue_create_fast("mlx4_en_que", M_NOWAIT, in mlx4_en_create_cq()
69 taskqueue_thread_enqueue, &cq->tq); in mlx4_en_create_cq()
72 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s rx cq", in mlx4_en_create_cq()
77 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s tx cq", in mlx4_en_create_cq()
177 taskqueue_drain(cq->tq, &cq->cq_task); in mlx4_en_destroy_cq()
178 taskqueue_free(cq->tq); in mlx4_en_destroy_cq()
191 taskqueue_drain(cq->tq, &cq->cq_task); in mlx4_en_deactivate_cq()
/NextBSD/sys/ofed/drivers/net/mlx4/
HDen_cq.c68 cq->tq = taskqueue_create_fast("mlx4_en_que", M_NOWAIT, in mlx4_en_create_cq()
69 taskqueue_thread_enqueue, &cq->tq); in mlx4_en_create_cq()
72 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s rx cq", in mlx4_en_create_cq()
77 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s tx cq", in mlx4_en_create_cq()
177 taskqueue_drain(cq->tq, &cq->cq_task); in mlx4_en_destroy_cq()
178 taskqueue_free(cq->tq); in mlx4_en_destroy_cq()
191 taskqueue_drain(cq->tq, &cq->cq_task); in mlx4_en_deactivate_cq()
/NextBSD/lib/libdispatch/src/
HDdata.m75 dispatch_queue_t tq = dd->do_targetq; \
80 if (!tq) { \
81 tq = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0);\
83 dispatch_async_f(tq, ctxt, func); \
85 if (tq) { \ category
86 _os_object_release_internal((_os_object_t)tq); \
HDapply.c159 dispatch_queue_t dq = da->da_dc->dc_data, rq = dq, tq; in _dispatch_apply_redirect() local
166 for (tq = dq; 1; tq = tq->do_targetq) { in _dispatch_apply_redirect()
167 (void)dispatch_atomic_sub2o(tq, dq_running, excess, relaxed); in _dispatch_apply_redirect()
168 if (tq == rq) { in _dispatch_apply_redirect()
HDqueue.c62 dispatch_queue_t tq, pthread_priority_t p);
64 dispatch_queue_t tq, pthread_priority_t p);
1133 dispatch_queue_t tq) in dispatch_queue_create_with_target() argument
1164 if (!tq) { in dispatch_queue_create_with_target()
1187 tq = _dispatch_get_root_queue(qos, overcommit); in dispatch_queue_create_with_target()
1188 if (slowpath(!tq)) { in dispatch_queue_create_with_target()
1192 _dispatch_retain(tq); in dispatch_queue_create_with_target()
1198 _dispatch_queue_priority_inherit_from_target(dq, tq); in dispatch_queue_create_with_target()
1201 dq->do_targetq = tq; in dispatch_queue_create_with_target()
1324 dispatch_queue_t prev_dq, dq = _dispatch_queue_get_current(), tq = ctxt; in _dispatch_set_target_queue2() local
[all …]
HDobject.c145 dispatch_queue_t tq = dou._do->do_targetq; in _dispatch_dealloc() local
152 dispatch_async_f(tq, ctxt, func); in _dispatch_dealloc()
154 _dispatch_release(tq); in _dispatch_dealloc()
/NextBSD/sys/dev/nvd/
HDnvd.c72 struct taskqueue *tq; member
198 taskqueue_enqueue(ndisk->tq, &ndisk->bioqtask); in nvd_strategy()
342 ndisk->tq = taskqueue_create("nvd_taskq", M_WAITOK, in nvd_new_disk()
343 taskqueue_thread_enqueue, &ndisk->tq); in nvd_new_disk()
344 taskqueue_start_threads(&ndisk->tq, 1, PI_DISK, "nvd taskq"); in nvd_new_disk()
370 taskqueue_free(ndisk->tq); in destroy_geom_disk()
/NextBSD/sys/dev/cfi/
HDcfi_disk.c63 struct taskqueue *tq; /* private task queue for i/o request */ member
128 sc->tq = taskqueue_create("cfid_taskq", M_NOWAIT, in cfi_disk_attach()
129 taskqueue_thread_enqueue, &sc->tq); in cfi_disk_attach()
130 taskqueue_start_threads(&sc->tq, 1, PI_DISK, "cfid taskq"); in cfi_disk_attach()
144 taskqueue_free(sc->tq); in cfi_disk_detach()
330 taskqueue_enqueue(sc->tq, &sc->iotask); in cfi_disk_strategy()
/NextBSD/usr.sbin/gstat/
HDgstat.c81 struct timespec tp, tq; in main() local
199 geom_stats_snapshot_timestamp(sq, &tq); in main()
205 dt = tp.tv_sec - tq.tv_sec; in main()
206 dt += (tp.tv_nsec - tq.tv_nsec) * 1e-9; in main()
207 tq = tp; in main()
/NextBSD/crypto/openssh/
HDssh-keyscan.c106 TAILQ_HEAD(conlist, Connection) tq; /* Timeout Queue */
358 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); in conalloc()
376 TAILQ_REMOVE(&tq, &fdcon[s], c_link); in confree()
384 TAILQ_REMOVE(&tq, &fdcon[s], c_link); in contouch()
387 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); in contouch()
530 c = TAILQ_FIRST(&tq); in conloop()
563 c = TAILQ_FIRST(&tq); in conloop()
628 TAILQ_INIT(&tq); in main()
/NextBSD/sbin/devfs/
HDdevfs.c173 STAILQ_ENTRY(ptrstq) tq;
204 STAILQ_INSERT_TAIL(&plist, pt, tq); in tokenize()
218 STAILQ_REMOVE_HEAD(&plist, tq); in tokenize()
/NextBSD/sys/dev/nand/
HDnand_geom.c111 taskqueue_enqueue(chip->tq, &chip->iotask); in nand_strategy()
133 taskqueue_enqueue(chip->tq, &chip->iotask); in nand_strategy_raw()
428 chip->tq = taskqueue_create("nand_taskq", M_WAITOK, in create_geom_disk()
429 taskqueue_thread_enqueue, &chip->tq); in create_geom_disk()
430 taskqueue_start_threads(&chip->tq, 1, PI_DISK, "nand taskq"); in create_geom_disk()
445 taskqueue_free(chip->tq); in destroy_geom_disk()
/NextBSD/sys/compat/linuxkpi/common/include/linux/
HDworkqueue.h154 flush_taskqueue(struct taskqueue *tq) in flush_taskqueue() argument
160 taskqueue_enqueue(tq, &flushtask); in flush_taskqueue()
161 taskqueue_drain(tq, &flushtask); in flush_taskqueue()
/NextBSD/sys/dev/ixgbe/
HDif_ix.c690 if (que->tq) { in ixgbe_detach()
692 taskqueue_drain(que->tq, &txr->txq_task); in ixgbe_detach()
694 taskqueue_drain(que->tq, &que->que_task); in ixgbe_detach()
695 taskqueue_free(que->tq); in ixgbe_detach()
700 if (adapter->tq) { in ixgbe_detach()
701 taskqueue_drain(adapter->tq, &adapter->link_task); in ixgbe_detach()
702 taskqueue_drain(adapter->tq, &adapter->mod_task); in ixgbe_detach()
703 taskqueue_drain(adapter->tq, &adapter->msf_task); in ixgbe_detach()
705 taskqueue_drain(adapter->tq, &adapter->mbx_task); in ixgbe_detach()
707 taskqueue_drain(adapter->tq, &adapter->phy_task); in ixgbe_detach()
[all …]
HDif_ixv.c474 if (que->tq) { in ixv_detach()
476 taskqueue_drain(que->tq, &txr->txq_task); in ixv_detach()
477 taskqueue_drain(que->tq, &que->que_task); in ixv_detach()
478 taskqueue_free(que->tq); in ixv_detach()
483 if (adapter->tq) { in ixv_detach()
484 taskqueue_drain(adapter->tq, &adapter->link_task); in ixv_detach()
485 taskqueue_free(adapter->tq); in ixv_detach()
827 taskqueue_enqueue(que->tq, &que->que_task); in ixv_handle_que()
924 taskqueue_enqueue(que->tq, &que->que_task); in ixv_msix_que()
946 taskqueue_enqueue(adapter->tq, &adapter->link_task); in ixv_msix_mbx()
[all …]

12345