/freebsd-9.3-release/cddl/contrib/opensolaris/lib/libzpool/common/ |
H A D | taskq.c | 55 task_alloc(taskq_t *tq, int tqflags) argument 60 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { 61 tq->tq_freelist = t->tqent_next; 63 if (tq->tq_nalloc >= tq->tq_maxalloc) { 77 tq->tq_maxalloc_wait++; 78 rv = cv_timedwait(&tq->tq_maxalloc_cv, 79 &tq 96 task_free(taskq_t *tq, taskq_ent_t *t) argument 113 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) argument 145 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument 177 taskq_wait(taskq_t *tq) argument 188 taskq_t *tq = arg; local 227 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); local 272 taskq_destroy(taskq_t *tq) argument 310 taskq_member(taskq_t *tq, void *t) argument [all...] |
/freebsd-9.3-release/sys/cddl/compat/opensolaris/kern/ |
H A D | opensolaris_taskq.c | 68 taskq_t *tq; local 73 tq = kmem_alloc(sizeof(*tq), KM_SLEEP); 74 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, 75 &tq->tq_queue); 76 (void) taskqueue_start_threads(&tq->tq_queue, nthreads, pri, "%s", name); 78 return ((taskq_t *)tq); 90 taskq_destroy(taskq_t *tq) argument 93 taskqueue_free(tq->tq_queue); 94 kmem_free(tq, sizeo 98 taskq_member(taskq_t *tq, kthread_t *thread) argument 115 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument 152 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags, taskq_ent_t *task) argument 171 taskq_wait(taskq_t *tq) argument [all...] |
/freebsd-9.3-release/usr.sbin/jail/ |
H A D | jailparse.y | 78 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); [all...] |
H A D | config.c | 148 TAILQ_FOREACH_SAFE(j, &cfjails, tq, tj) { 154 TAILQ_FOREACH(j, &cfjails, tq) { 157 TAILQ_CONCAT(&opp, &j->params, tq); 170 TAILQ_FOREACH(wj, &wild, tq) { 172 TAILQ_FOREACH(p, &opp, tq) 177 TAILQ_FOREACH(p, &wj->params, tq) 181 TAILQ_FOREACH(p, &opp, tq) 186 TAILQ_FOREACH(p, &j->params, tq) { 189 TAILQ_FOREACH(s, &p->val, tq) { 192 TAILQ_FOREACH(vp, &j->params, tq) [all...] |
H A D | state.c | 72 TAILQ_FOREACH(s, &p->val, tq) { 84 TAILQ_FOREACH(j, &cfjails, tq) 88 TAILQ_FOREACH(j, &cfjails, tq) 96 TAILQ_FOREACH(j, &cfjails, tq) { 100 TAILQ_FOREACH(s, &p->val, tq) { 144 TAILQ_FOREACH(j, &cfjails, tq) 145 STAILQ_FOREACH(d, &j->dep[DEP_FROM], tq[DEP_FROM]) 174 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfrom]) { 246 STAILQ_FOREACH(d, &j->dep[depto], tq[depto]) { 275 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfro [all...] |
H A D | jailp.h | 136 STAILQ_ENTRY(cfvar) tq; member in struct:cfvar 144 TAILQ_ENTRY(cfstring) tq; member in struct:cfstring 153 TAILQ_ENTRY(cfparam) tq; member in struct:cfparam 164 TAILQ_ENTRY(cfjail) tq; member in struct:cfjail 185 STAILQ_ENTRY(cfdepend) tq[2]; member in struct:cfdepend
|
H A D | command.c | 127 ? TAILQ_PREV(j->comstring, cfstrings, tq) 128 : TAILQ_NEXT(j->comstring, tq); 459 TAILQ_FOREACH(s, &j->intparams[IP_COMMAND]->val, tq) 463 TAILQ_FOREACH(s, &j->intparams[IP_COMMAND]->val, tq) 652 TAILQ_REMOVE(j->queue, j, tq); 653 TAILQ_FOREACH(tj, &sleeping, tq) { 658 TAILQ_INSERT_BEFORE(tj, j, tq); 663 TAILQ_INSERT_TAIL(&sleeping, j, tq);
|
/freebsd-9.3-release/sys/kern/ |
H A D | subr_taskqueue.c | 74 #define TQ_LOCK(tq) \ 76 if ((tq)->tq_spin) \ 77 mtx_lock_spin(&(tq)->tq_mutex); \ 79 mtx_lock(&(tq)->tq_mutex); \ 82 #define TQ_UNLOCK(tq) \ 84 if ((tq)->tq_spin) \ 85 mtx_unlock_spin(&(tq)->tq_mutex); \ 87 mtx_unlock(&(tq)->tq_mutex); \ 102 TQ_SLEEP(struct taskqueue *tq, void *p, struct mtx *m, int pri, const char *wm, argument 105 if (tq 144 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) argument 471 struct taskqueue *tq; local 523 struct taskqueue **tqp, *tq; local 551 struct taskqueue **tqp, *tq; local [all...] |
/freebsd-9.3-release/sys/ofed/drivers/net/mlx4/ |
H A D | en_cq.c | 54 cq->tq = taskqueue_create_fast("mlx4_en_que", M_NOWAIT, 55 taskqueue_thread_enqueue, &cq->tq); 61 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s rx cq", 67 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s tx cq", 125 taskqueue_drain(cq->tq, &cq->cq_task); 126 taskqueue_free(cq->tq); 138 taskqueue_drain(cq->tq, &cq->cq_task);
|
/freebsd-9.3-release/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 | 60 taskqueue_block(adapter->tq); 61 taskqueue_drain(adapter->tq, &adapter->rxtx_task); 62 taskqueue_drain(adapter->tq, &adapter->link_task); 74 taskqueue_unblock(adapter->tq); // XXX do we need this ?
|
/freebsd-9.3-release/contrib/nvi/ex/ |
H A D | ex_tag.c | 179 if (exp->tq.cqh_first == (void *)&exp->tq) { 219 if (exp->tq.cqh_first == (void *)&exp->tq) { 220 CIRCLEQ_INSERT_HEAD(&exp->tq, rtqp, q); 222 rtqp = exp->tq.cqh_first; 225 CIRCLEQ_INSERT_HEAD(&exp->tq, tqp, q); 276 if ((tqp = exp->tq.cqh_first) == (void *)&exp->tq) { 311 if ((tqp = exp->tq [all...] |
H A D | ex_cscope.c | 463 if (exp->tq.cqh_first == (void *)&exp->tq) { 536 if (exp->tq.cqh_first == (void *)&exp->tq) { 537 CIRCLEQ_INSERT_HEAD(&exp->tq, rtqp, q); 539 rtqp = exp->tq.cqh_first; 542 CIRCLEQ_INSERT_HEAD(&exp->tq, tqp, q);
|
/freebsd-9.3-release/sbin/devfs/ |
H A D | devfs.c | 173 STAILQ_ENTRY(ptrstq) tq; 204 STAILQ_INSERT_TAIL(&plist, pt, tq); 218 STAILQ_REMOVE_HEAD(&plist, tq);
|
/freebsd-9.3-release/sys/ofed/include/linux/ |
H A D | workqueue.h | 159 flush_taskqueue(struct taskqueue *tq) argument 165 taskqueue_enqueue(tq, &flushtask); 166 taskqueue_drain(tq, &flushtask);
|
/freebsd-9.3-release/sys/dev/cfi/ |
H A D | cfi_disk.c | 56 struct taskqueue *tq; /* private task queue for i/o request */ member in struct:cfi_disk_softc 119 sc->tq = taskqueue_create("cfid_taskq", M_NOWAIT, 120 taskqueue_thread_enqueue, &sc->tq); 121 taskqueue_start_threads(&sc->tq, 1, PI_DISK, "cfid taskq"); 135 taskqueue_free(sc->tq); 297 taskqueue_enqueue(sc->tq, &sc->iotask);
|
/freebsd-9.3-release/sys/dev/nvd/ |
H A D | nvd.c | 70 struct taskqueue *tq; member in struct:nvd_disk 161 taskqueue_enqueue(ndisk->tq, &ndisk->bioqtask); 323 ndisk->tq = taskqueue_create("nvd_taskq", M_WAITOK, 324 taskqueue_thread_enqueue, &ndisk->tq); 325 taskqueue_start_threads(&ndisk->tq, 1, PI_DISK, "nvd taskq"); 351 taskqueue_free(ndisk->tq);
|
/freebsd-9.3-release/usr.sbin/gstat/ |
H A D | gstat.c | 81 struct timespec tp, tq; local 193 geom_stats_snapshot_timestamp(sq, &tq); 199 dt = tp.tv_sec - tq.tv_sec; 200 dt += (tp.tv_nsec - tq.tv_nsec) * 1e-9; 201 tq = tp;
|
/freebsd-9.3-release/crypto/openssh/ |
H A D | ssh-keyscan.c | 106 TAILQ_HEAD(conlist, Connection) tq; /* Timeout Queue */ 358 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); 376 TAILQ_REMOVE(&tq, &fdcon[s], c_link); 384 TAILQ_REMOVE(&tq, &fdcon[s], c_link); 387 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); 530 c = TAILQ_FIRST(&tq); 563 c = TAILQ_FIRST(&tq); 628 TAILQ_INIT(&tq);
|
/freebsd-9.3-release/sys/dev/e1000/ |
H A D | if_em.h | 289 struct taskqueue *tq; member in struct:tx_ring 323 struct taskqueue *tq; member in struct:rx_ring 380 struct taskqueue *tq; /* private task queue */ member in struct:adapter
|
/freebsd-9.3-release/contrib/lukemftpd/src/ |
H A D | cmds.c | 858 char tq[MAXPATHLEN + 1] = ""; local 893 sz2 = readlink(tp, tq, MAXPATHLEN); 910 tq[sz2] = 0; 911 sz2 = strlen(tq); 912 if (tq[sz2 - 1] == '/') 913 tq[--sz2] = 0; 918 if (tq[0] == '/') { 923 memcpy(tp, tq, sz2); 932 (void)memcpy(cq + 1, tq, sz2);
|
/freebsd-9.3-release/sys/dev/ae/ |
H A D | if_aevar.h | 123 struct taskqueue *tq; member in struct:ae_softc
|
/freebsd-9.3-release/sys/dev/ixgbe/ |
H A D | ixgbe.c | 675 if (que->tq) { 677 taskqueue_drain(que->tq, &txr->txq_task); 679 taskqueue_drain(que->tq, &que->que_task); 680 taskqueue_free(que->tq); 685 if (adapter->tq) { 686 taskqueue_drain(adapter->tq, &adapter->link_task); 687 taskqueue_drain(adapter->tq, &adapter->mod_task); 688 taskqueue_drain(adapter->tq, &adapter->msf_task); 690 taskqueue_drain(adapter->tq, &adapter->fdir_task); 692 taskqueue_free(adapter->tq); [all...] |
/freebsd-9.3-release/sys/dev/hatm/ |
H A D | if_hatm.c | 1207 hatm_init_tbrq(struct hatm_softc *sc, struct hetbrq *tq, u_int group) argument 1209 if (tq->size == 0) { 1214 tq->tbrq = tq->mem.base; 1215 tq->head = 0; 1217 DBG(sc, ATTACH, ("TBRQ%u=0x%lx", group, (u_long)tq->mem.paddr)); 1219 WRITE4(sc, HE_REGO_TBRQ_B_T(group), tq->mem.paddr); 1221 WRITE4(sc, HE_REGO_TBRQ_S(group), tq->size - 1); 1222 WRITE4(sc, HE_REGO_TBRQ_THRESH(group), tq->thresh); 1231 struct hetpdrq *tq; local [all...] |
/freebsd-9.3-release/sys/dev/hpt27xx/ |
H A D | ldm.h | 134 #define TQ_EMPTY(tq) ((tq)->head==0) 497 void ldm_queue_task(struct task_queue *tq, struct tq_item *t);
|