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

1234

/freebsd-9.3-release/cddl/contrib/opensolaris/lib/libzpool/common/
H A Dtaskq.c55 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 Dopensolaris_taskq.c68 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 Djailparse.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);
[all...]
H A Dconfig.c148 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 Dstate.c72 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 Djailp.h136 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 Dcommand.c127 ? 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 Dsubr_taskqueue.c74 #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 Den_cq.c54 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 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.h60 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 Dex_tag.c179 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 Dex_cscope.c463 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 Ddevfs.c173 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 Dworkqueue.h159 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 Dcfi_disk.c56 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 Dnvd.c70 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 Dgstat.c81 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 Dssh-keyscan.c106 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 Dif_em.h289 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 Dcmds.c858 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 Dif_aevar.h123 struct taskqueue *tq; member in struct:ae_softc
/freebsd-9.3-release/sys/dev/ixgbe/
H A Dixgbe.c675 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 Dif_hatm.c1207 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 Dldm.h134 #define TQ_EMPTY(tq) ((tq)->head==0)
497 void ldm_queue_task(struct task_queue *tq, struct tq_item *t);

Completed in 191 milliseconds

1234