Verified Commit 65cdfc2d authored by ANA MANZANO RODRIGUEZ's avatar ANA MANZANO RODRIGUEZ Committed by Alberto Miranda
Browse files

ADM_update_job.c test created

parent d11e211d

examples/c/ADM_update_job.c

0 → 100644
+62 −0
Original line number Diff line number Diff line 
#include <stdlib.h>

#include <stdio.h>

#include <admire.h>



#define NINPUTS  10

#define NOUTPUTS 5



int

main(int argc, char* argv[]) {



    if(argc != 3) {

        fprintf(stderr, "ERROR: no location provided\n");

        fprintf(stderr, "Usage: ADM_update_job <REMOTE_IP> <JOB_REQS>\n");

        exit(EXIT_FAILURE);

    }



    int exit_status = EXIT_SUCCESS;

    ADM_server_t server = ADM_server_create("tcp", argv[1]);



    ADM_job_t job;



    ADM_dataset_t inputs[NINPUTS];



    for(int i = 0; i < NINPUTS; ++i) {

        const char* pattern = "input-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) malloc(n + 1);

        snprintf(id, n, pattern, i);

        inputs[i] = ADM_dataset_create(id);

    }



    ADM_dataset_t outputs[NOUTPUTS];



    for(int i = 0; i < NOUTPUTS; ++i) {

        const char* pattern = "output-dataset-%d";

        size_t n = snprintf(NULL, 0, pattern, i);

        char* id = (char*) malloc(n + 1);

        snprintf(id, n, pattern, i);

        outputs[i] = ADM_dataset_create(id);

    }



    ADM_job_requirements_t reqs = ADM_job_requirements_create(

            inputs, NINPUTS, outputs, NOUTPUTS, NULL);

    ADM_return_t ret =

            ADM_update_job(server, job, reqs);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

                "ADM_update_job() remote procedure not completed "

                "successfully\n");

        exit_status = EXIT_FAILURE;

        goto cleanup;

    }



    fprintf(stdout, "ADM_update_job() remote procedure completed "

                    "successfully\n");



cleanup:



    ADM_server_destroy(server);

    exit(exit_status);

}
 
 No newline at end of file

examples/c/CMakeLists.txt

+6 −2
Original line number Diff line number Diff line
@@ -27,7 +27,7 @@ list(APPEND examples_c ADM_register_job ADM_cancel_transfer ADM_connect_data_ope 
  ADM_get_statistics ADM_get_transfer_priority #ADM_link_transfer_to_data_operation

  ADM_register_adhoc_storage ADM_remove_adhoc_storage ADM_remove_job ADM_set_dataset_information

  ADM_set_io_resources ADM_set_qos_constraints ADM_set_transfer_priority ADM_transfer_dataset

  ADM_update_adhoc_storage)

  ADM_update_adhoc_storage ADM_update_job)



  # ADM_in_situ_ops ADM_in_transit_ops not implemented
@@ -82,3 +82,7 @@ add_test(ADM_set_transfer_priority_test ADM_set_transfer_priority ofi+tcp://127. 
add_test(ADM_transfer_dataset_test ADM_transfer_dataset ofi+tcp://127.0.0.1:52000 /build/examples /build bandwith distribution 42)



add_test(ADM_update_adhoc_storage_test ADM_update_adhoc_storage ofi+tcp://127.0.0.1:52000 9)



add_test(ADM_update_job_test ADM_update_job ofi+tcp://127.0.0.1:52000 42)



#ADM_update_pfs_storage (missing, not working in cpp. Will be created when they work in cpp)