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

12345

/freebsd-11-stable/cddl/contrib/opensolaris/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++;
83 rv = cv_timedwait(&tq->tq_maxalloc_cv,
84 &tq
105 task_free(taskq_t *tq, taskq_ent_t *t) argument
122 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) argument
155 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument
187 taskq_wait(taskq_t *tq) argument
196 taskq_wait_id(taskq_t *tq, taskqid_t id) argument
204 taskq_t *tq = arg; local
243 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); local
289 taskq_destroy(taskq_t *tq) argument
327 taskq_member(taskq_t *tq, void *t) argument
[all...]
/freebsd-11-stable/sys/dev/wtap/wtap_hal/
H A Dhandler.h45 struct taskqueue *tq; member in struct:eventhandler
/freebsd-11-stable/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c69 taskq_t *tq; local
74 tq = kmem_alloc(sizeof(*tq), KM_SLEEP);
75 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue,
76 &tq->tq_queue);
77 (void) taskqueue_start_threads(&tq->tq_queue, nthreads, pri, "%s", name);
79 return ((taskq_t *)tq);
91 taskq_destroy(taskq_t *tq) argument
94 taskqueue_free(tq->tq_queue);
95 kmem_free(tq, sizeo
99 taskq_member(taskq_t *tq, kthread_t *thread) argument
116 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument
153 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags, taskq_ent_t *task) argument
172 taskq_wait(taskq_t *tq) argument
178 taskq_wait_id(taskq_t *tq, taskqid_t id) argument
[all...]
/freebsd-11-stable/usr.sbin/jail/
H A Djailparse.y80 TAILQ_INSERT_TAIL(&j->params, $2, tq);
88 TAILQ_CONCAT(&$$->params, $3, tq);
101 TAILQ_INSERT_TAIL($$, $2, tq);
117 TAILQ_CONCAT(&$$->val, $3, tq);
123 TAILQ_CONCAT(&$$->val, $3, tq);
130 TAILQ_CONCAT(&$$->val, $2, tq);
162 TAILQ_INSERT_TAIL($$, $1, tq);
167 TAILQ_INSERT_TAIL($$, $3, tq);
193 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
214 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
[all...]
H A Dconfig.c153 TAILQ_FOREACH_SAFE(j, &cfjails, tq, tj) {
159 TAILQ_FOREACH(j, &cfjails, tq) {
162 TAILQ_CONCAT(&opp, &j->params, tq);
175 TAILQ_FOREACH(wj, &wild, tq) {
177 TAILQ_FOREACH(p, &opp, tq)
182 TAILQ_FOREACH(p, &wj->params, tq)
186 TAILQ_FOREACH(p, &opp, tq)
191 TAILQ_FOREACH(p, &j->params, tq) {
194 TAILQ_FOREACH(s, &p->val, tq) {
196 TAILQ_FOREACH(vp, &j->params, tq)
[all...]
H A Dstate.c74 TAILQ_FOREACH(s, &p->val, tq) {
86 TAILQ_FOREACH(j, &cfjails, tq)
90 TAILQ_FOREACH(j, &cfjails, tq)
97 TAILQ_FOREACH(j, &cfjails, tq) {
101 TAILQ_FOREACH(s, &p->val, tq) {
145 TAILQ_FOREACH(j, &cfjails, tq)
146 STAILQ_FOREACH(d, &j->dep[DEP_FROM], tq[DEP_FROM])
175 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfrom]) {
247 STAILQ_FOREACH(d, &j->dep[depto], tq[depto]) {
276 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfro
[all...]
H A Djailp.h143 STAILQ_ENTRY(cfvar) tq; member in struct:cfvar
151 TAILQ_ENTRY(cfstring) tq; member in struct:cfstring
160 TAILQ_ENTRY(cfparam) tq; member in struct:cfparam
171 TAILQ_ENTRY(cfjail) tq; member in struct:cfjail
192 STAILQ_ENTRY(cfdepend) tq[2]; member in struct:cfdepend
/freebsd-11-stable/sys/kern/
H A Dsubr_taskqueue.c87 #define TQ_LOCK(tq) \
89 if ((tq)->tq_spin) \
90 mtx_lock_spin(&(tq)->tq_mutex); \
92 mtx_lock(&(tq)->tq_mutex); \
94 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED)
96 #define TQ_UNLOCK(tq) \
98 if ((tq)->tq_spin) \
99 mtx_unlock_spin(&(tq)->tq_mutex); \
101 mtx_unlock(&(tq)
118 TQ_SLEEP(struct taskqueue *tq, void *p, const char *wm) argument
192 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) argument
654 struct taskqueue *tq; local
744 taskqueue_run_callback(struct taskqueue *tq, enum taskqueue_callback_type cb_type) argument
758 struct taskqueue **tqp, *tq; local
796 struct taskqueue **tqp, *tq; local
[all...]
H A Dsubr_gtaskqueue.c86 #define TQ_LOCK(tq) \
88 if ((tq)->tq_spin) \
89 mtx_lock_spin(&(tq)->tq_mutex); \
91 mtx_lock(&(tq)->tq_mutex); \
93 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED)
95 #define TQ_UNLOCK(tq) \
97 if ((tq)->tq_spin) \
98 mtx_unlock_spin(&(tq)->tq_mutex); \
100 mtx_unlock(&(tq)
114 TQ_SLEEP(struct gtaskqueue *tq, void *p, const char *wm) argument
160 gtaskqueue_terminate(struct thread **pp, struct gtaskqueue *tq) argument
391 struct gtaskqueue *tq; local
463 gtaskqueue_run_callback(struct gtaskqueue *tq, enum taskqueue_callback_type cb_type) argument
477 struct gtaskqueue **tqp, *tq; local
515 struct gtaskqueue **tqp, *tq; local
[all...]
/freebsd-11-stable/sys/dev/liquidio/base/
H A Dlio_response_manager.c61 ctq->tq = taskqueue_create("lio_dma_comp", M_WAITOK,
62 taskqueue_thread_enqueue, &ctq->tq);
63 if (ctq->tq == NULL) {
68 TIMEOUT_TASK_INIT(ctq->tq, &ctq->work, 0, lio_poll_req_completion,
73 taskqueue_start_threads(&ctq->tq, 1, PI_NET, "lio%d_dma_comp",
75 taskqueue_enqueue_timeout(ctq->tq, &ctq->work, lio_ms_to_ticks(50));
84 if (oct->dma_comp_tq.tq != NULL) {
85 while (taskqueue_cancel_timeout(oct->dma_comp_tq.tq,
87 taskqueue_drain_timeout(oct->dma_comp_tq.tq,
89 taskqueue_free(oct->dma_comp_tq.tq);
[all...]
H A Dlio_request_manager.c161 db_tq->tq = taskqueue_create("lio_check_db_timeout", M_WAITOK,
162 taskqueue_thread_enqueue, &db_tq->tq);
163 if (db_tq->tq == NULL) {
169 TIMEOUT_TASK_INIT(db_tq->tq, &db_tq->work, 0, lio_check_db_timeout,
174 taskqueue_start_threads(&db_tq->tq, 1, PI_NET,
177 taskqueue_enqueue_timeout(db_tq->tq, &db_tq->work, 1);
202 if (oct->check_db_tq[iq_no].tq != NULL) {
203 while (taskqueue_cancel_timeout(oct->check_db_tq[iq_no].tq,
206 taskqueue_drain_timeout(oct->check_db_tq[iq_no].tq,
208 taskqueue_free(oct->check_db_tq[iq_no].tq);
[all...]
/freebsd-11-stable/sys/compat/linuxkpi/common/src/
H A Dlinux_work.c117 struct taskqueue *tq; local
119 tq = dwork->work.work_queue->taskqueue;
120 taskqueue_enqueue(tq, &dwork->work.work_task);
325 struct taskqueue *tq; local
336 tq = work->work_queue->taskqueue;
337 if (taskqueue_cancel(tq, &work->work_task, NULL) != 0)
338 taskqueue_drain(tq, &work->work_task);
341 tq = work->work_queue->taskqueue;
342 if (taskqueue_cancel(tq, &work->work_task, NULL) != 0)
343 taskqueue_drain(tq,
386 struct taskqueue *tq; local
425 struct taskqueue *tq; local
469 struct taskqueue *tq; local
494 struct taskqueue *tq; local
538 struct taskqueue *tq; local
[all...]
/freebsd-11-stable/sys/dev/wtap/
H A Dif_medium.c45 eh->tq = taskqueue_create("wtap_tx_taskq", M_NOWAIT | M_ZERO,
46 taskqueue_thread_enqueue, &eh->tq);
47 taskqueue_start_threads(&eh->tq, 1, PI_NET, "%s taskq", "wtap_medium");
58 taskqueue_free(md->tx_handler->tq);
81 taskqueue_enqueue(md->tx_handler->tq, &md->tx_handler->proc);
/freebsd-11-stable/sys/dev/ixl/
H A Dixl_iw_int.h63 struct taskqueue *tq; member in struct:ixl_iw_state
H A Dixl_iw.c179 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
210 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
407 ixl_iw.tq = taskqueue_create("ixl_iw", M_NOWAIT,
408 taskqueue_thread_enqueue, &ixl_iw.tq);
409 if (ixl_iw.tq == NULL) {
414 taskqueue_start_threads(&ixl_iw.tq, 1, PI_NET, "ixl iw");
420 taskqueue_free(ixl_iw.tq);
432 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
473 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
481 taskqueue_drain(ixl_iw.tq,
[all...]
/freebsd-11-stable/sys/dev/netmap/
H A Dif_em_netmap.h52 taskqueue_block(txr->tq);
53 taskqueue_drain(txr->tq, &txr->tx_task);
54 taskqueue_block(rxr->tq);
55 taskqueue_drain(rxr->tq, &rxr->rx_task);
58 taskqueue_block(adapter->tq);
59 taskqueue_drain(adapter->tq, &adapter->link_task);
60 taskqueue_drain(adapter->tq, &adapter->que_task);
74 taskqueue_unblock(txr->tq);
75 taskqueue_unblock(rxr->tq);
78 taskqueue_unblock(adapter->tq);
[all...]
H A Dif_lem_netmap.h57 taskqueue_block(adapter->tq);
58 taskqueue_drain(adapter->tq, &adapter->rxtx_task);
59 taskqueue_drain(adapter->tq, &adapter->link_task);
71 taskqueue_unblock(adapter->tq); // XXX do we need this ?
/freebsd-11-stable/sys/dev/mlx4/mlx4_en/
H A Dmlx4_en_cq.c73 cq->tq = taskqueue_create_fast("mlx4_en_que", M_NOWAIT,
74 taskqueue_thread_enqueue, &cq->tq);
77 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s rx cq",
82 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s tx cq",
187 taskqueue_drain(cq->tq, &cq->cq_task);
188 taskqueue_free(cq->tq);
203 taskqueue_drain(cq->tq, &cq->cq_task);
/freebsd-11-stable/contrib/nvi/ex/
H A Dex_tag.c152 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) {
192 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) {
322 if (TAILQ_EMPTY(exp->tq)) {
330 dtqp = TAILQ_FIRST(exp->tq);
342 TAILQ_FOREACH(tqp, exp->tq, q)
355 for (tqp = TAILQ_FIRST(exp->tq); tqp;
358 if (tqp == TAILQ_FIRST(exp->tq))
373 if (tqp == TAILQ_FIRST(exp->tq))
397 if (TAILQ_EMPTY(exp->tq)) {
403 return (tag_pop(sp, TAILQ_PREV(TAILQ_LAST(exp->tq, _tq
[all...]
/freebsd-11-stable/sbin/devfs/
H A Ddevfs.c175 STAILQ_ENTRY(ptrstq) tq;
206 STAILQ_INSERT_TAIL(&plist, pt, tq);
220 STAILQ_REMOVE_HEAD(&plist, tq);
/freebsd-11-stable/sys/dev/cfi/
H A Dcfi_disk.c63 struct taskqueue *tq; /* private task queue for i/o request */ member in struct:cfi_disk_softc
128 sc->tq = taskqueue_create("cfid_taskq", M_NOWAIT,
129 taskqueue_thread_enqueue, &sc->tq);
130 taskqueue_start_threads(&sc->tq, 1, PI_DISK, "cfid taskq");
144 taskqueue_free(sc->tq);
330 taskqueue_enqueue(sc->tq, &sc->iotask);
/freebsd-11-stable/usr.sbin/gstat/
H A Dgstat.c83 struct timespec tp, tq; local
208 geom_stats_snapshot_timestamp(sq, &tq);
214 dt = tp.tv_sec - tq.tv_sec;
215 dt += (tp.tv_nsec - tq.tv_nsec) * 1e-9;
216 tq = tp;
/freebsd-11-stable/sys/dev/nand/
H A Dnand_geom.c111 taskqueue_enqueue(chip->tq, &chip->iotask);
133 taskqueue_enqueue(chip->tq, &chip->iotask);
430 chip->tq = taskqueue_create("nand_taskq", M_WAITOK,
431 taskqueue_thread_enqueue, &chip->tq);
432 taskqueue_start_threads(&chip->tq, 1, PI_DISK, "nand taskq");
447 taskqueue_free(chip->tq);
/freebsd-11-stable/sys/dev/nvd/
H A Dnvd.c79 struct taskqueue *tq; member in struct:nvd_disk
238 taskqueue_enqueue(ndisk->tq, &ndisk->bioqtask);
272 taskqueue_free(ndisk->tq);
396 ndisk->tq = taskqueue_create("nvd_taskq", M_WAITOK,
397 taskqueue_thread_enqueue, &ndisk->tq);
398 taskqueue_start_threads(&ndisk->tq, 1, PI_DISK, "nvd taskq");
/freebsd-11-stable/sys/dev/bwn/
H A Dif_bwn.c902 struct bwn_pio_txqueue *tq; local
915 tq = bwn_pio_select(mac, M_WME_GETAC(m));
916 if (tq->tq_free == 0 || pktlen > tq->tq_size ||
917 pktlen > (tq->tq_size - tq->tq_used))
953 struct bwn_pio_txqueue *tq; local
966 tq = bwn_pio_select(mac, M_WME_GETAC(m));
967 KASSERT(!TAILQ_EMPTY(&tq->tq_pktlist), ("%s: fail", __func__));
968 tp = TAILQ_FIRST(&tq
2423 bwn_pio_set_txqueue(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, int index) argument
2496 bwn_destroy_pioqueue_tx(struct bwn_pio_txqueue *tq) argument
2511 bwn_pio_read_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t offset) argument
2575 bwn_pio_cancel_tx_packets(struct bwn_pio_txqueue *tq) argument
5968 struct bwn_pio_txqueue *tq; local
6565 bwn_pio_write_multi_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint32_t ctl, const void *_data, int len) argument
6602 bwn_pio_write_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t offset, uint32_t value) argument
6610 bwn_pio_write_multi_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t ctl, const void *_data, int len) argument
6631 bwn_pio_write_mbuf_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t ctl, struct mbuf *m0) argument
6723 struct bwn_pio_txqueue *tq = NULL; local
[all...]

Completed in 188 milliseconds

12345