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 D | pmixp_nspaces.c | 46 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 D | pmixp_info.c | 143 _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 D | pmixp_nspaces.h | 60 uint32_t *task_cnts; /* Number of tasks on each node of namespace */ member 80 uint32_t ntasks, uint32_t *task_cnts,
|
H A D | pmixp_info.h | 60 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 D | pmixp_client.c | 396 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 D | apinfo.c | 257 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 D | multi_prog.c | 466 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 D | slurmstepd_job.c | 150 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 D | slurmstepd_job.h | 148 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 D | slurm_mpi.c | 108 info("task_cnts[%d]:%u", i, job->task_cnts[i]); in _log_step_rec()
|