/freebsd-11-stable/cddl/contrib/opensolaris/lib/libzpool/common/ |
H A D | taskq.c | 59 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 D | handler.h | 45 struct taskqueue *tq; member in struct:eventhandler
|
/freebsd-11-stable/sys/cddl/compat/opensolaris/kern/ |
H A D | opensolaris_taskq.c | 69 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 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 | 153 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 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 | 143 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 D | subr_taskqueue.c | 87 #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 D | subr_gtaskqueue.c | 86 #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 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-11-stable/sys/compat/linuxkpi/common/src/ |
H A D | linux_work.c | 117 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 D | if_medium.c | 45 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 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-11-stable/sys/dev/netmap/ |
H A D | if_em_netmap.h | 52 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 D | if_lem_netmap.h | 57 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 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-11-stable/contrib/nvi/ex/ |
H A D | ex_tag.c | 152 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 D | devfs.c | 175 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 D | cfi_disk.c | 63 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 D | gstat.c | 83 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 D | nand_geom.c | 111 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 D | nvd.c | 79 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 D | if_bwn.c | 902 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...] |