Home
last modified time | relevance | path

Searched refs:task_dist (Results 1 – 25 of 46) sorted by relevance

12

/dports/sysutils/slurm-wlm/slurm-20.02.7/src/common/
H A Dslurm_step_layout.c83 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 Dslurm_step_layout.h88 extern char *slurm_step_layout_type_name(task_dist_states_t task_dist);
H A Denv.c965 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 Dslurm_mpi.c138 layout->task_dist); in _log_mpi_rec()
H A Dslurmdbd_defs.h383 uint32_t task_dist; /* layout method of step */ member
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/select/cray_aries/
H A Dccm.c328 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 Dccm.h81 uint16_t task_dist; member
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmctld/
H A Dstep_mgr.c2400 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 Dslurmctld.h599 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 Dtask_cgroup_cpuset.c577 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 Dsetup.c442 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 Dlaunch.c270 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 Das_mysql_job.c1139 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 Das_mysql_archive.c266 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 Dstep_ctx.c147 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 Dinit_msg.c93 job_desc_msg->task_dist = NO_VAL; in slurm_init_job_desc_msg()
H A Dstep_launch.c189 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 Ddist_tasks.c502 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 Ddist_tasks.c239 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 Dslurmstepd_job.h158 task_dist_states_t task_dist;/* -m distribution */ member
H A Dslurmstepd_job.c329 job->task_dist = msg->task_dist; in stepd_step_rec_create()
H A Dtask.c379 job->envtp->distribution = job->task_dist; in exec_task()
/dports/sysutils/slurm-wlm/slurm-20.02.7/contribs/perlapi/libslurm/perl/
H A Dstep_ctx.c42 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 Dstep.c199 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 Daccounting_storage_slurmdbd.c2695 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()

12