Loading lfs/CMakeLists.txt +1 −1 Original line number Diff line number Diff line Loading @@ -2,7 +2,7 @@ cmake_minimum_required(VERSION 3.4 FATAL_ERROR) project(lfs VERSION 0.0.1) set(CMAKE_CXX_STANDARD 14) set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -D_FILE_OFFSET_BITS=64") set(CMAKE_CXX_FLAGS_RELEASE "${CMAKE_CXX_FLAGS} -D_FILE_OFFSET_BITS=64") set(CMAKE_CXX_FLAGS_DEBUG "${CMAKE_CXX_FLAGS_DEBUG} -Wall --pedantic -g -pg") set(CMAKE_MODULE_PATH "${CMAKE_CURRENT_SOURCE_DIR}/CMake" ${CMAKE_MODULE_PATH}) Loading lfs/src/rpc/server/s_dentry.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -16,7 +16,7 @@ static hg_return_t rpc_srv_lookup(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got lookup RPC with filename {}", in.filename); ADAFS_DATA->spdlogger()->debug("Got lookup RPC with filename {}", in.filename); hgi = HG_Get_info(handle); Loading Loading @@ -50,7 +50,7 @@ static hg_return_t rpc_srv_create_dentry(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got create dentry RPC with filename {}", in.filename); ADAFS_DATA->spdlogger()->debug("Got create dentry RPC with filename {}", in.filename); hgi = HG_Get_info(handle); Loading Loading @@ -84,7 +84,7 @@ static hg_return_t rpc_srv_remove_dentry(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got remove dentry RPC with filename {}", in.filename); ADAFS_DATA->spdlogger()->debug("Got remove dentry RPC with filename {}", in.filename); hgi = HG_Get_info(handle); Loading lfs/src/rpc/server/s_metadata.cpp +4 −4 Original line number Diff line number Diff line Loading @@ -13,7 +13,7 @@ static hg_return_t rpc_minimal(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got simple RPC with input {}", in.input); ADAFS_DATA->spdlogger()->debug("Got simple RPC with input {}", in.input); // Get hg_info handle hgi = HG_Get_info(handle); // extract margo id from hg_info (needed to know where to send response) Loading Loading @@ -41,7 +41,7 @@ static hg_return_t rpc_srv_create_mdata(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got create mdata RPC with inode {}", in.inode); ADAFS_DATA->spdlogger()->debug("Got create mdata RPC with inode {}", in.inode); hgi = HG_Get_info(handle); Loading Loading @@ -71,7 +71,7 @@ static hg_return_t rpc_srv_attr(hg_handle_t handle) { const struct hg_info* hgi; auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got get attr RPC with inode {}", in.inode); ADAFS_DATA->spdlogger()->debug("Got get attr RPC with inode {}", in.inode); hgi = HG_Get_info(handle); auto mid = margo_hg_class_to_instance(hgi->hg_class); // get the metadata Loading Loading @@ -108,7 +108,7 @@ static hg_return_t rpc_srv_remove_mdata(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got remove mdata RPC with inode {}", in.del_inode); ADAFS_DATA->spdlogger()->debug("Got remove mdata RPC with inode {}", in.del_inode); hgi = HG_Get_info(handle); Loading Loading
lfs/CMakeLists.txt +1 −1 Original line number Diff line number Diff line Loading @@ -2,7 +2,7 @@ cmake_minimum_required(VERSION 3.4 FATAL_ERROR) project(lfs VERSION 0.0.1) set(CMAKE_CXX_STANDARD 14) set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -D_FILE_OFFSET_BITS=64") set(CMAKE_CXX_FLAGS_RELEASE "${CMAKE_CXX_FLAGS} -D_FILE_OFFSET_BITS=64") set(CMAKE_CXX_FLAGS_DEBUG "${CMAKE_CXX_FLAGS_DEBUG} -Wall --pedantic -g -pg") set(CMAKE_MODULE_PATH "${CMAKE_CURRENT_SOURCE_DIR}/CMake" ${CMAKE_MODULE_PATH}) Loading
lfs/src/rpc/server/s_dentry.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -16,7 +16,7 @@ static hg_return_t rpc_srv_lookup(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got lookup RPC with filename {}", in.filename); ADAFS_DATA->spdlogger()->debug("Got lookup RPC with filename {}", in.filename); hgi = HG_Get_info(handle); Loading Loading @@ -50,7 +50,7 @@ static hg_return_t rpc_srv_create_dentry(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got create dentry RPC with filename {}", in.filename); ADAFS_DATA->spdlogger()->debug("Got create dentry RPC with filename {}", in.filename); hgi = HG_Get_info(handle); Loading Loading @@ -84,7 +84,7 @@ static hg_return_t rpc_srv_remove_dentry(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got remove dentry RPC with filename {}", in.filename); ADAFS_DATA->spdlogger()->debug("Got remove dentry RPC with filename {}", in.filename); hgi = HG_Get_info(handle); Loading
lfs/src/rpc/server/s_metadata.cpp +4 −4 Original line number Diff line number Diff line Loading @@ -13,7 +13,7 @@ static hg_return_t rpc_minimal(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got simple RPC with input {}", in.input); ADAFS_DATA->spdlogger()->debug("Got simple RPC with input {}", in.input); // Get hg_info handle hgi = HG_Get_info(handle); // extract margo id from hg_info (needed to know where to send response) Loading Loading @@ -41,7 +41,7 @@ static hg_return_t rpc_srv_create_mdata(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got create mdata RPC with inode {}", in.inode); ADAFS_DATA->spdlogger()->debug("Got create mdata RPC with inode {}", in.inode); hgi = HG_Get_info(handle); Loading Loading @@ -71,7 +71,7 @@ static hg_return_t rpc_srv_attr(hg_handle_t handle) { const struct hg_info* hgi; auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got get attr RPC with inode {}", in.inode); ADAFS_DATA->spdlogger()->debug("Got get attr RPC with inode {}", in.inode); hgi = HG_Get_info(handle); auto mid = margo_hg_class_to_instance(hgi->hg_class); // get the metadata Loading Loading @@ -108,7 +108,7 @@ static hg_return_t rpc_srv_remove_mdata(hg_handle_t handle) { auto ret = HG_Get_input(handle, &in); assert(ret == HG_SUCCESS); ADAFS_DATA->spdlogger()->info("Got remove mdata RPC with inode {}", in.del_inode); ADAFS_DATA->spdlogger()->debug("Got remove mdata RPC with inode {}", in.del_inode); hgi = HG_Get_info(handle); Loading