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

Cleanup C example code

parent 6b6f97a9
No related branches found
No related tags found
1 merge request!12Resolve "Execute RPCs tests in CI"
Showing
with 86 additions and 92 deletions
......@@ -74,9 +74,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -87,16 +87,16 @@ main(int argc, char* argv[]) {
ADM_qos_limit_t** limits = NULL;
ADM_transfer_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE;
ADM_transfer_t tx;
ADM_return_t ret_tx = ADM_transfer_dataset(server, job, sources, targets,
limits, mapping, &tx);
if(ret_tx != ADM_SUCCESS) {
ret = ADM_transfer_dataset(server, job, sources, targets, limits, mapping,
&tx);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_dataset() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
goto cleanup;
}
ADM_return_t ret = ADM_cancel_transfer(server, job, tx);
ret = ADM_cancel_transfer(server, job, tx);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_cancel_transfer() remote procedure not completed "
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -86,8 +86,8 @@ main(int argc, char* argv[]) {
exit_status = EXIT_SUCCESS;
bool should_stream = false;
ADM_return_t ret = ADM_connect_data_operation(server, job, inputs[0],
outputs[0], should_stream);
ret = ADM_connect_data_operation(server, job, inputs[0], outputs[0],
should_stream);
if(ret != ADM_SUCCESS) {
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -87,8 +87,7 @@ main(int argc, char* argv[]) {
const char* path = "/tmpxxxxx";
// va_list args; // FIXME placeholder
ADM_return_t ret = ADM_define_data_operation(server, job, path, &op);
ret = ADM_define_data_operation(server, job, path, &op);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -85,10 +85,9 @@ main(int argc, char* argv[]) {
ADM_storage_t adhoc_storage;
ADM_return_t ret_as =
ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
ret = ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
if(ret_as != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout,
"ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n");
......@@ -99,8 +98,7 @@ main(int argc, char* argv[]) {
fprintf(stdout, "ADM_register_adhoc_storage() remote procedure completed "
"successfully\n");
ADM_return_t ret = ADM_deploy_adhoc_storage(server, job, adhoc_storage);
ret = ADM_deploy_adhoc_storage(server, job, adhoc_storage);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -88,8 +88,7 @@ main(int argc, char* argv[]) {
ADM_define_data_operation(server, job, path, &op);
ADM_data_operation_status_t status;
ADM_return_t ret = ADM_finalize_data_operation(server, job, op, &status);
ret = ADM_finalize_data_operation(server, job, op, &status);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -74,17 +74,16 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_transfer_t** tx = NULL;
ADM_return_t ret = ADM_get_pending_transfers(server, job, tx);
ret = ADM_get_pending_transfers(server, job, tx);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -86,8 +86,7 @@ main(int argc, char* argv[]) {
ADM_qos_entity_t entity = NULL;
ADM_qos_limit_t* limits;
ADM_return_t ret = ADM_get_qos_constraints(server, job, entity, &limits);
ret = ADM_get_qos_constraints(server, job, entity, &limits);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -74,17 +74,16 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_job_stats_t* stats = NULL;
ADM_return_t ret = ADM_get_statistics(server, job, &stats);
ret = ADM_get_statistics(server, job, &stats);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_get_statistics() remote procedure not completed "
......
......@@ -74,22 +74,23 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_dataset_t** sources = NULL;
ADM_dataset_t** targets = NULL;
ADM_qos_limit_t** limits = NULL;
ADM_transfer_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE;
ADM_transfer_t tx;
ADM_return_t ret_tx = ADM_transfer_dataset(server, job, sources, targets,
limits, mapping, &tx);
ret = ADM_transfer_dataset(server, job, sources, targets, limits, mapping,
&tx);
if(ret_tx != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_dataset() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -97,8 +98,7 @@ main(int argc, char* argv[]) {
}
ADM_transfer_priority_t priority;
ADM_return_t ret = ADM_get_transfer_priority(server, job, tx, &priority);
ret = ADM_get_transfer_priority(server, job, tx, &priority);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -75,13 +75,14 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_data_operation_t op;
const char* path = "/tmpxxxxx";
ADM_define_data_operation(server, job, path, &op);
......@@ -90,10 +91,10 @@ main(int argc, char* argv[]) {
ADM_qos_limit_t** limits = NULL;
ADM_transfer_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE;
ADM_transfer_t tx;
ADM_return_t ret_tx = ADM_transfer_dataset(server, job, sources, targets,
limits, mapping, &tx);
ret = ADM_transfer_dataset(server, job, sources, targets, limits, mapping,
&tx);
if(ret_tx != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_dataset() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -101,9 +102,9 @@ main(int argc, char* argv[]) {
}
bool should_stream = false;
va_list args;
ADM_return_t ret = ADM_link_transfer_to_data_operation(server, job, op, tx,
should_stream, args);
ret = ADM_link_transfer_to_data_operation(server, job, op, tx,
should_stream, args);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
"ADM_link_transfer_to_data_operation() remote procedure not completed "
......
......@@ -76,9 +76,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -86,8 +86,7 @@ main(int argc, char* argv[]) {
ADM_storage_t adhoc_storage;
ADM_return_t ret =
ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
ret = ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -75,18 +75,18 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_storage_t adhoc_storage;
ADM_return_t ret_as =
ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
ret = ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
if(ret_as != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout,
"ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n");
......@@ -97,7 +97,7 @@ main(int argc, char* argv[]) {
fprintf(stdout, "ADM_register_adhoc_storage() remote procedure completed "
"successfully\n");
ADM_return_t ret = ADM_remove_adhoc_storage(server, job, adhoc_storage);
ret = ADM_remove_adhoc_storage(server, job, adhoc_storage);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......@@ -111,7 +111,6 @@ main(int argc, char* argv[]) {
"successfully\n");
cleanup:
ADM_server_destroy(server);
exit(exit_status);
}
......@@ -74,15 +74,15 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_return_t ret = ADM_remove_job(server, job);
ret = ADM_remove_job(server, job);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_remove_job() remote procedure not completed "
......
......@@ -75,16 +75,17 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_dataset_t target = NULL;
ADM_dataset_info_t info = NULL;
ADM_return_t ret = ADM_set_dataset_information(server, job, target, info);
ret = ADM_set_dataset_information(server, job, target, info);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -76,16 +76,17 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_storage_t tier = NULL;
ADM_storage_resources_t resources = NULL;
ADM_return_t ret = ADM_set_io_resources(server, job, tier, resources);
ret = ADM_set_io_resources(server, job, tier, resources);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_set_io_resources() remote procedure not completed "
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -86,7 +86,7 @@ main(int argc, char* argv[]) {
ADM_qos_entity_t entity = NULL;
ADM_qos_limit_t limit = NULL;
ADM_return_t ret = ADM_set_qos_constraints(server, job, entity, limit);
ret = ADM_set_qos_constraints(server, job, entity, limit);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -88,8 +88,8 @@ main(int argc, char* argv[]) {
ADM_qos_limit_t** limits = NULL;
ADM_transfer_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE;
ADM_transfer_t tx;
ADM_return_t ret = ADM_transfer_dataset(server, job, sources, targets,
limits, mapping, &tx);
ret = ADM_transfer_dataset(server, job, sources, targets, limits, mapping,
&tx);
int incr = 42;
ret = ADM_set_transfer_priority(server, job, tx, incr);
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -88,8 +88,8 @@ main(int argc, char* argv[]) {
ADM_qos_limit_t** limits = NULL;
ADM_transfer_mapping_t mapping = ADM_MAPPING_ONE_TO_ONE;
ADM_transfer_t tx;
ADM_return_t ret = ADM_transfer_dataset(server, job, sources, targets,
limits, mapping, &tx);
ret = ADM_transfer_dataset(server, job, sources, targets, limits, mapping,
&tx);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_transfer_dataset() remote procedure not completed "
......
......@@ -74,18 +74,18 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
}
ADM_storage_t adhoc_storage;
ADM_return_t ret_as =
ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
ret = ADM_register_adhoc_storage(server, job, ctx, &adhoc_storage);
if(ret_as != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout,
"ADM_register_adhoc_storage() remote procedure not completed "
"successfully\n");
......@@ -96,8 +96,7 @@ main(int argc, char* argv[]) {
fprintf(stdout, "ADM_register_adhoc_storage() remote procedure completed "
"successfully\n");
ADM_return_t ret =
ADM_update_adhoc_storage(server, job, ctx, adhoc_storage);
ret = ADM_update_adhoc_storage(server, job, ctx, adhoc_storage);
if(ret != ADM_SUCCESS) {
fprintf(stdout,
......
......@@ -75,9 +75,9 @@ main(int argc, char* argv[]) {
ADM_job_requirements_create(inputs, NINPUTS, outputs, NOUTPUTS, st);
assert(reqs);
ADM_return_t ret_job = ADM_register_job(server, reqs, &job);
ADM_return_t ret = ADM_register_job(server, reqs, &job);
if(ret_job != ADM_SUCCESS) {
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_register_job() remote procedure not completed "
"successfully\n");
exit_status = EXIT_FAILURE;
......@@ -105,7 +105,8 @@ main(int argc, char* argv[]) {
ADM_job_requirements_t new_reqs = ADM_job_requirements_create(
new_inputs, NINPUTS, new_outputs, NOUTPUTS, st);
ADM_return_t ret = ADM_update_job(server, job, new_reqs);
ret = ADM_update_job(server, job, new_reqs);
if(ret != ADM_SUCCESS) {
fprintf(stdout, "ADM_update_job() remote procedure not completed "
......
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