Skip to content
Snippets Groups Projects
Verified Commit c5de2913 authored by Alberto Miranda's avatar Alberto Miranda :hotsprings:
Browse files

examples: Ensure ADM_remove_job is called

Print error messages to stderr instead of stdout

Closes #86
parent 7e9d1bd0
No related branches found
No related tags found
1 merge request!58Resolve "adhoc_storage instances should keep track of jobs using them"
Pipeline #3252 passed
This commit is part of merge request !58. Comments created here will be created in the context of that merge request.
Showing
with 237 additions and 138 deletions
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -75,8 +75,10 @@ main(int argc, char* argv[]) { ...@@ -75,8 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_adhoc_storage() remote procedure not " fprintf(stderr,
"completed successfully\n"); "ADM_register_adhoc_storage() remote procedure not "
"completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -89,9 +91,12 @@ main(int argc, char* argv[]) { ...@@ -89,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_dataset_t* sources = NULL; ADM_dataset_t* sources = NULL;
...@@ -107,8 +112,10 @@ main(int argc, char* argv[]) { ...@@ -107,8 +112,10 @@ main(int argc, char* argv[]) {
targets_len, limits, limits_len, mapping, &tx); targets_len, limits, limits_len, mapping, &tx);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_datasets() remote procedure not " fprintf(stderr,
"completed successfully\n"); "ADM_transfer_datasets() remote procedure not "
"completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -116,8 +123,10 @@ main(int argc, char* argv[]) { ...@@ -116,8 +123,10 @@ main(int argc, char* argv[]) {
ret = ADM_cancel_transfer(server, job, tx); ret = ADM_cancel_transfer(server, job, tx);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_cancel_transfer() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_cancel_transfer() remote procedure not completed "
"successfully\n, %s",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -126,6 +135,7 @@ main(int argc, char* argv[]) { ...@@ -126,6 +135,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
destroy_datasets(inputs, NINPUTS); destroy_datasets(inputs, NINPUTS);
destroy_datasets(outputs, NOUTPUTS); destroy_datasets(outputs, NOUTPUTS);
......
...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) { ...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) { ...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
exit_status = EXIT_SUCCESS; exit_status = EXIT_SUCCESS;
...@@ -103,9 +107,10 @@ main(int argc, char* argv[]) { ...@@ -103,9 +107,10 @@ main(int argc, char* argv[]) {
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_connect_data_operation() remote procedure not completed " "ADM_connect_data_operation() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -122,6 +127,7 @@ cleanup: ...@@ -122,6 +127,7 @@ cleanup:
ADM_dataset_destroy(outputs[i]); ADM_dataset_destroy(outputs[i]);
} }
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) { ...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) {
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -76,9 +76,10 @@ main(int argc, char* argv[]) { ...@@ -76,9 +76,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -91,9 +92,12 @@ main(int argc, char* argv[]) { ...@@ -91,9 +92,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_data_operation_t op; ADM_data_operation_t op;
...@@ -103,9 +107,10 @@ main(int argc, char* argv[]) { ...@@ -103,9 +107,10 @@ main(int argc, char* argv[]) {
ret = ADM_define_data_operation(server, job, path, &op); ret = ADM_define_data_operation(server, job, path, &op);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_define_data_operation() remote procedure not completed " "ADM_define_data_operation() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -114,7 +119,7 @@ main(int argc, char* argv[]) { ...@@ -114,7 +119,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -67,9 +67,10 @@ main(int argc, char* argv[]) { ...@@ -67,9 +67,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -80,9 +81,10 @@ main(int argc, char* argv[]) { ...@@ -80,9 +81,10 @@ main(int argc, char* argv[]) {
ret = ADM_deploy_adhoc_storage(server, adhoc_storage); ret = ADM_deploy_adhoc_storage(server, adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_deploy_adhoc_storage() remote procedure not completed " "ADM_deploy_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -91,7 +93,6 @@ main(int argc, char* argv[]) { ...@@ -91,7 +93,6 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) { ...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -72,9 +72,10 @@ main(int argc, char* argv[]) { ...@@ -72,9 +72,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -91,10 +92,14 @@ main(int argc, char* argv[]) { ...@@ -91,10 +92,14 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_data_operation_t op; ADM_data_operation_t op;
const char* path = "/tmpxxxxx"; const char* path = "/tmpxxxxx";
...@@ -104,9 +109,10 @@ main(int argc, char* argv[]) { ...@@ -104,9 +109,10 @@ main(int argc, char* argv[]) {
ret = ADM_finalize_data_operation(server, job, op, &status); ret = ADM_finalize_data_operation(server, job, op, &status);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_finalize_data_operation() remote procedure not completed " "ADM_finalize_data_operation() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -115,7 +121,7 @@ main(int argc, char* argv[]) { ...@@ -115,7 +121,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) { ...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,18 +91,23 @@ main(int argc, char* argv[]) { ...@@ -90,18 +91,23 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_transfer_t** tx = NULL; ADM_transfer_t** tx = NULL;
ret = ADM_get_pending_transfers(server, job, tx); ret = ADM_get_pending_transfers(server, job, tx);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_get_pending_transfers() remote procedure not completed " "ADM_get_pending_transfers() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -110,7 +116,7 @@ main(int argc, char* argv[]) { ...@@ -110,7 +116,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) { ...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) { ...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_qos_entity_t entity = NULL; ADM_qos_entity_t entity = NULL;
...@@ -101,9 +105,10 @@ main(int argc, char* argv[]) { ...@@ -101,9 +105,10 @@ main(int argc, char* argv[]) {
ret = ADM_get_qos_constraints(server, job, entity, &limits); ret = ADM_get_qos_constraints(server, job, entity, &limits);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_get_qos_constraints() remote procedure not completed " "ADM_get_qos_constraints() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -112,7 +117,7 @@ main(int argc, char* argv[]) { ...@@ -112,7 +117,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) { ...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,17 +91,23 @@ main(int argc, char* argv[]) { ...@@ -90,17 +91,23 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_job_stats_t* stats = NULL; ADM_job_stats_t* stats = NULL;
ret = ADM_get_statistics(server, job, &stats); ret = ADM_get_statistics(server, job, &stats);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_get_statistics() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_get_statistics() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -109,7 +116,7 @@ main(int argc, char* argv[]) { ...@@ -109,7 +116,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) { ...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) { ...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_dataset_t* sources = NULL; ADM_dataset_t* sources = NULL;
...@@ -108,8 +112,10 @@ main(int argc, char* argv[]) { ...@@ -108,8 +112,10 @@ main(int argc, char* argv[]) {
targets_len, limits, limits_len, mapping, &tx); targets_len, limits, limits_len, mapping, &tx);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_datasets() remote procedure not " fprintf(stderr,
"completed successfully\n"); "ADM_transfer_datasets() remote procedure not "
"completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -118,9 +124,10 @@ main(int argc, char* argv[]) { ...@@ -118,9 +124,10 @@ main(int argc, char* argv[]) {
ret = ADM_get_transfer_priority(server, job, tx, &priority); ret = ADM_get_transfer_priority(server, job, tx, &priority);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_get_transfer_priority() remote procedure not completed " "ADM_get_transfer_priority() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -129,7 +136,7 @@ main(int argc, char* argv[]) { ...@@ -129,7 +136,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) { ...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -72,9 +72,10 @@ main(int argc, char* argv[]) { ...@@ -72,9 +72,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -91,9 +92,12 @@ main(int argc, char* argv[]) { ...@@ -91,9 +92,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_data_operation_t op; ADM_data_operation_t op;
...@@ -114,8 +118,10 @@ main(int argc, char* argv[]) { ...@@ -114,8 +118,10 @@ main(int argc, char* argv[]) {
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_datasets() remote procedure not " fprintf(stderr,
"completed successfully\n"); "ADM_transfer_datasets() remote procedure not "
"completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -125,9 +131,10 @@ main(int argc, char* argv[]) { ...@@ -125,9 +131,10 @@ main(int argc, char* argv[]) {
ret = ADM_link_transfer_to_data_operation(server, job, op, tx, ret = ADM_link_transfer_to_data_operation(server, job, op, tx,
should_stream, args); should_stream, args);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_link_transfer_to_data_operation() remote procedure not completed " "ADM_link_transfer_to_data_operation() remote procedure not "
"successfully\n"); "completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -137,7 +144,7 @@ main(int argc, char* argv[]) { ...@@ -137,7 +144,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -67,9 +67,10 @@ main(int argc, char* argv[]) { ...@@ -67,9 +67,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -78,7 +79,6 @@ main(int argc, char* argv[]) { ...@@ -78,7 +79,6 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) { ...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,8 +91,10 @@ main(int argc, char* argv[]) { ...@@ -90,8 +91,10 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -114,6 +117,7 @@ cleanup: ...@@ -114,6 +117,7 @@ cleanup:
ADM_job_requirements_destroy(reqs); ADM_job_requirements_destroy(reqs);
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -60,9 +60,10 @@ main(int argc, char* argv[]) { ...@@ -60,9 +60,10 @@ main(int argc, char* argv[]) {
ADM_return_t ret = ADM_register_pfs_storage(server, ctx, &pfs_storage); ADM_return_t ret = ADM_register_pfs_storage(server, ctx, &pfs_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_pfs_storage() remote procedure not completed " "ADM_register_pfs_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
......
...@@ -67,9 +67,10 @@ main(int argc, char* argv[]) { ...@@ -67,9 +67,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -80,9 +81,10 @@ main(int argc, char* argv[]) { ...@@ -80,9 +81,10 @@ main(int argc, char* argv[]) {
ret = ADM_remove_adhoc_storage(server, adhoc_storage); ret = ADM_remove_adhoc_storage(server, adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_remove_adhoc_storage() remote procedure not completed " "ADM_remove_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
......
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) { ...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,16 +91,21 @@ main(int argc, char* argv[]) { ...@@ -90,16 +91,21 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ret = ADM_remove_job(server, job); ret = ADM_remove_job(server, job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_remove_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_remove_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -108,7 +114,6 @@ main(int argc, char* argv[]) { ...@@ -108,7 +114,6 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -46,9 +46,10 @@ main(int argc, char* argv[]) { ...@@ -46,9 +46,10 @@ main(int argc, char* argv[]) {
ADM_return_t ret = ADM_register_pfs_storage(server, ctx, &pfs_storage); ADM_return_t ret = ADM_register_pfs_storage(server, ctx, &pfs_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_pfs_storage() remote procedure not completed " "ADM_register_pfs_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -59,9 +60,10 @@ main(int argc, char* argv[]) { ...@@ -59,9 +60,10 @@ main(int argc, char* argv[]) {
ret = ADM_remove_pfs_storage(server, pfs_storage); ret = ADM_remove_pfs_storage(server, pfs_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_remove_pfs_storage() remote procedure not completed " "ADM_remove_pfs_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
......
...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) { ...@@ -46,7 +46,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -72,9 +72,10 @@ main(int argc, char* argv[]) { ...@@ -72,9 +72,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -91,9 +92,12 @@ main(int argc, char* argv[]) { ...@@ -91,9 +92,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_dataset_t target = NULL; ADM_dataset_t target = NULL;
...@@ -101,9 +105,10 @@ main(int argc, char* argv[]) { ...@@ -101,9 +105,10 @@ main(int argc, char* argv[]) {
ret = ADM_set_dataset_information(server, job, target, info); ret = ADM_set_dataset_information(server, job, target, info);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_set_dataset_information() remote procedure not completed " "ADM_set_dataset_information() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -113,6 +118,7 @@ main(int argc, char* argv[]) { ...@@ -113,6 +118,7 @@ main(int argc, char* argv[]) {
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) { ...@@ -71,9 +71,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) { ...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_storage_t tier = NULL; ADM_storage_t tier = NULL;
...@@ -100,8 +104,10 @@ main(int argc, char* argv[]) { ...@@ -100,8 +104,10 @@ main(int argc, char* argv[]) {
ret = ADM_set_io_resources(server, job, tier, resources); ret = ADM_set_io_resources(server, job, tier, resources);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_set_io_resources() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_set_io_resources() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -110,7 +116,7 @@ main(int argc, char* argv[]) { ...@@ -110,7 +116,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) { ...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) { ...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_qos_entity_t entity = NULL; ADM_qos_entity_t entity = NULL;
...@@ -101,9 +105,10 @@ main(int argc, char* argv[]) { ...@@ -101,9 +105,10 @@ main(int argc, char* argv[]) {
ret = ADM_set_qos_constraints(server, job, entity, limit); ret = ADM_set_qos_constraints(server, job, entity, limit);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_set_qos_constraints() remote procedure not completed " "ADM_set_qos_constraints() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -113,6 +118,7 @@ main(int argc, char* argv[]) { ...@@ -113,6 +118,7 @@ main(int argc, char* argv[]) {
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) { ...@@ -45,7 +45,7 @@ main(int argc, char* argv[]) {
int exit_status = EXIT_SUCCESS; int exit_status = EXIT_SUCCESS;
ADM_server_t server = ADM_server_create("tcp", argv[1]); 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); ADM_node_t* job_nodes = prepare_nodes(NJOB_NODES);
assert(job_nodes); assert(job_nodes);
ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES); ADM_node_t* adhoc_nodes = prepare_nodes(NADHOC_NODES);
...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) { ...@@ -75,9 +75,10 @@ main(int argc, char* argv[]) {
server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage); server, name, ADM_STORAGE_GEKKOFS, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_register_adhoc_storage() remote procedure not completed " "ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) { ...@@ -90,9 +91,12 @@ main(int argc, char* argv[]) {
ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job); ret = ADM_register_job(server, job_resources, reqs, slurm_job_id, &job);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed " fprintf(stderr,
"successfully\n"); "ADM_register_job() remote procedure not completed "
"successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup;
} }
ADM_dataset_t* sources = NULL; ADM_dataset_t* sources = NULL;
...@@ -108,8 +112,10 @@ main(int argc, char* argv[]) { ...@@ -108,8 +112,10 @@ main(int argc, char* argv[]) {
targets_len, limits, limits_len, mapping, &tx); targets_len, limits, limits_len, mapping, &tx);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_datasets() remote procedure not " fprintf(stderr,
"completed successfully\n"); "ADM_transfer_datasets() remote procedure not "
"completed successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -118,9 +124,10 @@ main(int argc, char* argv[]) { ...@@ -118,9 +124,10 @@ main(int argc, char* argv[]) {
ret = ADM_set_transfer_priority(server, job, tx, incr); ret = ADM_set_transfer_priority(server, job, tx, incr);
if(ret != ADM_SUCCESS) { if(ret != ADM_SUCCESS) {
fprintf(stdout, fprintf(stderr,
"ADM_set_transfer_priority() remote procedure not completed " "ADM_set_transfer_priority() remote procedure not completed "
"successfully\n"); "successfully: %s\n",
ADM_strerror(ret));
exit_status = EXIT_FAILURE; exit_status = EXIT_FAILURE;
goto cleanup; goto cleanup;
} }
...@@ -129,7 +136,7 @@ main(int argc, char* argv[]) { ...@@ -129,7 +136,7 @@ main(int argc, char* argv[]) {
"successfully\n"); "successfully\n");
cleanup: cleanup:
ADM_remove_job(server, job);
ADM_server_destroy(server); ADM_server_destroy(server);
exit(exit_status); exit(exit_status);
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment