Verified Commit b9a21350 authored by Alberto Miranda's avatar Alberto Miranda ♨️
Browse files

Fix build errors in forwarding mode

parent ea8e16a1

include/common/rpc/distributor.hpp

+4 −0
Original line number Diff line number Diff line
@@ -131,6 +131,10 @@ public: 
    locate_data(const std::string& path,

                const chunkid_t& chnk_id) const override final;



    host_t

    locate_data(const std::string& path, const chunkid_t& chnk_id,

                unsigned int host_size) override final;



    host_t

    locate_file_metadata(const std::string& path) const override;

src/client/preload_util.cpp

+1 −1
Original line number Diff line number Diff line
@@ -336,7 +336,7 @@ load_forwarding_map() { 
    //    forwarding_map_file));

    //}



    auto local_hostname = get_my_hostname(true);

    auto local_hostname = gkfs::rpc::get_my_hostname(true);



    if(forwarding_map.find(local_hostname) == forwarding_map.end()) {

        throw runtime_error(

src/common/rpc/distributor.cpp

+7 −0
Original line number Diff line number Diff line
@@ -116,6 +116,13 @@ ForwarderDistributor::locate_data(const std::string& path, 
    return fwd_host_;

}



host_t

ForwarderDistributor::locate_data(const std::string& path,

                                  const chunkid_t& chnk_id,

                                  unsigned int host_size) {

    return fwd_host_;

}



host_t

ForwarderDistributor::locate_file_metadata(const std::string& path) const {

    return str_hash(path) % hosts_size_;

src/daemon/handler/srv_data.cpp

+1 −1
Original line number Diff line number Diff line
@@ -184,7 +184,7 @@ rpc_srv_write(hg_handle_t handle) { 
        return gkfs::rpc::cleanup_respond(&handle, &in, &out, &bulk_handle);

    }

    auto const host_id = in.host_id;

    auto const host_size = in.host_size;

    [[maybe_unused]] auto const host_size = in.host_size;



    auto path = make_shared<string>(in.path);

    // chnk_ids used by this host