| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/switch/cray_aries/ |
| H A D | switch_cray_aries.c | 176 xassert(switch_job); in switch_p_alloc_jobinfo()
183 *switch_job = (switch_jobinfo_t *) new; in switch_p_alloc_jobinfo()
354 if (!switch_job) { in switch_p_unpack_jobinfo()
362 *switch_job = (switch_jobinfo_t *)job; in switch_p_unpack_jobinfo()
410 switch_p_free_jobinfo(*switch_job); in switch_p_unpack_jobinfo()
411 *switch_job = NULL; in switch_p_unpack_jobinfo()
454 slurm_cray_jobinfo_t *sw_job = job->switch_job ? in switch_p_job_init()
455 (slurm_cray_jobinfo_t *)job->switch_job->data : NULL; in switch_p_job_init()
793 if (!job->switch_job) { in switch_p_job_postfini()
984 slurm_cray_jobinfo_t *jobinfo = job->switch_job ? in switch_p_job_step_pre_suspend()
[all …]
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/switch/none/ |
| H A D | switch_none.c | 116 int switch_p_alloc_jobinfo ( switch_jobinfo_t **switch_job, in switch_p_alloc_jobinfo() argument
122 int switch_p_build_jobinfo ( switch_jobinfo_t *switch_job, in switch_p_build_jobinfo() argument
134 void switch_p_free_jobinfo ( switch_jobinfo_t *switch_job ) in switch_p_free_jobinfo() argument
139 int switch_p_pack_jobinfo(switch_jobinfo_t *switch_job, Buf buffer, in switch_p_pack_jobinfo() argument
145 int switch_p_unpack_jobinfo(switch_jobinfo_t **switch_job, Buf buffer, in switch_p_unpack_jobinfo() argument
257 extern int switch_p_get_jobinfo(switch_jobinfo_t *switch_job, in switch_p_get_jobinfo() argument
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/plugins/switch/generic/ |
| H A D | switch_generic.c | 353 int switch_p_alloc_jobinfo(switch_jobinfo_t **switch_job, in switch_p_alloc_jobinfo() argument
360 xassert(switch_job); in switch_p_alloc_jobinfo()
363 *switch_job = (switch_jobinfo_t *) gen_step_info; in switch_p_alloc_jobinfo()
368 int switch_p_build_jobinfo(switch_jobinfo_t *switch_job, in switch_p_build_jobinfo() argument
435 void switch_p_free_jobinfo(switch_jobinfo_t *switch_job) in switch_p_free_jobinfo() argument
507 switch_p_alloc_jobinfo(switch_job, 0, 0); in switch_p_unpack_jobinfo()
508 gen_step_info = (sw_gen_step_info_t *) *switch_job; in switch_p_unpack_jobinfo()
545 *switch_job = NULL; in switch_p_unpack_jobinfo()
586 int switch_p_job_preinit(switch_jobinfo_t *switch_job) in switch_p_job_preinit() argument
708 extern int switch_p_get_jobinfo(switch_jobinfo_t *switch_job, in switch_p_get_jobinfo() argument
[all …]
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/api/ |
| H A D | step_ctx.c | 372 if (switch_g_alloc_jobinfo(&step_resp->switch_job, in slurm_step_ctx_create_no_alloc()
376 if (switch_g_build_jobinfo(step_resp->switch_job, in slurm_step_ctx_create_no_alloc()
422 dynamic_plugin_data_t **switch_job; in slurm_step_ctx_get() local
472 switch_job = (dynamic_plugin_data_t **) va_arg(ap, void *); in slurm_step_ctx_get()
473 *switch_job = ctx->step_resp->switch_job; in slurm_step_ctx_get()
|
| H A D | step_launch.c | 299 launch.switch_job = ctx->step_resp->switch_job; in slurm_step_launch()
498 launch.switch_job = ctx->step_resp->switch_job; in slurm_step_launch_add()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmctld/ |
| H A D | step_mgr.c | 374 if (step_ptr->switch_job) { in _free_step_rec()
377 step_ptr->switch_job, in _free_step_rec()
2817 if (!het_step_ptr->switch_job) in step_create()
2821 &step_ptr->switch_job); in step_create()
3518 if (step_ptr->switch_job) { in step_partial_comp()
3522 step_ptr->switch_job, in step_partial_comp()
3525 step_ptr->switch_job = NULL; in step_partial_comp()
3539 step_ptr->switch_job, node_list); in step_partial_comp()
3688 if ((!step_ptr->switch_job) in step_epilog_complete()
3705 step_ptr->switch_job, node_name); in step_epilog_complete()
[all …]
|
| H A D | slurmctld.h | 991 dynamic_plugin_data_t *switch_job; /* switch context, opaque */ member
|
| H A D | proc_req.c | 2917 job_step_resp.switch_job = step_rec->switch_job; in _slurm_rpc_job_step_create()
|
| H A D | job_mgr.c | 15987 switch_g_job_suspend_info_get(step_ptr->switch_job, in _switch_suspend_info()
16188 rc = switch_g_job_suspend_test(step_ptr->switch_job); in _job_suspend_switch_test()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmd/slurmstepd/ |
| H A D | slurmstepd_job.h | 169 dynamic_plugin_data_t *switch_job; /* switch-specific job information */ member
|
| H A D | slurmstepd_job.c | 474 job->switch_job = msg->switch_job; in stepd_step_rec_create()
|
| H A D | task.c | 417 if (switch_g_job_attach(job->switch_job, &job->env, in exec_task()
|
| H A D | mgr.c | 1241 (switch_g_job_preinit(job->switch_job) < 0)) { in job_manager()
1374 (switch_g_job_fini(job->switch_job) < 0)) { in job_manager()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/src/common/ |
| H A D | slurm_protocol_defs.h | 789 dynamic_plugin_data_t *switch_job; /* switch opaque data type */ member
879 dynamic_plugin_data_t *switch_job; /* switch credential for the job */ member
|
| H A D | switch.c | 75 int (*get_jobinfo) ( switch_jobinfo_t *switch_job,
|
| H A D | slurm_protocol_defs.c | 1491 if (msg->switch_job) in slurm_free_launch_tasks_request_msg()
1492 switch_g_free_jobinfo(msg->switch_job); in slurm_free_launch_tasks_request_msg()
4070 if (msg->switch_job) in slurm_free_job_step_create_response_msg()
4071 switch_g_free_jobinfo(msg->switch_job); in slurm_free_job_step_create_response_msg()
|
| H A D | slurm_protocol_pack.c | 2769 switch_g_pack_jobinfo(msg->switch_job, buffer, in _pack_job_step_create_response_msg()
2806 if (switch_g_unpack_jobinfo(&tmp_ptr->switch_job, buffer, in _unpack_job_step_create_response_msg()
2809 switch_g_free_jobinfo(tmp_ptr->switch_job); in _unpack_job_step_create_response_msg()
7969 switch_g_pack_jobinfo(msg->switch_job, buffer, in _pack_launch_tasks_request_msg()
8062 switch_g_pack_jobinfo(msg->switch_job, buffer, in _pack_launch_tasks_request_msg()
8233 if (switch_g_unpack_jobinfo(&msg->switch_job, buffer, in _unpack_launch_tasks_request_msg()
8236 switch_g_free_jobinfo(msg->switch_job); in _unpack_launch_tasks_request_msg()
8371 if (switch_g_unpack_jobinfo(&msg->switch_job, buffer, in _unpack_launch_tasks_request_msg()
8374 switch_g_free_jobinfo(msg->switch_job); in _unpack_launch_tasks_request_msg()
|
| /dports/sysutils/slurm-wlm/slurm-20.02.7/contribs/perlapi/libslurm/perl/ |
| H A D | step_ctx.c | 74 STORE_PTR_FIELD(hv, resp_msg, switch_job, "TODO");
|