taskqueue
struct taskqueue *taskqueue;
void *taskqueue;
gDpc->queue_dpc(sc->fc.taskqueue, fwohci_task_busreset, sc);
gDpc->queue_dpc(sc->fc.taskqueue, fwohci_task_sid, sc);
gDpc->queue_dpc(sc->fc.taskqueue, fwohci_task_dma, sc);
gDpc->new_dpc_queue(&sc->fc.taskqueue, "fw_taskq", FW_TASKQ_PRI);
if (sc->fc.taskqueue != NULL) {
gDpc->delete_dpc_queue(sc->fc.taskqueue);
sc->fc.taskqueue = NULL;
struct taskqueue *alc_tq;
struct taskqueue *ale_tq;
struct taskqueue *age_tq;
struct taskqueue *tq;
struct taskqueue *bge_tq;
struct taskqueue *jme_tq;
struct taskqueue *nfe_tq;
struct taskqueue;
struct taskqueue;
struct taskqueue *sc_tq; /* private task queue */
struct taskqueue *sc_tq;
struct taskqueue *sc_tq;
struct taskqueue *malo_tq; /* private task queue */
struct taskqueue *sc_tq; /* private task queue */
struct taskqueue *ifc_tq;
void _timeout_task_init(struct taskqueue *queue,
extern struct taskqueue *taskqueue_##name
struct taskqueue *taskqueue_##name; \
struct taskqueue *taskqueue_##name; \
struct taskqueue *taskqueue_create_fast(const char *name, int mflags,
struct taskqueue;
struct taskqueue *q;
struct taskqueue *taskqueue_create(const char *name, int mflags,
int taskqueue_start_threads(struct taskqueue **tqp, int count, int pri,
int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
int taskqueue_enqueue_timeout(struct taskqueue *queue,
int taskqueue_cancel(struct taskqueue *queue, struct task *task,
int taskqueue_cancel_timeout(struct taskqueue *queue,
void taskqueue_drain(struct taskqueue *queue, struct task *task);
void taskqueue_drain_timeout(struct taskqueue *queue,
void taskqueue_drain_all(struct taskqueue *queue);
void taskqueue_free(struct taskqueue *queue);
void taskqueue_run(struct taskqueue *queue);
void taskqueue_block(struct taskqueue *queue);
void taskqueue_unblock(struct taskqueue *queue);
int taskqueue_member(struct taskqueue *queue, struct thread *td);
void taskqueue_set_callback(struct taskqueue *queue,
_timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task,
static struct taskqueue *
struct taskqueue *queue;
queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO);
struct taskqueue *
taskqueue_set_callback(struct taskqueue *queue,
taskqueue_free(struct taskqueue *queue)
taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task)
taskqueue_enqueue(struct taskqueue *queue, struct task *task)
struct taskqueue *queue;
taskqueue_enqueue_timeout(struct taskqueue *queue,
taskqueue_block(struct taskqueue *queue)
taskqueue_unblock(struct taskqueue *queue)
taskqueue_run_locked(struct taskqueue *queue)
taskqueue_run(struct taskqueue *queue)
task_is_running(struct taskqueue *queue, struct task *task)
taskqueue_cancel_locked(struct taskqueue *queue, struct task *task,
taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp)
taskqueue_cancel_timeout(struct taskqueue *queue,
taskqueue_drain_timeout(struct taskqueue *queue,
taskqueue_start_threads(struct taskqueue **tqp, int count, int pri,
taskqueue_run_callback(struct taskqueue *tq,
taskqueue_member(struct taskqueue *queue, struct thread *td)
struct taskqueue *
taskqueue_terminate(struct thread **pp, struct taskqueue *tq)
taskqueue_drain(struct taskqueue *taskQueue, struct task *task)
taskqueue_drain_all(struct taskqueue *taskQueue)
static int _taskqueue_start_threads(struct taskqueue **taskQueue,
struct taskqueue **tqp = context;
static void taskqueue_terminate(struct thread **pp, struct taskqueue *tq);
struct taskqueue *taskqueue_fast = NULL;
struct taskqueue *taskqueue_swi = NULL;
struct taskqueue *taskqueue_thread = NULL;
struct taskqueue *tq = data;
_taskqueue_start_threads(struct taskqueue **taskQueue, int count, int priority,
struct taskqueue *tq = (*taskQueue);
struct taskqueue* sUSBTaskqueue = NULL;
struct taskqueue *ic_tq; /* deferred state thread */
struct taskqueue* tq;
struct taskqueue* tq = (tasq == systq) ? taskqueue_fast : tasq->tq;
struct taskqueue* tq = (tasq == systq) ? taskqueue_fast : tasq->tq;