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

ADM_link_transfer_to_data_operation fixed in c and cpp test

parent 65cdfc2d

examples/c/ADM_link_transfer_to_data_operation.c

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

#include <stdio.h>

#include <admire.h>



int

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



    if(argc != 7) {

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

        fprintf(stderr,

                "Usage: ADM_link_transfer_to_data_operation <REMOTE_IP> <OPERATION_ID> <TRANSFER_ID> <STREAM> <ARGUMENTS> <JOB_ID>\n");

        exit(EXIT_FAILURE);

    }



    int exit_status = EXIT_SUCCESS;

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



    ADM_job_t job;

    ADM_data_operation_t op_handle;

    ADM_transfer_t transfer;

    bool should_stream = false;

    va_list args;

    ADM_return_t ret = ADM_link_transfer_to_data_operation(

            server, job, op_handle, transfer, should_stream, args);



    if(ret != ADM_SUCCESS) {

        fprintf(stdout,

                "ADM_link_transfer_to_data_operation() remote procedure not completed "

                "successfully\n");

        exit_status = EXIT_FAILURE;

        goto cleanup;

    }



    fprintf(stdout,

            "ADM_link_transfer_to_data_operation() remote procedure completed "

            "successfully\n");



cleanup:



    ADM_server_destroy(server);

    exit(exit_status);

}
 
 No newline at end of file

examples/c/CMakeLists.txt

+2 −2
Original line number Diff line number Diff line
@@ -24,7 +24,7 @@ 


list(APPEND examples_c ADM_register_job ADM_cancel_transfer ADM_connect_data_operation ADM_define_data_operation

  ADM_deploy_adhoc_storage ADM_finalize_data_operation ADM_get_pending_transfers ADM_get_qos_constraints

  ADM_get_statistics ADM_get_transfer_priority #ADM_link_transfer_to_data_operation

  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_job)
@@ -60,7 +60,7 @@ add_test(ADM_get_statistics_test ADM_get_statistics ofi+tcp://127.0.0.1:52000 42 


add_test(ADM_get_transfer_priority_test ADM_get_transfer_priority ofi+tcp://127.0.0.1:52000 8)



#add_test(ADM_link_transfer_to_data_operation_test ADM_link_transfer_to_data_operation ofi+tcp://127.0.0.1:52000 8 2 dataset arguments 42)

add_test(ADM_link_transfer_to_data_operation_test ADM_link_transfer_to_data_operation ofi+tcp://127.0.0.1:52000 8 2 dataset arguments 42)



add_test(ADM_register_adhoc_storage_test ADM_register_adhoc_storage ofi+tcp://127.0.0.1:52000 42)

examples/cxx/ADM_link_transfer_to_data_operation.cpp

+2 −1
Original line number Diff line number Diff line
@@ -18,10 +18,11 @@ main(int argc, char* argv[]) { 
    ADM_data_operation_t op_handle{};

    bool should_stream = false;

    va_list args;

    ADM_transfer_t transfer;

    ADM_return_t ret = ADM_SUCCESS;



    try {

        ret = admire::link_transfer_to_data_operation(server, job, op_handle,

        ret = admire::link_transfer_to_data_operation(server, job, op_handle, transfer,

                                                      should_stream, args);

    } catch(const std::exception& e) {

        fmt::print(stderr, "FATAL: ADM_cancel_transfer() failed: {}\n",