Loading src/daemon/relocation/transmitter.cpp +3 −1 Original line number Diff line number Diff line Loading @@ -50,12 +50,14 @@ transmit_metadata_and_data(gkfs::rpc::host_t localhost) { GKFS_DATA->distributor(distributor); } auto hosts = read_hosts_file(); auto mid = RPC_DATA->client_rpc_mid(); auto relocate_metadata_id = gkfs::rpc::get_rpc_id(mid, gkfs::rpc::tag::relocate_metadata); auto& distributor = *(GKFS_DATA->distributor()); auto hosts = dynamic_cast<gkfs::rpc::RandomSlicingDistributor*>(&distributor) ->get_hosts_map(); cout << fmt::format("Got host_id = {} and parsed {} hosts.\n", localhost, hosts.size()); Loading Loading
src/daemon/relocation/transmitter.cpp +3 −1 Original line number Diff line number Diff line Loading @@ -50,12 +50,14 @@ transmit_metadata_and_data(gkfs::rpc::host_t localhost) { GKFS_DATA->distributor(distributor); } auto hosts = read_hosts_file(); auto mid = RPC_DATA->client_rpc_mid(); auto relocate_metadata_id = gkfs::rpc::get_rpc_id(mid, gkfs::rpc::tag::relocate_metadata); auto& distributor = *(GKFS_DATA->distributor()); auto hosts = dynamic_cast<gkfs::rpc::RandomSlicingDistributor*>(&distributor) ->get_hosts_map(); cout << fmt::format("Got host_id = {} and parsed {} hosts.\n", localhost, hosts.size()); Loading