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

RPCs test in c++ implemented -first version-

parent b2c1ddb9

examples/cxx/ADM_define_data_operation.cpp

+1 −1
Original line number Diff line number Diff line
@@ -16,7 +16,7 @@ main(int argc, char* argv[]) { 
    admire::server server{"tcp", argv[1]};



    ADM_job_t job{};

    const char* path = "";

    const char* path = "/tmpxxxxx";

    ADM_data_operation_t op_handle;

    va_list args; // FIXME: placeholder

    ADM_return_t ret = ADM_SUCCESS;

examples/cxx/CMakeLists.txt

+12 −6
Original line number Diff line number Diff line
@@ -50,9 +50,9 @@ add_test(ADM_ping_test ADM_ping ofi+tcp://127.0.0.1:52000) 


add_test(ADM_cancel_transfer_test ADM_cancel_transfer ofi+tcp://127.0.0.1:52000 42)



add_test(ADM_connect_data_operation_test ADM_connect_data_operation ofi+tcp://127.0.0.1:52000 42 ofi+tcp://127.0.0.1:52000 ofi+tcp://127.0.0.1:52000 true arguments 10)

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 " " 42 arguments)

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)
@@ -72,20 +72,26 @@ add_test(ADM_register_adhoc_storage_test ADM_register_adhoc_storage ofi+tcp://12 


add_test(ADM_register_job_test ADM_register_job ofi+tcp://127.0.0.1:52000 42)



add_test(ADM_register_pfs_storage_test ADM_register_pfs_storage ofi+tcp://127.0.0.1:52000 42)



add_test(ADM_remove_adhoc_storage_test ADM_remove_adhoc_storage ofi+tcp://127.0.0.1:52000 42)



add_test(ADM_remove_job_test ADM_remove_job ofi+tcp://127.0.0.1:52000 42)



add_test(ADM_set_dataset_information_test ADM_set_dataset_information ofi+tcp://127.0.0.1:52000 5 "info" 42)

add_test(ADM_remove_pfs_storage_test ADM_remove_pfs_storage ofi+tcp://127.0.0.1:52000 42)



add_test(ADM_set_dataset_information_test ADM_set_dataset_information ofi+tcp://127.0.0.1:52000 5 info 42)



add_test(ADM_set_io_resources_test ADM_set_io_resources ofi+tcp://127.0.0.1:52000 4 resources 42)



add_test(ADM_set_qos_constraints_test ADM_set_qos_constraints ofi+tcp://127.0.0.1:52000 "dataset" "bandwith" 7 "iops")

add_test(ADM_set_qos_constraints_test ADM_set_qos_constraints ofi+tcp://127.0.0.1:52000 dataset bandwith 7 iops)



add_test(ADM_set_transfer_priority_test ADM_set_transfer_priority ofi+tcp://127.0.0.1:52000 9 2)



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 2)

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)



add_test(ADM_update_pfs_storage_test ADM_update_pfs_storage ofi+tcp://127.0.0.1:52000 42)
 
 No newline at end of file

src/lib/admire.cpp

+24 −0
Original line number Diff line number Diff line
@@ -427,6 +427,11 @@ transfer_dataset(const server& srv, ADM_job_t job, ADM_dataset_t** sources, 
    ADM_transfer_dataset_in_t in{};

    ADM_transfer_dataset_out_t out;



    in.source = "/tmp";

    in.destination = "/tmp";

    in.qos_constraints = "constraints";

    in.distribution = "distribution";



    endp.call("ADM_transfer_dataset", &in, &out);



    if(out.ret < 0) {
@@ -455,6 +460,8 @@ set_dataset_information(const server& srv, ADM_job_t job, ADM_dataset_t target, 
    ADM_set_dataset_information_in_t in{};

    ADM_set_dataset_information_out_t out;



    in.info = "info";



    endp.call("ADM_set_dataset_information", &in, &out);



    if(out.ret < 0) {
@@ -483,6 +490,8 @@ set_io_resources(const server& srv, ADM_job_t job, ADM_storage_t tier, 
    ADM_set_io_resources_in_t in{};

    ADM_set_io_resources_out_t out;



    in.resources = "resources";



    endp.call("ADM_set_io_resources", &in, &out);



    if(out.ret < 0) {
@@ -623,6 +632,10 @@ set_qos_constraints(const server& srv, ADM_job_t job, ADM_qos_entity_t entity, 
    ADM_set_qos_constraints_in_t in{};

    ADM_set_qos_constraints_out_t out;



    in.scope = "dataset";

    in.qos_class = "class";

    in.class_value = "value";



    endp.call("ADM_set_qos_constraints", &in, &out);



    if(out.ret < 0) {
@@ -652,6 +665,8 @@ get_qos_constraints(const server& srv, ADM_job_t job, ADM_qos_entity_t entity, 
    ADM_get_qos_constraints_in_t in{};

    ADM_get_qos_constraints_out_t out;



    in.scope = "dataset";



    endp.call("ADM_get_qos_constraints", &in, &out);



    if(out.ret < 0) {
@@ -682,6 +697,10 @@ define_data_operation(const server& srv, ADM_job_t job, const char* path, 
    ADM_define_data_operation_in_t in{};

    ADM_define_data_operation_out_t out;



    in.path = path;

    in.operation_id = 1;

    in.arguments = "argument1 argument2";



    endp.call("ADM_define_data_operation", &in, &out);



    if(out.ret < 0) {
@@ -713,6 +732,9 @@ connect_data_operation(const server& srv, ADM_job_t job, ADM_dataset_t input, 
    ADM_connect_data_operation_in_t in{};

    ADM_connect_data_operation_out_t out;



    in.input="/tmp";

    in.arguments = "argument1 argument2";



    endp.call("ADM_connect_data_operation", &in, &out);



    if(out.ret < 0) {
@@ -774,6 +796,8 @@ link_transfer_to_data_operation(const server& srv, ADM_job_t job, 
    ADM_link_transfer_to_data_operation_in_t in{};

    ADM_link_transfer_to_data_operation_out_t out;



    in.arguments = "argument1 argument2";



    endp.call("ADM_link_transfer_to_data_operation", &in, &out);



    if(out.ret < 0) {