Lines Matching refs:pqueue

64 	struct padata_parallel_queue *pqueue;  in padata_parallel_worker()  local
70 pqueue = container_of(parallel_work, in padata_parallel_worker()
72 pd = pqueue->pd; in padata_parallel_worker()
75 spin_lock(&pqueue->parallel.lock); in padata_parallel_worker()
76 list_replace_init(&pqueue->parallel.list, &local_list); in padata_parallel_worker()
77 spin_unlock(&pqueue->parallel.lock); in padata_parallel_worker()
141 queue = per_cpu_ptr(pd->pqueue, target_cpu); in padata_do_parallel()
190 next_queue = per_cpu_ptr(pd->pqueue, cpu); in padata_get_next()
196 next_queue = per_cpu_ptr(pd->pqueue, cpu); in padata_get_next()
220 queue = per_cpu_ptr(pd->pqueue, smp_processor_id()); in padata_get_next()
344 struct padata_parallel_queue *pqueue; in padata_do_serial() local
350 pqueue = per_cpu_ptr(pd->pqueue, cpu); in padata_do_serial()
352 spin_lock(&pqueue->reorder.lock); in padata_do_serial()
354 list_add_tail(&padata->list, &pqueue->reorder.list); in padata_do_serial()
355 spin_unlock(&pqueue->reorder.lock); in padata_do_serial()
404 struct padata_parallel_queue *pqueue; in padata_init_pqueues() local
408 pqueue = per_cpu_ptr(pd->pqueue, cpu); in padata_init_pqueues()
409 pqueue->pd = pd; in padata_init_pqueues()
410 pqueue->cpu_index = cpu_index; in padata_init_pqueues()
413 __padata_list_init(&pqueue->reorder); in padata_init_pqueues()
414 __padata_list_init(&pqueue->parallel); in padata_init_pqueues()
415 INIT_WORK(&pqueue->work, padata_parallel_worker); in padata_init_pqueues()
416 atomic_set(&pqueue->num_obj, 0); in padata_init_pqueues()
434 pd->pqueue = alloc_percpu(struct padata_parallel_queue); in padata_alloc_pd()
435 if (!pd->pqueue) in padata_alloc_pd()
458 free_percpu(pd->pqueue); in padata_alloc_pd()
469 free_percpu(pd->pqueue); in padata_free_pd()
478 struct padata_parallel_queue *pqueue; in padata_flush_queues() local
482 pqueue = per_cpu_ptr(pd->pqueue, cpu); in padata_flush_queues()
483 flush_work(&pqueue->work); in padata_flush_queues()