Commit b1a289de authored by Marc Vef's avatar Marc Vef
Browse files

Added: proper RPC_TIMEOUT configurations

parent 613ad72e

lfs/src/configure.hpp

+1 −0
Original line number Diff line number Diff line
@@ -21,6 +21,7 @@ 


// RPC configuration

#define RPCPORT 4433

#define RPC_TIMEOUT 15000



// Debug configurations

//#define RPC_TEST

lfs/src/rpc/client/c_data.cpp

+1 −1
Original line number Diff line number Diff line
@@ -47,7 +47,7 @@ int rpc_send_write(const size_t recipient, const fuse_ino_t inode, const size_t 


    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }

lfs/src/rpc/client/c_data.hpp

+1 −1
Original line number Diff line number Diff line
@@ -42,7 +42,7 @@ int rpc_send_read(const size_t recipient, const fuse_ino_t inode, const size_t i 


    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }

lfs/src/rpc/client/c_dentry.cpp

+3 −3
Original line number Diff line number Diff line
@@ -31,7 +31,7 @@ int rpc_send_lookup(const size_t recipient, const fuse_ino_t parent, const char* 
    }

    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }
@@ -80,7 +80,7 @@ int rpc_send_create_dentry(const size_t recipient, const fuse_ino_t parent, cons 
    }

    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }
@@ -128,7 +128,7 @@ int rpc_send_remove_dentry(const size_t recipient, const fuse_ino_t parent, cons 
    }

    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }

lfs/src/rpc/client/c_metadata.cpp

+3 −3
Original line number Diff line number Diff line
@@ -130,7 +130,7 @@ int rpc_send_create_mdata(const size_t recipient, const uid_t uid, const gid_t g 
    }

    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }
@@ -172,7 +172,7 @@ int rpc_send_get_attr(const size_t recipient, const fuse_ino_t inode, struct sta 
    }

    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }
@@ -226,7 +226,7 @@ int rpc_send_remove_mdata(const size_t recipient, const fuse_ino_t del_inode) { 
    }

    int send_ret = HG_FALSE;

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

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, 15000);

        send_ret = margo_forward_timed(RPC_DATA->client_mid(), handle, &in, RPC_TIMEOUT);

        if (send_ret == HG_SUCCESS) {

            break;

        }