Unverified Commit f550913b authored by Tommaso Tocci's avatar Tommaso Tocci
Browse files

Cleanup margo_forward_timed wrapper

parent 2d93d2af

ifs/include/preload/rpc/ld_rpc_metadentry.hpp

+0 −4
Original line number Diff line number Diff line
@@ -11,10 +11,6 @@ class OpenDir; 
class Metadata;





inline hg_return_t margo_forward_timed_wrap_timer(hg_handle_t& handle, void* in_struct, const char* func);



inline hg_return_t margo_forward_timed_wrap(hg_handle_t& handle, void* in_struct);



void send_minimal_rpc(hg_id_t minimal_id);



int rpc_send_mk_node(const std::string& path, mode_t mode);

ifs/src/preload/rpc/ld_rpc_metadentry.cpp

+3 −10
Original line number Diff line number Diff line
@@ -9,16 +9,9 @@ 


using namespace std;



inline hg_return_t margo_forward_timed_wrap(hg_handle_t& handle, void* in_struct) {

    hg_return_t ret = HG_OTHER_ERROR;



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

        ret = margo_forward_timed(handle, in_struct, RPC_TIMEOUT);

        if (ret == HG_SUCCESS) {

            break;

        }

    }

    return ret;

static inline hg_return_t

margo_forward_timed_wrap(const hg_handle_t& handle, void* in_struct) {

    return margo_forward_timed(handle, in_struct, RPC_TIMEOUT);

}



int rpc_send_mk_node(const std::string& path, const mode_t mode) {