Home
last modified time | relevance | path

Searched refs:task_cnts (Results 1 – 10 of 10) sorted by relevance

/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/mpi/pmix/
H A Dpmixp_nspaces.c46 xfree(nsptr->task_cnts); in _xfree_nspace()
55 uint32_t nnodes, ntasks, *task_cnts; in pmixp_nspaces_init() local
67 task_cnts = pmixp_info_tasks_cnts(); in pmixp_nspaces_init()
71 rc = pmixp_nspaces_add(mynspace, nnodes, nodeid, ntasks, task_cnts, in pmixp_nspaces_init()
84 uint32_t ntasks, uint32_t *task_cnts, in pmixp_nspaces_add() argument
100 nsptr->task_cnts = xmalloc(sizeof(uint32_t) * nnodes); in pmixp_nspaces_add()
103 nsptr->task_cnts[i] = task_cnts[i]; in pmixp_nspaces_add()
109 xfree(nsptr->task_cnts); in pmixp_nspaces_add()
H A Dpmixp_info.c143 _pmixp_job_info.task_cnts = xmalloc(msize); in pmixp_info_set()
145 _pmixp_job_info.task_cnts[i] = in pmixp_info_set()
162 _pmixp_job_info.task_cnts = xmalloc(msize); in pmixp_info_set()
164 _pmixp_job_info.task_cnts[i] = job->task_cnts[i]; in pmixp_info_set()
182 info("TASK_CNT[%d]:%u", i,_pmixp_job_info.task_cnts[i]); in pmixp_info_set()
204 if (_pmixp_job_info.task_cnts) { in pmixp_info_free()
205 xfree(_pmixp_job_info.task_cnts); in pmixp_info_free()
H A Dpmixp_nspaces.h60 uint32_t *task_cnts; /* Number of tasks on each node of namespace */ member
80 uint32_t ntasks, uint32_t *task_cnts,
H A Dpmixp_info.h60 uint32_t *task_cnts; /* Number of tasks on each node in this step */ member
201 return _pmixp_job_info.task_cnts[nodeid]; in pmixp_info_tasks_node()
207 return _pmixp_job_info.task_cnts; in pmixp_info_tasks_cnts()
H A Dpmixp_client.c396 node_offs[i] = node_offs[i - 1] + nsptr->task_cnts[i - 1];
399 nsptr->task_cnts[nsptr->nnodes - 1]));
406 xassert(nsptr->task_cnts[node] >= node_tasks[node]);
446 for (j = 0; j < nsptr->task_cnts[i]; j++){
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/mpi/cray_shasta/
H A Dapinfo.c257 static pals_pe_t *_setup_pals_pes(int ntasks, int nnodes, uint16_t *task_cnts, in _setup_pals_pes() argument
265 for (localidx = 0; localidx < task_cnts[nodeidx]; localidx++) { in _setup_pals_pes()
438 uint16_t *task_cnts; in create_apinfo() local
454 task_cnts = job->het_job_task_cnts; in create_apinfo()
461 task_cnts = job->msg->tasks_to_launch; in create_apinfo()
487 if (task_cnts == NULL) { in create_apinfo()
502 pes = _setup_pals_pes(ntasks, nnodes, task_cnts, tids, tid_offsets); in create_apinfo()
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmd/slurmstepd/
H A Dmulti_prog.c466 if (!job->task_cnts) { in multi_prog_parse()
470 if (!job->task_cnts[i]) { in multi_prog_parse()
482 for (j = 0; j < job->task_cnts[i]; j++) { in multi_prog_parse()
H A Dslurmstepd_job.c150 for (j = 1; j < job->task_cnts[i]; j++) { in _job_init_task_info()
306 job->task_cnts = xcalloc(msg->nnodes, sizeof(uint16_t)); in stepd_step_rec_create()
307 memcpy(job->task_cnts, msg->tasks_to_launch, in stepd_step_rec_create()
691 xfree(job->task_cnts); in stepd_step_rec_destroy()
H A Dslurmstepd_job.h148 uint16_t *task_cnts; /* Number of tasks on each node in job */ member
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/common/
H A Dslurm_mpi.c108 info("task_cnts[%d]:%u", i, job->task_cnts[i]); in _log_step_rec()