floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加submit job测试用列

This commit is contained in:
tzwang 2022-10-20 03:24:32 -07:00
parent 23b380b035
commit 7242b4fa74
1 changed files with 83 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
adaptor/pcm_slurm/cgo/src/slurm/submitjob/submit_job.go Normal file
View File

@ -0,0 +1,83 @@
package submit_job
/*
#cgo LDFLAGS: -lslurm
#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include<slurm/slurm.h>
#include<slurm/slurm_errno.h>
int submit() {
int error_code, i, count;
job_desc_msg_t job_mesg;
submit_response_msg_t *resp_msg;
char *env[2];
slurm_init_job_desc_msg( &job_mesg );
job_mesg. contiguous = 1;
job_mesg. name = ("job01");
job_mesg. min_cpus = 1;
job_mesg. pn_min_memory = 100;
job_mesg. pn_min_tmp_disk = 200;
job_mesg. priority = 100;
job_mesg. shared = 0;
job_mesg. time_limit = 100;
job_mesg. min_nodes = 1;
job_mesg. user_id = getuid();
job_mesg. script = "#!/bin/csh\n/bin/hostname\n";
job_mesg. std_err = "/tmp/slurm.stderr";
job_mesg. std_in = "/tmp/slurm.stdin";
job_mesg. std_out = "/tmp/slurm.stdout";
job_mesg. work_dir = "/tmp\0";
job_mesg. env_size = 2;
env[0] = "SLURM_ENV_0=looking_good";
env[1] = "SLURM_ENV_1=still_good";
job_mesg. environment = env;
error_code = slurm_submit_batch_job( &job_mesg, &resp_msg );
if (error_code) {
slurm_perror ("slurm_submit_batch_job");
return (error_code);
}
else {
printf ("job %u submitted\n", resp_msg->job_id);
slurm_free_submit_response_response_msg ( resp_msg );
}
//if (argc > 1)
// count = atoi (argv[1]);
//else
// count = 1;
//
//for (i=1; i<count; i++) {
// slurm_init_job_desc_msg( &job_mesg );
// job_mesg. contiguous = 1;
// job_mesg. name = ("job02+");
// job_mesg. min_cpus = 1;
// job_mesg. pn_min_memory = 100 + i;
// job_mesg. pn_min_tmp_disk = 200 + i;
// job_mesg. priority = 100 + i;
// job_mesg. script = "/bin/hostname\n";
// job_mesg. shared = 0;
// job_mesg. time_limit = 100 + i;
// job_mesg. min_nodes = i;
// job_mesg. user_id = getuid();
// error_code = slurm_submit_batch_job( &job_mesg, &resp_msg );
// if (error_code) {
// slurm_perror ("slurm_submit_batch_job");
// break;
// }
// else {
// printf ("job %u submitted\n", resp_msg->job_id);
// slurm_free_submit_response_response_msg ( resp_msg );
// }
//}
exit (error_code);
}
*/
import "C"
func TestSubmit() {
C.submit()
}