/freebsd-13-stable/sys/contrib/openzfs/lib/libzpool/ |
H A D | taskq.c | 42 task_alloc(taskq_t *tq, int tqflags) argument 47 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { 49 tq->tq_freelist = t->tqent_next; 51 if (tq->tq_nalloc >= tq->tq_maxalloc) { 65 tq->tq_maxalloc_wait++; 66 rv = cv_timedwait(&tq->tq_maxalloc_cv, 67 &tq 87 task_free(taskq_t *tq, taskq_ent_t *t) argument 104 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) argument 137 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags, clock_t expire_time) argument 160 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument 191 taskq_wait(taskq_t *tq) argument 200 taskq_wait_id(taskq_t *tq, taskqid_t id) argument 206 taskq_wait_outstanding(taskq_t *tq, taskqid_t id) argument 214 taskq_t *tq = arg; local 255 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); local 302 taskq_destroy(taskq_t *tq) argument 336 taskq_member(taskq_t *tq, kthread_t *t) argument 357 taskq_cancel_id(taskq_t *tq, taskqid_t id) argument [all...] |
/freebsd-13-stable/sys/contrib/openzfs/module/os/linux/spl/ |
H A D | spl-taskq.c | 94 taskq_t *tq; local 97 tq = list_entry(tql, taskq_t, tq_taskqs); 98 if (strcmp(name, tq->tq_name) == 0) 99 return (tq->tq_instance); 105 * NOTE: Must be called with tq->tq_lock held, returns a list_t which 109 task_alloc(taskq_t *tq, uint_t flags, unsigned long *irqflags) argument 114 ASSERT(tq); 117 if (!list_empty(&tq->tq_free_list) && !(flags & TQ_NEW)) { 118 t = list_entry(tq->tq_free_list.next, taskq_ent_t, tqent_list); 133 if (tq 175 task_free(taskq_t *tq, taskq_ent_t *t) argument 191 task_done(taskq_t *tq, taskq_ent_t *t) argument 221 taskq_t *tq = t->tqent_taskq; local 271 taskq_lowest_id(taskq_t *tq) argument 306 taskq_insert_in_order(taskq_t *tq, taskq_thread_t *tqt) argument 330 taskq_find_list(taskq_t *tq, struct list_head *lh, taskqid_t id) argument 355 taskq_find(taskq_t *tq, taskqid_t id) argument 416 taskq_wait_id_check(taskq_t *tq, taskqid_t id) argument 433 taskq_wait_id(taskq_t *tq, taskqid_t id) argument 440 taskq_wait_outstanding_check(taskq_t *tq, taskqid_t id) argument 460 taskq_wait_outstanding(taskq_t *tq, taskqid_t id) argument 468 taskq_wait_check(taskq_t *tq) argument 486 taskq_wait(taskq_t *tq) argument 493 taskq_member(taskq_t *tq, kthread_t *t) argument 513 taskq_cancel_id(taskq_t *tq, taskqid_t id) argument 566 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument 631 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t flags, clock_t expire_time) argument 677 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument 769 taskq_next_ent(taskq_t *tq) argument 789 taskq_t *tq = (taskq_t *)arg; local 809 taskq_thread_spawn(taskq_t *tq) argument 836 taskq_thread_should_stop(taskq_t *tq, taskq_thread_t *tqt) argument 859 taskq_t *tq; local 1002 taskq_thread_create(taskq_t *tq) argument 1037 taskq_t *tq; local 1143 taskq_destroy(taskq_t *tq) argument 1244 taskq_t *tq = NULL; local 1294 taskq_t *tq = list_entry(node, taskq_t, tq_hp_cb_node); local 1330 taskq_t *tq = list_entry(node, taskq_t, tq_hp_cb_node); local [all...] |
H A D | spl-proc.c | 191 taskq_t *tq = p; local 203 spin_lock_irqsave_nested(&tq->tq_lock, flags, tq->tq_lock_class); 204 spin_lock_irqsave(&tq->tq_wait_waitq.lock, wflags); 207 lheads[LHEAD_PEND] = &tq->tq_pend_list; 208 lheads[LHEAD_PRIO] = &tq->tq_prio_list; 209 lheads[LHEAD_DELAY] = &tq->tq_delay_list; 211 lheads[LHEAD_WAIT] = &tq->tq_wait_waitq.head; 213 lheads[LHEAD_WAIT] = &tq->tq_wait_waitq.task_list; 215 lheads[LHEAD_ACTIVE] = &tq 349 taskq_t *tq = p; local [all...] |
/freebsd-13-stable/sys/dev/wtap/wtap_hal/ |
H A D | handler.h | 47 struct taskqueue *tq; member in struct:eventhandler
|
/freebsd-13-stable/sys/cddl/compat/opensolaris/kern/ |
H A D | opensolaris_taskq.c | 71 taskq_t *tq; local 76 tq = kmem_alloc(sizeof(*tq), KM_SLEEP); 77 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, 78 &tq->tq_queue); 79 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri, 82 return ((taskq_t *)tq); 100 taskq_destroy(taskq_t *tq) argument 103 taskqueue_free(tq->tq_queue); 104 kmem_free(tq, sizeo 108 taskq_member(taskq_t *tq, kthread_t *thread) argument 125 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument 162 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags, taskq_ent_t *task) argument 181 taskq_wait(taskq_t *tq) argument 187 taskq_wait_id(taskq_t *tq, taskqid_t id) argument [all...] |
/freebsd-13-stable/usr.sbin/jail/ |
H A D | jailparse.y | 80 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 D | config.c | 155 TAILQ_FOREACH_SAFE(j, &cfjails, tq, tj) { 161 TAILQ_FOREACH(j, &cfjails, tq) { 164 TAILQ_CONCAT(&opp, &j->params, tq); 177 TAILQ_FOREACH(wj, &wild, tq) { 179 TAILQ_FOREACH(p, &opp, tq) 184 TAILQ_FOREACH(p, &wj->params, tq) 188 TAILQ_FOREACH(p, &opp, tq) 193 TAILQ_FOREACH(p, &j->params, tq) { 196 TAILQ_FOREACH(s, &p->val, tq) { 198 TAILQ_FOREACH(vp, &j->params, tq) [all...] |
H A D | state.c | 74 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 D | jailp.h | 145 STAILQ_ENTRY(cfvar) tq; member in struct:cfvar 153 TAILQ_ENTRY(cfstring) tq; member in struct:cfstring 162 TAILQ_ENTRY(cfparam) tq; member in struct:cfparam 173 TAILQ_ENTRY(cfjail) tq; member in struct:cfjail 194 STAILQ_ENTRY(cfdepend) tq[2]; member in struct:cfdepend
|
/freebsd-13-stable/sys/contrib/openzfs/module/os/freebsd/spl/ |
H A D | spl_taskq.c | 202 taskq_t *tq = context; local 208 tsd_set(taskq_tsd, tq); 215 taskq_t *tq; local 220 tq = kmem_alloc(sizeof (*tq), KM_SLEEP); 221 tq->tq_queue = taskqueue_create(name, M_WAITOK, 222 taskqueue_thread_enqueue, &tq->tq_queue); 223 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_INIT, 224 taskq_tsd_set, tq); 225 taskqueue_set_callback(tq 248 taskq_destroy(taskq_t *tq) argument 256 taskq_member(taskq_t *tq, kthread_t *thread) argument 277 taskq_cancel_id(taskq_t *tq, taskqid_t tid) argument 320 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t flags, clock_t expire_time) argument 355 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument 394 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint32_t flags, taskq_ent_t *task) argument 415 taskq_wait(taskq_t *tq) argument 421 taskq_wait_id(taskq_t *tq, taskqid_t tid) argument 435 taskq_wait_outstanding(taskq_t *tq, taskqid_t id __unused) argument [all...] |
/freebsd-13-stable/sys/dev/liquidio/base/ |
H A D | lio_response_manager.c | 61 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 D | lio_request_manager.c | 161 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-13-stable/sys/dev/wtap/ |
H A D | if_medium.c | 47 eh->tq = taskqueue_create("wtap_tx_taskq", M_NOWAIT | M_ZERO, 48 taskqueue_thread_enqueue, &eh->tq); 49 taskqueue_start_threads(&eh->tq, 1, PI_NET, "%s taskq", "wtap_medium"); 60 taskqueue_free(md->tx_handler->tq); 83 taskqueue_enqueue(md->tx_handler->tq, &md->tx_handler->proc);
|
/freebsd-13-stable/sys/kern/ |
H A D | subr_taskqueue.c | 90 #define TQ_LOCK(tq) \ 92 if ((tq)->tq_spin) \ 93 mtx_lock_spin(&(tq)->tq_mutex); \ 95 mtx_lock(&(tq)->tq_mutex); \ 97 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) 99 #define TQ_UNLOCK(tq) \ 101 if ((tq)->tq_spin) \ 102 mtx_unlock_spin(&(tq)->tq_mutex); \ 104 mtx_unlock(&(tq) 121 TQ_SLEEP(struct taskqueue *tq, void *p, const char *wm) argument 195 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) argument 669 struct taskqueue *tq; local 771 taskqueue_run_callback(struct taskqueue *tq, enum taskqueue_callback_type cb_type) argument 785 struct taskqueue **tqp, *tq; local 823 struct taskqueue **tqp, *tq; local [all...] |
H A D | subr_gtaskqueue.c | 90 #define TQ_LOCK(tq) \ 92 if ((tq)->tq_spin) \ 93 mtx_lock_spin(&(tq)->tq_mutex); \ 95 mtx_lock(&(tq)->tq_mutex); \ 97 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) 99 #define TQ_UNLOCK(tq) \ 101 if ((tq)->tq_spin) \ 102 mtx_unlock_spin(&(tq)->tq_mutex); \ 104 mtx_unlock(&(tq) 118 TQ_SLEEP(struct gtaskqueue *tq, void *p, const char *wm) argument 163 gtaskqueue_terminate(struct thread **pp, struct gtaskqueue *tq) argument 454 struct gtaskqueue *tq; local 525 gtaskqueue_run_callback(struct gtaskqueue *tq, enum taskqueue_callback_type cb_type) argument 539 struct gtaskqueue **tqp, *tq; local 577 struct gtaskqueue **tqp, *tq; local [all...] |
/freebsd-13-stable/sys/compat/linuxkpi/common/src/ |
H A D | linux_work.c | 121 struct taskqueue *tq; local 123 tq = dwork->work.work_queue->taskqueue; 124 taskqueue_enqueue(tq, &dwork->work.work_task); 376 struct taskqueue *tq; local 387 tq = work->work_queue->taskqueue; 388 if (taskqueue_cancel(tq, &work->work_task, NULL) != 0) 389 taskqueue_drain(tq, &work->work_task); 392 tq = work->work_queue->taskqueue; 393 if (taskqueue_cancel(tq, &work->work_task, NULL) != 0) 394 taskqueue_drain(tq, 437 struct taskqueue *tq; local 476 struct taskqueue *tq; local 520 struct taskqueue *tq; local 545 struct taskqueue *tq; local 589 struct taskqueue *tq; local [all...] |
/freebsd-13-stable/sys/dev/ixl/ |
H A D | ixl_iw_int.h | 63 struct taskqueue *tq; member in struct:ixl_iw_state
|
H A D | ixl_iw.c | 179 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-13-stable/sys/dev/mlx4/mlx4_en/ |
H A D | mlx4_en_cq.c | 73 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-13-stable/contrib/nvi/ex/ |
H A D | ex_tag.c | 147 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) { 187 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) { 317 if (TAILQ_EMPTY(exp->tq)) { 325 dtqp = TAILQ_FIRST(exp->tq); 337 TAILQ_FOREACH(tqp, exp->tq, q) 350 for (tqp = TAILQ_FIRST(exp->tq); tqp; 353 if (tqp == TAILQ_FIRST(exp->tq)) 368 if (tqp == TAILQ_FIRST(exp->tq)) 392 if (TAILQ_EMPTY(exp->tq)) { 398 return (tag_pop(sp, TAILQ_PREV(TAILQ_LAST(exp->tq, _tq [all...] |
/freebsd-13-stable/sbin/devfs/ |
H A D | devfs.c | 175 STAILQ_ENTRY(ptrstq) tq; 206 STAILQ_INSERT_TAIL(&plist, pt, tq); 220 STAILQ_REMOVE_HEAD(&plist, tq);
|
/freebsd-13-stable/sys/dev/cfi/ |
H A D | cfi_disk.c | 65 struct taskqueue *tq; /* private task queue for i/o request */ member in struct:cfi_disk_softc 130 sc->tq = taskqueue_create("cfid_taskq", M_NOWAIT, 131 taskqueue_thread_enqueue, &sc->tq); 132 taskqueue_start_threads(&sc->tq, 1, PI_DISK, "cfid taskq"); 146 taskqueue_free(sc->tq); 333 taskqueue_enqueue(sc->tq, &sc->iotask);
|
/freebsd-13-stable/usr.sbin/gstat/ |
H A D | gstat.c | 86 struct timespec tp, tq; local 219 geom_stats_snapshot_timestamp(sq, &tq); 225 dt = tp.tv_sec - tq.tv_sec; 226 dt += (tp.tv_nsec - tq.tv_nsec) * 1e-9; 227 tq = tp; 230 "%F %T",localtime(&tq.tv_sec)); 232 "%s.%.9ld",ts,tq.tv_nsec);
|
/freebsd-13-stable/crypto/openssh/ |
H A D | ssh-keyscan.c | 114 TAILQ_HEAD(conlist, Connection) tq; /* Timeout Queue */ 395 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); 418 TAILQ_REMOVE(&tq, &fdcon[s], c_link); 426 TAILQ_REMOVE(&tq, &fdcon[s], c_link); 429 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); 563 c = TAILQ_FIRST(&tq); 596 c = TAILQ_FIRST(&tq); 659 TAILQ_INIT(&tq);
|
/freebsd-13-stable/sys/dev/bwn/ |
H A D | if_bwn.c | 1034 struct bwn_pio_txqueue *tq; local 1047 tq = bwn_pio_select(mac, M_WME_GETAC(m)); 1048 if (tq->tq_free == 0 || pktlen > tq->tq_size || 1049 pktlen > (tq->tq_size - tq->tq_used)) 1085 struct bwn_pio_txqueue *tq; local 1098 tq = bwn_pio_select(mac, M_WME_GETAC(m)); 1099 KASSERT(!TAILQ_EMPTY(&tq->tq_pktlist), ("%s: fail", __func__)); 1100 tp = TAILQ_FIRST(&tq 2641 bwn_pio_set_txqueue(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, int index) argument 2714 bwn_destroy_pioqueue_tx(struct bwn_pio_txqueue *tq) argument 2729 bwn_pio_read_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t offset) argument 2759 bwn_pio_cancel_tx_packets(struct bwn_pio_txqueue *tq) argument 6201 struct bwn_pio_txqueue *tq; local 6752 bwn_pio_write_multi_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint32_t ctl, const void *_data, int len) argument 6789 bwn_pio_write_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t offset, uint32_t value) argument 6797 bwn_pio_write_multi_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t ctl, const void *_data, int len) argument 6818 bwn_pio_write_mbuf_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t ctl, struct mbuf *m0) argument 6910 struct bwn_pio_txqueue *tq = NULL; local [all...] |