Lines Matching refs:pqueue
62 struct padata_parallel_queue *pqueue; in padata_parallel_worker() local
66 pqueue = container_of(parallel_work, in padata_parallel_worker()
69 spin_lock(&pqueue->parallel.lock); in padata_parallel_worker()
70 list_replace_init(&pqueue->parallel.list, &local_list); in padata_parallel_worker()
71 spin_unlock(&pqueue->parallel.lock); in padata_parallel_worker()
145 queue = per_cpu_ptr(pd->pqueue, target_cpu); in padata_do_parallel()
180 next_queue = per_cpu_ptr(pd->pqueue, cpu); in padata_find_next()
265 next_queue = per_cpu_ptr(pd->pqueue, pd->cpu); in padata_reorder()
320 struct padata_parallel_queue *pqueue = per_cpu_ptr(pd->pqueue, in padata_do_serial() local
324 spin_lock(&pqueue->reorder.lock); in padata_do_serial()
326 list_for_each_entry_reverse(cur, &pqueue->reorder.list, list) in padata_do_serial()
331 spin_unlock(&pqueue->reorder.lock); in padata_do_serial()
404 struct padata_parallel_queue *pqueue; in padata_init_pqueues() local
407 pqueue = per_cpu_ptr(pd->pqueue, cpu); in padata_init_pqueues()
409 __padata_list_init(&pqueue->reorder); in padata_init_pqueues()
410 __padata_list_init(&pqueue->parallel); in padata_init_pqueues()
411 INIT_WORK(&pqueue->work, padata_parallel_worker); in padata_init_pqueues()
412 atomic_set(&pqueue->num_obj, 0); in padata_init_pqueues()
427 pd->pqueue = alloc_percpu(struct padata_parallel_queue); in padata_alloc_pd()
428 if (!pd->pqueue) in padata_alloc_pd()
453 free_percpu(pd->pqueue); in padata_alloc_pd()
464 free_percpu(pd->pqueue); in padata_free_pd()
473 struct padata_parallel_queue *pqueue; in padata_flush_queues() local
477 pqueue = per_cpu_ptr(pd->pqueue, cpu); in padata_flush_queues()
478 flush_work(&pqueue->work); in padata_flush_queues()