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

ADM_deploy_adhoc_storage ADM_finalize_data_operation and ADM_get_pending_transfers c test added

parent d9b68b3f
Loading
Loading
Loading
Loading
+38 −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 != 3) {
        fprintf(stderr, "ERROR: no location provided\n");
        fprintf(stderr, "Usage: ADM_deploy_adhoc_storage <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_storage_t adhoc_storage;

    ADM_return_t ret = ADM_SUCCESS;


    if(ret != ADM_SUCCESS) {
        fprintf(stdout, "ADM_deploy_adhoc_storage() remote procedure not completed "
                        "successfully\n");
        exit_status = EXIT_FAILURE;
        goto cleanup;
    }

    fprintf(stdout, "ADM_deploy_adhoc_storage() remote procedure completed "
                    "successfully\n");

cleanup:

    ADM_server_destroy(server);
    exit(exit_status);
}
 No newline at end of file
+38 −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 != 3) {
        fprintf(stderr, "ERROR: no location provided\n");
        fprintf(stderr, "Usage: ADM_finalize_data_operation <REMOTE_IP> <OPERATION_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_data_operation_status_t status;

    ADM_return_t ret = ADM_SUCCESS;


    if(ret != ADM_SUCCESS) {
        fprintf(stdout, "ADM_finalize_data_operation() remote procedure not completed "
                        "successfully\n");
        exit_status = EXIT_FAILURE;
        goto cleanup;
    }

    fprintf(stdout, "ADM_finalize_data_operation() remote procedure completed "
                    "successfully\n");

cleanup:

    ADM_server_destroy(server);
    exit(exit_status);
}
 No newline at end of file
+37 −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 != 2) {
        fprintf(stderr, "ERROR: no location provided\n");
        fprintf(stderr, "Usage: ADM_get_pending_transfers <REMOTE_IP>\n");
        exit(EXIT_FAILURE);
    }

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

    ADM_job_t job;
    ADM_transfer_t** tx_handles = NULL;

    ADM_return_t ret = ADM_SUCCESS;


    if(ret != ADM_SUCCESS) {
        fprintf(stdout, "ADM_get_pending_transfers() remote procedure not completed "
                        "successfully\n");
        exit_status = EXIT_FAILURE;
        goto cleanup;
    }

    fprintf(stdout, "ADM_get_pending_transfers() remote procedure completed "
                    "successfully\n");

cleanup:

    ADM_server_destroy(server);
    exit(exit_status);
}
 No newline at end of file
+18 −11
Original line number Diff line number Diff line
@@ -22,7 +22,8 @@
# SPDX-License-Identifier: GPL-3.0-or-later                                    #
# ###############################################################################

list(APPEND examples_c ADM_register_job ADM_cancel_transfer ADM_connect_data_operation ADM_define_data_operation)
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)

foreach(example IN LISTS examples_c)
  add_executable(${example}_c)
@@ -40,3 +41,9 @@ add_test(ADM_cancel_transfer_test ADM_cancel_transfer ofi+tcp://127.0.0.1:52000
add_test(ADM_connect_data_operation_test ADM_connect_data_operation ofi+tcp://127.0.0.1:52000 42 /tmp true arguments 10)

add_test(ADM_define_data_operation_test ADM_define_data_operation ofi+tcp://127.0.0.1:52000 /tmp 42 arguments)

add_test(ADM_deploy_adhoc_storage_test ADM_deploy_adhoc_storage ofi+tcp://127.0.0.1:52000 42)

add_test(ADM_finalize_data_operation_test ADM_finalize_data_operation ofi+tcp://127.0.0.1:52000 42)

add_test(ADM_get_pending_transfers_test ADM_get_pending_transfers ofi+tcp://127.0.0.1:52000)
 No newline at end of file