Commit c1cf3760 authored by David Auer's avatar David Auer
Browse files

Write and delete metadata on relocation

parent f3c87e4d

src/daemon/handler/srv_relocation.cpp

+3 −0
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@ 




#include <daemon/daemon.hpp>

#include <daemon/backend/metadata/db.hpp>

#include <daemon/handler/rpc_defs.hpp>

#include <daemon/handler/rpc_util.hpp>

// #include <daemon/backend/metadata/db.hpp>
@@ -53,6 +54,8 @@ rpc_srv_relocate_metadata(hg_handle_t handle) { 
    cout << fmt::format("TODO Received metadata entry {}: {}\n", in.key,

                        in.value);



    GKFS_DATA->mdb()->put(in.key, in.value);



    out.err = 0; // TODO

    return gkfs::rpc::cleanup_respond(&handle, &in, &out);

}

src/daemon/relocation/transmitter.cpp

+1 −0
Original line number Diff line number Diff line
@@ -80,6 +80,7 @@ transmit_metadata(gkfs::rpc::host_t localhost) { 
        assert(ret == HG_SUCCESS);



        // TODO process output

        GKFS_DATA->mdb()->remove(in.key);



        ret = margo_free_output(handle, &out);

        assert(ret == HG_SUCCESS);