Loading ifs/src/daemon/handler/h_data.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -480,6 +480,7 @@ static hg_return_t rpc_srv_trunc_data(hg_handle_t handle) { ADAFS_DATA->spdlogger()->error("{}() Could not get RPC input data with err {}", __func__, ret); throw runtime_error("Failed to get RPC input data"); } ADAFS_DATA->spdlogger()->debug("{}() path: '{}', length: {}", __func__, in.path, in.length); unsigned int chunk_start = chnk_id_for_offset(in.length, CHUNKSIZE); Loading @@ -492,7 +493,7 @@ static hg_return_t rpc_srv_trunc_data(hg_handle_t handle) { ADAFS_DATA->storage()->trim_chunk_space(in.path, chunk_start); ADAFS_DATA->spdlogger()->debug("Sending output {}", out.err); ADAFS_DATA->spdlogger()->debug("{}() Sending output {}", __func__, out.err); auto hret = margo_respond(handle, &out); if (hret != HG_SUCCESS) { ADAFS_DATA->spdlogger()->error("{}() Failed to respond"); Loading ifs/src/daemon/handler/h_metadentry.cpp +3 −4 Original line number Diff line number Diff line Loading @@ -99,7 +99,7 @@ static hg_return_t rpc_srv_stat(hg_handle_t handle) { if (ret != HG_SUCCESS) ADAFS_DATA->spdlogger()->error("{}() Failed to retrieve input from handle", __func__); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->debug("Got srv stat RPC for path {}", in.path); ADAFS_DATA->spdlogger()->debug("{}() path: '{}'", __func__, in.path); std::string val; try { Loading Loading @@ -139,8 +139,7 @@ static hg_return_t rpc_srv_decr_size(hg_handle_t handle) { throw runtime_error("Failed to retrieve input from handle"); } ADAFS_DATA->spdlogger()->debug("Serving decrement size RPC with path: '{}', length: {}", in.path, in.length); ADAFS_DATA->spdlogger()->debug("{}() path: '{}', length: {}", __func__, in.path, in.length); try { ADAFS_DATA->mdb()->decrease_size(in.path, in.length); Loading Loading @@ -270,7 +269,7 @@ static hg_return_t rpc_srv_update_metadentry_size(hg_handle_t handle) { if (ret != HG_SUCCESS) ADAFS_DATA->spdlogger()->error("{}() Failed to retrieve input from handle", __func__); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->debug("{}() Got update metadentry size RPC with path {}", __func__, in.path); ADAFS_DATA->spdlogger()->debug("{}() path: {}, size: {}, offset: {}, append: {}", __func__, in.path, in.size, in.offset, in.append); try { update_metadentry_size(in.path, in.size, in.offset, (in.append == HG_TRUE)); Loading Loading
ifs/src/daemon/handler/h_data.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -480,6 +480,7 @@ static hg_return_t rpc_srv_trunc_data(hg_handle_t handle) { ADAFS_DATA->spdlogger()->error("{}() Could not get RPC input data with err {}", __func__, ret); throw runtime_error("Failed to get RPC input data"); } ADAFS_DATA->spdlogger()->debug("{}() path: '{}', length: {}", __func__, in.path, in.length); unsigned int chunk_start = chnk_id_for_offset(in.length, CHUNKSIZE); Loading @@ -492,7 +493,7 @@ static hg_return_t rpc_srv_trunc_data(hg_handle_t handle) { ADAFS_DATA->storage()->trim_chunk_space(in.path, chunk_start); ADAFS_DATA->spdlogger()->debug("Sending output {}", out.err); ADAFS_DATA->spdlogger()->debug("{}() Sending output {}", __func__, out.err); auto hret = margo_respond(handle, &out); if (hret != HG_SUCCESS) { ADAFS_DATA->spdlogger()->error("{}() Failed to respond"); Loading
ifs/src/daemon/handler/h_metadentry.cpp +3 −4 Original line number Diff line number Diff line Loading @@ -99,7 +99,7 @@ static hg_return_t rpc_srv_stat(hg_handle_t handle) { if (ret != HG_SUCCESS) ADAFS_DATA->spdlogger()->error("{}() Failed to retrieve input from handle", __func__); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->debug("Got srv stat RPC for path {}", in.path); ADAFS_DATA->spdlogger()->debug("{}() path: '{}'", __func__, in.path); std::string val; try { Loading Loading @@ -139,8 +139,7 @@ static hg_return_t rpc_srv_decr_size(hg_handle_t handle) { throw runtime_error("Failed to retrieve input from handle"); } ADAFS_DATA->spdlogger()->debug("Serving decrement size RPC with path: '{}', length: {}", in.path, in.length); ADAFS_DATA->spdlogger()->debug("{}() path: '{}', length: {}", __func__, in.path, in.length); try { ADAFS_DATA->mdb()->decrease_size(in.path, in.length); Loading Loading @@ -270,7 +269,7 @@ static hg_return_t rpc_srv_update_metadentry_size(hg_handle_t handle) { if (ret != HG_SUCCESS) ADAFS_DATA->spdlogger()->error("{}() Failed to retrieve input from handle", __func__); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->debug("{}() Got update metadentry size RPC with path {}", __func__, in.path); ADAFS_DATA->spdlogger()->debug("{}() path: {}, size: {}, offset: {}, append: {}", __func__, in.path, in.size, in.offset, in.append); try { update_metadentry_size(in.path, in.size, in.offset, (in.append == HG_TRUE)); Loading