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

Send metadata RPC

parent 17219a53

include/daemon/handler/rpc_defs.hpp

+2 −0
Original line number Diff line number Diff line
@@ -48,6 +48,8 @@ DECLARE_MARGO_RPC_HANDLER(rpc_srv_mk_symlink) 


DECLARE_MARGO_RPC_HANDLER(rpc_srv_relocation_start)



DECLARE_MARGO_RPC_HANDLER(rpc_srv_relocate_metadata)





// data

DECLARE_MARGO_RPC_HANDLER(rpc_srv_remove_data)

include/global/global_defs.hpp

+2 −0
Original line number Diff line number Diff line
@@ -37,6 +37,8 @@ constexpr auto get_dirents_extended = "rpc_srv_get_dirents_extended"; 
constexpr auto mk_symlink = "rpc_srv_mk_symlink";

#endif

constexpr auto relocation_start = "rpc_srv_relocation_start";

constexpr auto relocate_metadata = "rpc_srv_relocate_metadata";



constexpr auto write = "rpc_srv_write_data";

constexpr auto read = "rpc_srv_read_data";

constexpr auto truncate = "rpc_srv_trunc_data";

include/global/rpc/rpc_types.hpp

+3 −0
Original line number Diff line number Diff line
@@ -102,6 +102,9 @@ MERCURY_GEN_PROC(rpc_config_out_t, 


MERCURY_GEN_PROC(rpc_relocation_start_in_t, ((hg_uint64_t)(host_id)))



MERCURY_GEN_PROC(rpc_relocate_metadata_in_t,

                 ((hg_const_string_t)(key))((hg_const_string_t)(value)))





MERCURY_GEN_PROC(rpc_chunk_stat_in_t, ((hg_int32_t)(dummy)))

src/daemon/CMakeLists.txt

+1 −0
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@ set(DAEMON_SRC 
    handler/srv_data.cpp

    handler/srv_metadata.cpp

    handler/srv_management.cpp

    handler/srv_relocation.cpp

    relocation/config_manager.cpp

    relocation/transmitter.cpp

    )

src/daemon/daemon.cpp

+3 −0
Original line number Diff line number Diff line
@@ -128,6 +128,9 @@ register_server_rpcs(margo_instance_id mid) { 
        MARGO_REGISTER(mid, gkfs::rpc::tag::relocation_start,

                       rpc_relocation_start_in_t, rpc_err_out_t,

                       rpc_srv_relocation_start);

        MARGO_REGISTER(mid, gkfs::rpc::tag::relocate_metadata,

                       rpc_relocate_metadata_in_t, rpc_err_out_t,

                       rpc_srv_relocate_metadata);

    }

}