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);
538 static struct parallel_data *padata_alloc_pd(struct padata_shell *ps,
541 struct padata_instance *pinst = ps->pinst;
556 pd->ps = ps;
615 static int padata_replace_one(struct padata_shell *ps, int offlining_cpu)
619 pd_new = padata_alloc_pd(ps, offlining_cpu);
623 ps->opd = rcu_dereference_protected(ps->pd, 1);
624 rcu_assign_pointer(ps->pd, pd_new);
631 struct padata_shell *ps;
636 list_for_each_entry(ps, &pinst->pslist, list) {
637 err = padata_replace_one(ps, offlining_cpu);
644 list_for_each_entry_continue_reverse(ps, &pinst->pslist, list)
645 padata_put_pd(ps->opd);
1038 struct padata_shell *ps;
1040 ps = kzalloc_obj(*ps);
1041 if (!ps)
1044 ps->pinst = pinst;
1047 pd = padata_alloc_pd(ps, -1);
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);