Commit 7450d163 authored by David Auer's avatar David Auer
Browse files

Refactor transmitter

parent ba7bf254

src/daemon/relocation/transmitter.cpp

+6 −6
Original line number Diff line number Diff line
@@ -62,12 +62,12 @@ transmit_metadata_and_data(gkfs::rpc::host_t localhost) { 
                        hosts.size());



    // Relocate metadata

    for(auto metadentry : GKFS_DATA->mdb()->get_all()) {

        if(metadentry.first == "/") {

    for(const auto& [metakey, metavalue] : GKFS_DATA->mdb()->get_all()) {

        if(metakey == "/") {

            continue;

        }

        auto destination = distributor.locate_file_metadata(metadentry.first);

        cout << "Metadentry " << metadentry.first << " : " << metadentry.second

        auto destination = distributor.locate_file_metadata(metakey);

        cout << "Metadentry " << metakey << " : " << metavalue

             << (destination == localhost

                         ? " Stay"

                         : " -> Goto "s + std::to_string(destination))
@@ -81,8 +81,8 @@ transmit_metadata_and_data(gkfs::rpc::host_t localhost) { 
        rpc_err_out_t out{};

        hg_addr_t host_addr{};



        in.key = metadentry.first.c_str();

        in.value = metadentry.second.c_str();

        in.key = metakey.c_str();

        in.value = metavalue.c_str();



        auto ret = margo_addr_lookup(mid, hosts[destination].second.c_str(),

                                     &host_addr);