Lines Matching defs: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;
403 	struct padata_mt_job_state *ps = pw->pw_data;
404 	struct padata_mt_job *job = ps->job;
407 	spin_lock(&ps->lock);
414 		size = roundup(start + 1, ps->chunk_size) - start;
421 		spin_unlock(&ps->lock);
423 		spin_lock(&ps->lock);
426 	++ps->nworks_fini;
427 	done = (ps->nworks_fini == ps->nworks);
428 	spin_unlock(&ps->lock);
431 		complete(&ps->completion);
445 	struct padata_mt_job_state ps;
463 	spin_lock_init(&ps.lock);
464 	init_completion(&ps.completion);
465 	ps.job	       = job;
466 	ps.nworks      = padata_work_alloc_mt(nworks, &ps, &works);
467 	ps.nworks_fini = 0;
477 	ps.chunk_size = job->size / (ps.nworks * load_balance_factor);
478 	ps.chunk_size = max(ps.chunk_size, job->min_chunk);
479 	ps.chunk_size = max(ps.chunk_size, 1ul);
480 	ps.chunk_size = roundup(ps.chunk_size, job->align);
495 	padata_work_init(&my_work, padata_mt_helper, &ps, PADATA_WORK_ONSTACK);
499 	wait_for_completion(&ps.completion);
538 static struct parallel_data *padata_alloc_pd(struct padata_shell *ps)
540 	struct padata_instance *pinst = ps->pinst;
555 	pd->ps = ps;
610 static int padata_replace_one(struct padata_shell *ps)
614 	pd_new = padata_alloc_pd(ps);
618 	ps->opd = rcu_dereference_protected(ps->pd, 1);
619 	rcu_assign_pointer(ps->pd, pd_new);
626 	struct padata_shell *ps;
631 	list_for_each_entry(ps, &pinst->pslist, list) {
632 		err = padata_replace_one(ps);
639 	list_for_each_entry_continue_reverse(ps, &pinst->pslist, list)
640 		padata_put_pd(ps->opd);
1038 	struct padata_shell *ps;
1040 	ps = kzalloc(sizeof(*ps), GFP_KERNEL);
1041 	if (!ps)
1044 	ps->pinst = pinst;
1047 	pd = padata_alloc_pd(ps);
1054 	RCU_INIT_POINTER(ps->pd, pd);
1055 	list_add(&ps->list, &pinst->pslist);
1058 	return ps;
1061 	kfree(ps);
1070  * @ps: padata shell to free
1072 void padata_free_shell(struct padata_shell *ps)
1076 	if (!ps)
1079 	mutex_lock(&ps->pinst->lock);
1080 	list_del(&ps->list);
1081 	pd = rcu_dereference_protected(ps->pd, 1);
1083 	mutex_unlock(&ps->pinst->lock);
1085 	kfree(ps);