Loading src/common/rpc/distributor.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -209,7 +209,8 @@ GuidedDistributor::locate_data(const string& path, for(auto const& it : prefix_list) { if(0 == path.compare(0, min(it.length(), path.length()), it, 0, min(it.length(), path.length()))) {} min(it.length(), path.length()))) { } return str_hash(path) % hosts_size_; } Loading src/daemon/daemon.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -165,7 +165,8 @@ init_rpc_server() { struct margo_init_info args = {nullptr}; args.json_config = margo_config.c_str(); args.hg_init_info = &hg_options; auto* mid = margo_init_ext(GKFS_DATA->bind_addr().c_str(), MARGO_SERVER_MODE, &args); auto* mid = margo_init_ext(GKFS_DATA->bind_addr().c_str(), MARGO_SERVER_MODE, &args); if(mid == MARGO_INSTANCE_NULL) { throw runtime_error("Failed to initialize the Margo RPC server"); Loading Loading
src/common/rpc/distributor.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -209,7 +209,8 @@ GuidedDistributor::locate_data(const string& path, for(auto const& it : prefix_list) { if(0 == path.compare(0, min(it.length(), path.length()), it, 0, min(it.length(), path.length()))) {} min(it.length(), path.length()))) { } return str_hash(path) % hosts_size_; } Loading
src/daemon/daemon.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -165,7 +165,8 @@ init_rpc_server() { struct margo_init_info args = {nullptr}; args.json_config = margo_config.c_str(); args.hg_init_info = &hg_options; auto* mid = margo_init_ext(GKFS_DATA->bind_addr().c_str(), MARGO_SERVER_MODE, &args); auto* mid = margo_init_ext(GKFS_DATA->bind_addr().c_str(), MARGO_SERVER_MODE, &args); if(mid == MARGO_INSTANCE_NULL) { throw runtime_error("Failed to initialize the Margo RPC server"); Loading