Commit 081f02e7 authored by Ramon Nou's avatar Ramon Nou
Browse files

added RPC

parent 75f9cde3

ci/check_rpcs.py

+1 −1
Original line number Diff line number Diff line
@@ -19,7 +19,7 @@ RPC_NAMES = { 
    'ADM_remove_pfs_storage',

    'ADM_transfer_datasets', 'ADM_get_transfer_priority',

    'ADM_set_transfer_priority', 'ADM_cancel_transfer',

    'ADM_get_pending_transfers',

    'ADM_get_pending_transfers', 'ADM_transfer_update',

    'ADM_set_qos_constraints', 'ADM_get_qos_constraints',

    'ADM_define_data_operation', 'ADM_connect_data_operation',

    'ADM_finalize_data_operation',

examples/cxx/ADM_transfer_update.cpp

+1 −1
Original line number Diff line number Diff line
@@ -77,7 +77,7 @@ main(int argc, char* argv[]) { 
                server, job, sources, targets, qos_limits, mapping);





        scord::transfer_update(server, transfer, 10.0f);

        scord::transfer_update(server, transfer.id(), 10.0f);

        fmt::print(stdout, "ADM_transfer_update remote procedure completed "

                           "successfully\n");

        exit(EXIT_SUCCESS);

src/lib/c_wrapper.cpp

+3 −3
Original line number Diff line number Diff line
@@ -246,11 +246,11 @@ ADM_transfer_datasets(ADM_server_t server, ADM_job_t job, 
}



ADM_return_t

ADM_transfer_update(ADM_server_t server, ADM_transfer_t transfer,

ADM_transfer_update(ADM_server_t server, uint64_t transfer_id,

                    float obtained_bw) {



    return scord::detail::transfer_update(

            scord::server{server}, scord::transfer{transfer}, obtained_bw);

    return scord::detail::transfer_update(scord::server{server}, transfer_id,

                                          obtained_bw);

}

src/lib/detail/impl.cpp

+4 −4
Original line number Diff line number Diff line
@@ -532,8 +532,7 @@ transfer_datasets(const server& srv, const job& job, 




scord::error_code

transfer_update(const server& srv, scord::transfer transfer,

                float obtained_bw) {

transfer_update(const server& srv, uint64_t transfer_id, float obtained_bw) {



    network::client rpc_client{srv.protocol()};
@@ -543,9 +542,10 @@ transfer_update(const server& srv, scord::transfer transfer, 
       lookup_rv.has_value()) {

        const auto& endp = lookup_rv.value();



        LOGGER_INFO("rpc {:<} body: {{transfer_id: {}}}", rpc, transfer.id());

        LOGGER_INFO("rpc {:<} body: {{transfer_id: {}}}", rpc, transfer_id);



        if(const auto& call_rv = endp.call(rpc.name(), transfer, obtained_bw);

        if(const auto& call_rv =

                   endp.call(rpc.name(), transfer_id, obtained_bw);

           call_rv.has_value()) {



            const network::generic_response resp{call_rv.value()};

src/lib/detail/impl.hpp

+1 −1
Original line number Diff line number Diff line
@@ -87,7 +87,7 @@ transfer_datasets(const server& srv, const job& job, 
                  transfer::mapping mapping);



scord::error_code

transfer_update(const server& srv, scord::transfer transfer, float obtained_bw);

transfer_update(const server& srv, uint64_t transfer_id, float obtained_bw);





} // namespace scord::detail