Lines Matching full:ps

167  * @ps: padatashell
180 int padata_do_parallel(struct padata_shell *ps,
183 	struct padata_instance *pinst = ps->pinst;
190 	pd = rcu_dereference_bh(ps->pd);
283 	struct padata_instance *pinst = pd->ps->pinst;
407 	struct padata_mt_job_state *ps = pw->pw_data;
408 	struct padata_mt_job *job = ps->job;
411 	spin_lock(&ps->lock);
418 		size = roundup(start + 1, ps->chunk_size) - start;
425 		spin_unlock(&ps->lock);
427 		spin_lock(&ps->lock);
430 	++ps->nworks_fini;
431 	done = (ps->nworks_fini == ps->nworks);
432 	spin_unlock(&ps->lock);
435 		complete(&ps->completion);
449 	struct padata_mt_job_state ps;
467 	spin_lock_init(&ps.lock);
468 	init_completion(&ps.completion);
469 	ps.job	       = job;
470 	ps.nworks      = padata_work_alloc_mt(nworks, &ps, &works);
471 	ps.nworks_fini = 0;
481 	ps.chunk_size = job->size / (ps.nworks * load_balance_factor);
482 	ps.chunk_size = max(ps.chunk_size, job->min_chunk);
483 	ps.chunk_size = max(ps.chunk_size, 1ul);
484 	ps.chunk_size = roundup(ps.chunk_size, job->align);
499 	padata_work_init(&my_work, padata_mt_helper, &ps, PADATA_WORK_ONSTACK);
503 	wait_for_completion(&ps.completion);
542 static struct parallel_data *padata_alloc_pd(struct padata_shell *ps)
544 	struct padata_instance *pinst = ps->pinst;
559 	pd->ps = ps;
614 static int padata_replace_one(struct padata_shell *ps)
618 	pd_new = padata_alloc_pd(ps);
622 	ps->opd = rcu_dereference_protected(ps->pd, 1);
623 	rcu_assign_pointer(ps->pd, pd_new);
630 	struct padata_shell *ps;
635 	list_for_each_entry(ps, &pinst->pslist, list) {
636 		err = padata_replace_one(ps);
643 	list_for_each_entry_continue_reverse(ps, &pinst->pslist, list)
644 		padata_put_pd(ps->opd);
1043 	struct padata_shell *ps;
1045 	ps = kzalloc(sizeof(*ps), GFP_KERNEL);
1046 	if (!ps)
1049 	ps->pinst = pinst;
1052 	pd = padata_alloc_pd(ps);
1059 	RCU_INIT_POINTER(ps->pd, pd);
1060 	list_add(&ps->list, &pinst->pslist);
1063 	return ps;
1066 	kfree(ps);
1075  * @ps: padata shell to free
1077 void padata_free_shell(struct padata_shell *ps)
1081 	if (!ps)
1084 	mutex_lock(&ps->pinst->lock);
1085 	list_del(&ps->list);
1086 	pd = rcu_dereference_protected(ps->pd, 1);
1088 	mutex_unlock(&ps->pinst->lock);
1090 	kfree(ps);