/dports/sysutils/slurm-wlm/slurm-20.02.7/src/common/ |
H A D | slurm_step_layout.c | 83 step_layout->task_dist = step_layout_req->task_dist; in slurm_step_layout_create() 84 if ((step_layout->task_dist & SLURM_DIST_STATE_BASE) in slurm_step_layout_create() 216 layout->task_dist = step_layout->task_dist; in slurm_step_layout_copy() 249 pack32(step_layout->task_dist, buffer); in pack_slurm_step_layout() 285 safe_unpack32(&step_layout->task_dist, buffer); in unpack_slurm_step_layout() 397 step_layout->node_list, step_layout->task_dist); in _init_task_layout() 453 if ((step_layout->task_dist & SLURM_DIST_NODEMASK) in _init_task_layout() 578 if (step_layout->task_dist & SLURM_DIST_PACK_NODES) in _task_layout_block() 823 switch (task_dist & SLURM_DIST_STATE_BASE) { in slurm_step_layout_type_name() 922 if (task_dist & SLURM_DIST_PACK_NODES) { in slurm_step_layout_type_name() [all …]
|
H A D | slurm_step_layout.h | 88 extern char *slurm_step_layout_type_name(task_dist_states_t task_dist);
|
H A D | env.c | 965 set_distribution(desc->task_dist, &dist, &lllp_dist); in env_array_for_job() 970 if ((desc->task_dist & SLURM_DIST_STATE_BASE) == SLURM_DIST_PLANE) { in env_array_for_job() 1025 if ((desc->task_dist & SLURM_DIST_STATE_BASE) == SLURM_DIST_ARBITRARY) { in env_array_for_job() 1037 step_layout_req.task_dist = desc->task_dist; in env_array_for_job() 1158 uint32_t task_dist; in env_array_for_batch_job() local 1242 task_dist = SLURM_DIST_ARBITRARY; in env_array_for_batch_job() 1245 task_dist = SLURM_DIST_BLOCK; in env_array_for_batch_job() 1252 step_layout_req.task_dist = task_dist; in env_array_for_batch_job()
|
H A D | slurm_mpi.c | 138 layout->task_dist); in _log_mpi_rec()
|
H A D | slurmdbd_defs.h | 383 uint32_t task_dist; /* layout method of step */ member
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/select/cray_aries/ |
H A D | ccm.c | 328 step_layout_req.task_dist = ccm_info->task_dist; in _ccm_create_nidlist_file() 591 if ((job_ptr->details->task_dist == 0) || in ccm_begin() 592 (job_ptr->details->task_dist > SLURM_DIST_UNKNOWN) || in ccm_begin() 593 (job_ptr->details->task_dist == SLURM_DIST_PLANE)) { in ccm_begin() 594 ccm_info.task_dist = SLURM_DIST_BLOCK; in ccm_begin() 596 job_ptr->job_id, job_ptr->details->task_dist); in ccm_begin() 598 ccm_info.task_dist = job_ptr->details->task_dist; in ccm_begin() 606 ccm_info.job_id, ccm_info.cpus_per_task, ccm_info.task_dist, in ccm_begin()
|
H A D | ccm.h | 81 uint16_t task_dist; member
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmctld/ |
H A D | step_mgr.c | 2400 uint32_t task_dist; in step_create() local 2442 task_dist = step_specs->task_dist & SLURM_DIST_STATE_BASE; in step_create() 2446 if ((task_dist == SLURM_DIST_UNKNOWN) && in step_create() 2450 task_dist = SLURM_DIST_BLOCK; in step_create() 2453 if ((task_dist != SLURM_DIST_CYCLIC) && in step_create() 2454 (task_dist != SLURM_DIST_BLOCK) && in step_create() 2479 (task_dist != SLURM_DIST_PLANE) && in step_create() 2480 (task_dist != SLURM_DIST_ARBITRARY)) in step_create() 2716 step_specs->task_dist, in step_create() 2878 uint32_t task_dist, in step_layout_create() argument [all …]
|
H A D | slurmctld.h | 599 uint32_t task_dist; /* task layout for this job. Only member 2383 uint32_t task_dist,
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/task/cgroup/ |
H A D | task_cgroup_cpuset.c | 577 sock_fcyclic = (job->task_dist & SLURM_DIST_SOCKMASK) == 579 core_cyclic = (job->task_dist & SLURM_DIST_COREMASK) == 581 core_fcyclic = (job->task_dist & SLURM_DIST_COREMASK) == 587 format_task_dist_states(job->task_dist), job->task_dist); 764 taskid, format_task_dist_states(job->task_dist), buf); 795 core_block = (job->task_dist & SLURM_DIST_COREMASK) == 797 core_fcyclic = (job->task_dist & SLURM_DIST_COREMASK) == 802 "task_dist 0x%x", taskid, job->task_dist); 858 taskid, format_task_dist_states(job->task_dist), 1553 job->task_dist); [all …]
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/mpi/pmi2/ |
H A D | setup.c | 442 uint32_t task_dist, block; in _get_proc_mapping() local 449 task_dist = job->step_layout->task_dist & SLURM_DIST_STATE_BASE; in _get_proc_mapping() 455 if ((task_dist & SLURM_DIST_NODEMASK) == SLURM_DIST_NODECYCLIC) { in _get_proc_mapping() 490 } else if (task_dist == SLURM_DIST_ARBITRARY) { in _get_proc_mapping() 500 } else if (task_dist == SLURM_DIST_PLANE) { in _get_proc_mapping()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/srun/libsrun/ |
H A D | launch.c | 270 job->ctx_params.task_dist = opt_local->distribution; in launch_common_create_job_step() 275 job->ctx_params.task_dist = SLURM_DIST_PLANE; in launch_common_create_job_step() 290 job->ctx_params.task_dist = opt_local->distribution; in launch_common_create_job_step()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/accounting_storage/mysql/ |
H A D | as_mysql_job.c | 1139 int tasks = 0, nodes = 0, task_dist = 0; in as_mysql_step_start() local 1174 task_dist = step_ptr->step_layout->task_dist; in as_mysql_step_start() 1222 task_dist = step_ptr->step_layout->task_dist; in as_mysql_step_start() 1264 nodes, tasks, node_list, node_inx, task_dist, in as_mysql_step_start() 1267 node_list, node_inx, task_dist, step_ptr->cpu_freq_max, in as_mysql_step_start()
|
H A D | as_mysql_archive.c | 266 char *task_dist; member 312 xfree(object->task_dist); in _free_local_step_members() 1509 packstr(object->task_dist, buffer); in _pack_local_step() 1561 safe_unpackstr_xmalloc(&object->task_dist, &tmp32, buffer); in _unpack_local_step() 1610 safe_unpackstr_xmalloc(&object->task_dist, &tmp32, buffer); in _unpack_local_step() 1763 safe_unpackstr_xmalloc(&object->task_dist, &tmp32, buffer); in _unpack_local_step() 1919 safe_unpackstr_xmalloc(&object->task_dist, &tmp32, buffer); in _unpack_local_step() 3247 step.task_dist = row[STEP_REQ_TASKDIST]; in _pack_archive_steps() 3327 object.task_dist, in _load_steps()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/api/ |
H A D | step_ctx.c | 147 step_req->task_dist = step_params->task_dist; in _create_step_request() 644 ptr->task_dist = SLURM_DIST_CYCLIC; in slurm_step_ctx_params_t_init()
|
H A D | init_msg.c | 93 job_desc_msg->task_dist = NO_VAL; in slurm_init_job_desc_msg()
|
H A D | step_launch.c | 189 new_step_layout->task_dist = orig_step_layout->task_dist; in _rebuild_mpi_layout() 324 launch.task_dist = params->task_dist; in slurm_step_launch() 516 launch.task_dist = params->task_dist; in slurm_step_launch_add()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/task/affinity/ |
H A D | dist_tasks.c | 502 buf_type, req->task_dist); in lllp_distribution() 507 req->job_id, buf_type, req->task_dist); in lllp_distribution() 510 switch (req->task_dist & SLURM_DIST_NODESOCKMASK) { in lllp_distribution() 1042 (((req->task_dist & SLURM_DIST_NODESOCKMASK) == in _task_layout_lllp_cyclic() 1044 ((req->task_dist & SLURM_DIST_NODESOCKMASK) == in _task_layout_lllp_cyclic()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/select/cons_common/ |
H A D | dist_tasks.c | 239 if ((job_ptr->details->task_dist & SLURM_DIST_STATE_BASE) == in _set_task_dist() 1206 if (((job_ptr->details->task_dist & SLURM_DIST_STATE_BASE) == in dist_tasks() 1238 switch (job_ptr->details->task_dist & SLURM_DIST_NODEMASK) { in dist_tasks() 1253 switch (job_ptr->details->task_dist & SLURM_DIST_NODESOCKMASK) { in dist_tasks()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmd/slurmstepd/ |
H A D | slurmstepd_job.h | 158 task_dist_states_t task_dist;/* -m distribution */ member
|
H A D | slurmstepd_job.c | 329 job->task_dist = msg->task_dist; in stepd_step_rec_create()
|
H A D | task.c | 379 job->envtp->distribution = job->task_dist; in exec_task()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/contribs/perlapi/libslurm/perl/ |
H A D | step_ctx.c | 42 FETCH_FIELD(hv, params, task_dist, uint16_t, FALSE); in hv_to_slurm_step_ctx_params() 207 FETCH_FIELD(hv, params, task_dist, uint16_t, FALSE); in hv_to_slurm_step_launch_params()
|
H A D | step.c | 199 STORE_FIELD(hv, step_layout, task_dist, uint16_t); in slurm_step_layout_to_hv()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/accounting_storage/slurmdbd/ |
H A D | accounting_storage_slurmdbd.c | 2695 uint32_t tasks = 0, nodes = 0, task_dist = 0; in jobacct_storage_p_step_start() local 2708 task_dist = step_ptr->step_layout->task_dist; in jobacct_storage_p_step_start() 2742 req.task_dist = step_ptr->step_layout->task_dist; in jobacct_storage_p_step_start() 2743 req.task_dist = task_dist; in jobacct_storage_p_step_start()
|