Loading src/daemon/handler/srv_data.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -109,7 +109,7 @@ rpc_srv_write(hg_handle_t handle) { return gkfs::rpc::cleanup_respond(&handle, &in, &out, &bulk_handle); } auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug( "{}() path: '{}' chunk_start '{}' chunk_end '{}' chunk_n '{}' total_chunk_size '{}' bulk_size: '{}' offset: '{}'", Loading Loading @@ -412,7 +412,7 @@ rpc_srv_read(hg_handle_t handle) { return gkfs::rpc::cleanup_respond(&handle, &in, &out, &bulk_handle); } auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug( Loading src/daemon/handler/srv_metadata.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -537,7 +537,7 @@ rpc_srv_get_dirents(hg_handle_t handle) { // Retrieve size of source buffer auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug("{}() Got RPC: path '{}' bulk_size '{}' ", __func__, in.path, bulk_size); Loading Loading @@ -696,7 +696,7 @@ rpc_srv_get_dirents_extended(hg_handle_t handle) { // Retrieve size of source buffer auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug("{}() Got RPC: path '{}' bulk_size '{}' ", __func__, in.path, bulk_size); Loading Loading
src/daemon/handler/srv_data.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -109,7 +109,7 @@ rpc_srv_write(hg_handle_t handle) { return gkfs::rpc::cleanup_respond(&handle, &in, &out, &bulk_handle); } auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug( "{}() path: '{}' chunk_start '{}' chunk_end '{}' chunk_n '{}' total_chunk_size '{}' bulk_size: '{}' offset: '{}'", Loading Loading @@ -412,7 +412,7 @@ rpc_srv_read(hg_handle_t handle) { return gkfs::rpc::cleanup_respond(&handle, &in, &out, &bulk_handle); } auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug( Loading
src/daemon/handler/srv_metadata.cpp +2 −2 Original line number Diff line number Diff line Loading @@ -537,7 +537,7 @@ rpc_srv_get_dirents(hg_handle_t handle) { // Retrieve size of source buffer auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug("{}() Got RPC: path '{}' bulk_size '{}' ", __func__, in.path, bulk_size); Loading Loading @@ -696,7 +696,7 @@ rpc_srv_get_dirents_extended(hg_handle_t handle) { // Retrieve size of source buffer auto hgi = margo_get_info(handle); auto mid = margo_hg_info_get_instance(hgi); auto mid = margo_hg_handle_get_instance(handle); auto bulk_size = margo_bulk_get_size(in.bulk_handle); GKFS_DATA->spdlogger()->debug("{}() Got RPC: path '{}' bulk_size '{}' ", __func__, in.path, bulk_size); Loading