Skip to content
Snippets Groups Projects

Resolve "adhoc_storage instances should keep track of jobs using them"

35 files
+ 559
294
Compare changes
  • Side-by-side
  • Inline
Files
35
@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]);
ADM_job_t job;
ADM_job_t job = NULL;
ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
@@ -75,8 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_adhoc_storage() remote procedure not "
"completed successfully\n");
fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not "
"completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE;
goto cleanup;
}
@@ -89,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
fprintf(stderr,
"ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE;
goto cleanup;
}
ADM_dataset_t* sources = NULL;
@@ -107,8 +112,10 @@ main(int argc, char* argv[]) {
targets_len, limits, limits_len, mapping, &tx);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_datasets() remote procedure not "
"completed successfully\n");
fprintf(stderr,
"ADM_transfer_datasets() remote procedure not "
"completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE;
goto cleanup;
}
@@ -116,8 +123,10 @@ main(int argc, char* argv[]) {
ret = ADM_cancel_transfer(server, job, tx);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_cancel_transfer() remote procedure not completed "
"successfully\n");
fprintf(stderr,
"ADM_cancel_transfer() remote procedure not completed "
"successfully\n, %s",
ADM_strerror(ret));
exit_status = EXIT_FAILURE;
goto cleanup;
}
@@ -126,6 +135,7 @@ main(int argc, char* argv[]) {
"successfully\n");
cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server);
destroy_datasets(inputs, NINPUTS);
destroy_datasets(outputs, NOUTPUTS);
Loading