Lines Matching refs:worker
108 struct kthread_worker *worker; in qib_cq_enter() local
114 worker = cq->dd->worker; in qib_cq_enter()
115 if (likely(worker)) { in qib_cq_enter()
118 queue_kthread_work(worker, &cq->comptask); in qib_cq_enter()
502 if (dd->worker) in qib_cq_init()
504 dd->worker = kzalloc(sizeof(*dd->worker), GFP_KERNEL); in qib_cq_init()
505 if (!dd->worker) in qib_cq_init()
507 init_kthread_worker(dd->worker); in qib_cq_init()
510 dd->worker, in qib_cq_init()
522 kfree(dd->worker); in qib_cq_init()
523 dd->worker = NULL; in qib_cq_init()
529 struct kthread_worker *worker; in qib_cq_exit() local
531 worker = dd->worker; in qib_cq_exit()
532 if (!worker) in qib_cq_exit()
535 dd->worker = NULL; in qib_cq_exit()
537 flush_kthread_worker(worker); in qib_cq_exit()
538 kthread_stop(worker->task); in qib_cq_exit()
539 kfree(worker); in qib_cq_exit()