| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/srun/libsrun/ |
| H A D | opt.c | 111 static void _opt_env(int het_job_offset);
138 (het_job_offset >= 0) && in _get_first_opt()
204 if (het_job_offset == -2) { in get_next_opt()
210 if (offset_last != het_job_offset) { in get_next_opt()
211 offset_last = het_job_offset; in get_next_opt()
234 het_job_offset = in get_max_het_group()
237 max_het_job_offset = het_job_offset; in get_max_het_group()
573 static void _opt_env(int het_job_offset) in _opt_env() argument
581 if ((het_job_offset >= 0) && in _opt_env()
586 e->var, het_job_offset); in _opt_env()
[all …]
|
| H A D | srun_job.c | 139 int het_job_offset);
141 int het_job_offset);
498 int het_job_offset; in _het_grp_test() local
516 ((het_job_offset = in _het_grp_test()
519 het_job_offset); in _het_grp_test()
546 het_job_offset = 0; in _het_grp_test()
1089 het_job_offset = 0; in create_srun_job()
1203 het_job_offset++; in create_srun_job()
1277 job->het_job_offset = het_job_offset; in create_srun_job()
1820 int het_job_offset) in _set_env_vars() argument
[all …]
|
| H A D | opt.h | 101 extern slurm_opt_t *get_next_opt(int het_job_offset);
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/common/ |
| H A D | write_labelled_message.c | 52 uint32_t het_job_offset,
76 uint32_t het_job_offset, in write_labelled_message() argument
88 prefix = _build_label(task_id, task_id_width, het_job_offset, in write_labelled_message()
129 uint32_t het_job_offset, in _build_label() argument
134 if (het_job_offset != NO_VAL) { in _build_label()
139 xstrfmtcat(buf, "P%u %*d: ", het_job_offset, in _build_label()
|
| H A D | env.c | 948 if (het_job_offset < 1) { in env_array_for_job()
1046 het_job_offset, in env_array_for_job()
1057 het_job_offset, in env_array_for_job()
1075 het_job_offset, in env_array_for_job()
1104 het_job_offset, in env_array_for_job()
1108 het_job_offset, in env_array_for_job()
1542 int het_job_offset, in env_array_overwrite_het_fmt() argument
1553 if (het_job_offset != -1) { in env_array_overwrite_het_fmt()
1557 het_job_offset); in env_array_overwrite_het_fmt()
1561 het_job_offset); in env_array_overwrite_het_fmt()
[all …]
|
| H A D | env.h | 130 const job_desc_msg_t *desc, int het_job_offset);
289 int het_job_offset,
364 int het_job_offset);
|
| H A D | slurm_protocol_util.c | 172 if (msg->het_job_offset != NO_VAL) in slurm_print_launch_task_msg()
173 debug3("het_job_offset: %u", msg->het_job_offset); in slurm_print_launch_task_msg()
|
| H A D | write_labelled_message.h | 64 uint32_t het_job_offset,
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/sbcast/ |
| H A D | opts.c | 111 params.het_job_offset = NO_VAL; in parse_command_line()
144 params.het_job_offset = in parse_command_line()
255 if (params.het_job_offset == NO_VAL) { in _print_options()
259 params.job_id, params.het_job_offset); in _print_options()
262 if (params.het_job_offset == NO_VAL) { in _print_options()
267 params.job_id, params.het_job_offset, in _print_options()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/sbatch/ |
| H A D | opt.c | 1291 int het_job_offset) in set_envs() argument
1295 het_job_offset, "%u", in set_envs()
1301 het_job_offset, "%s", in set_envs()
1307 het_job_offset, "%s", in set_envs()
1313 het_job_offset, "%s", in set_envs()
1319 het_job_offset, "%s", in set_envs()
1325 het_job_offset, "%s", in set_envs()
1341 het_job_offset, "%u", in set_envs()
1347 het_job_offset, "%u", in set_envs()
1353 het_job_offset, "%u", in set_envs()
[all …]
|
| H A D | opt.h | 128 int het_job_offset);
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/api/ |
| H A D | step_io.h | 48 uint32_t het_job_offset; /* offset within a hetjob or NO_VAL */ member
109 bool label, uint32_t het_job_offset,
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmd/slurmstepd/ |
| H A D | slurmstepd_job.c | 136 uint32_t het_job_offset = 0; in _job_init_task_info() local
144 if (job->het_job_offset != NO_VAL) in _job_init_task_info()
145 het_job_offset = job->het_job_offset; in _job_init_task_info()
164 gtid[node_id][i] + het_job_offset, in _job_init_task_info()
167 gtid[node_id][i] + het_job_offset, in _job_init_task_info()
170 gtid[node_id][i] + het_job_offset, in _job_init_task_info()
383 job->het_job_offset = msg->het_job_offset; in stepd_step_rec_create()
541 job->het_job_offset = NO_VAL; /* Used to set labels and env vars */ in batch_stepd_step_rec_create()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/scontrol/ |
| H A D | info_job.c | 279 static bool _het_job_offset_match(job_info_t *job_ptr, uint32_t het_job_offset) in _het_job_offset_match() argument
281 if ((het_job_offset == NO_VAL) || in _het_job_offset_match()
282 (het_job_offset == job_ptr->het_job_offset)) in _het_job_offset_match()
315 uint32_t array_id = NO_VAL, het_job_offset = NO_VAL; in scontrol_print_job() local
340 het_job_offset = strtol(end_ptr + 1, &end_ptr, 10); in scontrol_print_job()
362 if (!_het_job_offset_match(job_ptr, het_job_offset)) in scontrol_print_job()
387 } else if (het_job_offset != NO_VAL) { in scontrol_print_job()
389 job_id, het_job_offset); in scontrol_print_job()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/sstat/ |
| H A D | options.c | 204 selected_step->het_job_offset = NO_VAL; in _addto_job_list()
211 selected_step->het_job_offset = in _addto_job_list()
268 selected_step->het_job_offset = NO_VAL; in _addto_job_list()
274 selected_step->het_job_offset = atoi(plus); in _addto_job_list()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/bcast/ |
| H A D | file_bcast.c | 137 rc = slurm_sbcast_lookup(params->job_id, params->het_job_offset, in _get_job_info()
141 if (params->het_job_offset == NO_VAL) { in _get_job_info()
147 params->job_id, params->het_job_offset, in _get_job_info()
151 if (params->het_job_offset == NO_VAL) { in _get_job_info()
157 params->job_id, params->het_job_offset, in _get_job_info()
|
| H A D | file_bcast.h | 49 uint32_t het_job_offset; /* HetJob offset or NO_VAL */ member
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/accounting_storage/mysql/ |
| H A D | as_mysql_jobacct_process.c | 268 char *het_job_ids = NULL, *het_job_offset = NULL; in _setup_job_cond_selected_steps() local
286 if (het_job_offset) in _setup_job_cond_selected_steps()
287 xstrcat(het_job_offset, " ,"); in _setup_job_cond_selected_steps()
290 xstrfmtcat(het_job_offset, "%u", in _setup_job_cond_selected_steps()
291 selected_step->het_job_offset); in _setup_job_cond_selected_steps()
323 if (het_job_offset) { in _setup_job_cond_selected_steps()
330 sep, het_job_ids, het_job_offset); in _setup_job_cond_selected_steps()
350 xfree(het_job_offset); in _setup_job_cond_selected_steps()
872 } else if ((selected_step->het_job_offset != in _cluster_get_jobs()
874 (selected_step->het_job_offset != in _cluster_get_jobs()
[all …]
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/prep/script/ |
| H A D | prep_script_slurmctld.c | 237 job_ptr->het_job_offset); in _build_env()
241 job_ptr->het_job_offset); in _build_env()
242 if ((job_ptr->het_job_offset == 0) && job_ptr->het_job_list) { in _build_env()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/jobcomp/script/ |
| H A D | jobcomp_script.c | 158 uint32_t het_job_offset; member
219 j->het_job_offset = job->het_job_offset; in _jobcomp_info_create()
409 _env_append_fmt (&env, "PACKJOBOFFSET", "%u", job->het_job_offset); in _create_environment()
411 _env_append_fmt (&env, "HETJOBOFFSET", "%u", job->het_job_offset); in _create_environment()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmctld/ |
| H A D | burst_buffer.c | 426 extern char *bb_g_build_het_job_script(char *script, uint32_t het_job_offset) in bb_g_build_het_job_script() argument
449 if (cur_offset > het_job_offset) in bb_g_build_het_job_script()
451 } else if (cur_offset == het_job_offset) { in bb_g_build_het_job_script()
459 if (het_job_offset == 0) { in bb_g_build_het_job_script()
|
| H A D | proc_req.c | 127 uint32_t het_job_offset,
1541 job_desc_msg->het_job_offset = het_job_offset; in _slurm_rpc_allocate_het_job()
1552 if (het_job_offset) { in _slurm_rpc_allocate_het_job()
1560 job_desc_msg->het_job_offset = het_job_offset; in _slurm_rpc_allocate_het_job()
1582 job_ptr->het_job_offset = het_job_offset++; in _slurm_rpc_allocate_het_job()
4268 job_desc_msg->het_job_offset = het_job_offset; in _slurm_rpc_submit_batch_het_job()
4290 het_job_offset++; in _slurm_rpc_submit_batch_het_job()
4312 het_job_offset = 0; in _slurm_rpc_submit_batch_het_job()
4326 if (het_job_offset) { in _slurm_rpc_submit_batch_het_job()
4344 job_desc_msg->het_job_offset = het_job_offset; in _slurm_rpc_submit_batch_het_job()
[all …]
|
| H A D | burst_buffer.h | 131 extern char *bb_g_build_het_job_script(char *script, uint32_t het_job_offset);
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/srun/ |
| H A D | srun.c | 418 het_job_tid_offsets[i] = job->het_job_offset; in _launch_app()
572 if (job->het_job_offset) { in _launch_app()
579 job->het_job_offset; in _launch_app()
758 params->het_job_offset = bit_ffs(srun_opt->het_grp_bits); in _file_bcast()
760 params->het_job_offset = NO_VAL; in _file_bcast()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/launch/slurm/ |
| H A D | launch_slurm.c | 697 job->het_job_offset, task_state_list); in launch_p_step_launch()
700 job->het_job_offset, job->ntasks, in launch_p_step_launch()
734 launch_params.het_job_offset = job->het_job_offset; in launch_p_step_launch()
|