Added Proxy lseek() support for Client <-> Proxy (a57cdc22) · Commits · hpc / gekkofs

include/client/rpc/forward_metadata_proxy.hpp

+3 −0

Original line number	Diff line number	Diff line
		@@ -33,6 +33,9 @@ forward_update_metadentry_size_proxy(const std::string& path, const size_t size,
		const off64_t offset,
		const bool append_flag);

		std::pair<int, off64_t>
		forward_get_metadentry_size_proxy(const std::string& path);

		std::pair<int, std::vector<std::tuple<const std::string, bool, size_t, time_t>>>
		forward_get_dirents_single_proxy(const std::string& path, int server);

include/client/rpc/rpc_types.hpp

+119 −2

Original line number	Diff line number	Diff line
		@@ -3299,6 +3299,123 @@ struct decr_size_proxy {
		};
		};

		//==============================================================================
		// definitions for get_metadentry_size_proxy
		struct get_metadentry_size_proxy {

		// forward declarations of public input/output types for this RPC
		class input;

		class output;

		// traits used so that the engine knows what to do with the RPC
		using self_type = get_metadentry_size_proxy;
		using handle_type = hermes::rpc_handle<self_type>;
		using input_type = input;
		using output_type = output;
		using mercury_input_type = rpc_path_only_in_t;
		using mercury_output_type = rpc_get_metadentry_size_out_t;

		// RPC public identifier
		// (N.B: we reuse the same IDs assigned by Margo so that the daemon
		// understands Hermes RPCs)
		constexpr static const uint64_t public_id = 28;

		// RPC internal Mercury identifier
		constexpr static const hg_id_t mercury_id = 0;

		// RPC name
		constexpr static const auto name = gkfs::rpc::tag::client_proxy_get_size;

		// requires response?
		constexpr static const auto requires_response = true;

		// Mercury callback to serialize input arguments
		constexpr static const auto mercury_in_proc_cb =
		HG_GEN_PROC_NAME(rpc_path_only_in_t);

		// Mercury callback to serialize output arguments
		constexpr static const auto mercury_out_proc_cb =
		HG_GEN_PROC_NAME(rpc_get_metadentry_size_out_t);

		class input {

		template <typename ExecutionContext>
		friend hg_return_t
		hermes::detail::post_to_mercury(ExecutionContext*);

		public:
		input(const std::string& path) : m_path(path) {}

		input(input&& rhs) = default;

		input(const input& other) = default;

		input&
		operator=(input&& rhs) = default;

		input&
		operator=(const input& other) = default;

		std::string
		path() const {
		return m_path;
		}

		explicit input(const rpc_path_only_in_t& other) : m_path(other.path) {}

		explicit
		operator rpc_path_only_in_t() {
		return {m_path.c_str()};
		}

		private:
		std::string m_path;
		};

		class output {

		template <typename ExecutionContext>
		friend hg_return_t
		hermes::detail::post_to_mercury(ExecutionContext*);

		public:
		output() : m_err(), m_ret_size() {}

		output(int32_t err, int64_t ret_size)
		: m_err(err), m_ret_size(ret_size) {}

		output(output&& rhs) = default;

		output(const output& other) = default;

		output&
		operator=(output&& rhs) = default;

		output&
		operator=(const output& other) = default;

		explicit output(const rpc_get_metadentry_size_out_t& out) {
		m_err = out.err;
		m_ret_size = out.ret_size;
		}

		int32_t
		err() const {
		return m_err;
		}

		int64_t
		ret_size() const {
		return m_ret_size;
		}

		private:
		int32_t m_err;
		int64_t m_ret_size;
		};
		};

		//==============================================================================
		// definitions for update_metadentry_size
		struct update_metadentry_size_proxy {
		@@ -3319,7 +3436,7 @@ struct update_metadentry_size_proxy {
		// RPC public identifier
		// (N.B: we reuse the same IDs assigned by Margo so that the daemon
		// understands Hermes RPCs)
		constexpr static const uint64_t public_id = 28;
		constexpr static const uint64_t public_id = 29;

		// RPC internal Mercury identifier
		constexpr static const hg_id_t mercury_id = 0;
		@@ -3458,7 +3575,7 @@ struct get_dirents_extended_proxy {
		// RPC public identifier
		// (N.B: we reuse the same IDs assigned by Margo so that the daemon
		// understands Hermes RPCs)
		constexpr static const uint64_t public_id = 29;
		constexpr static const uint64_t public_id = 30;

		// RPC internal Mercury identifier
		constexpr static const hg_id_t mercury_id = 0;

include/common/common_defs.hpp

+1 −0

Original line number	Diff line number	Diff line
		@@ -66,6 +66,7 @@ constexpr auto client_proxy_create = "proxy_rpc_srv_create";
		constexpr auto client_proxy_stat = "proxy_rpc_srv_stat";
		constexpr auto client_proxy_remove = "proxy_rpc_srv_remove";
		constexpr auto client_proxy_decr_size = "proxy_rpc_srv_decr_size";
		constexpr auto client_proxy_get_size = "proxy_rpc_srv_get_metadentry_size";
		constexpr auto client_proxy_update_size =
		"proxy_rpc_srv_update_metadentry_size";
		constexpr auto client_proxy_write = "proxy_rpc_srv_write_data";

include/config.hpp

+1 −0

Original line number	Diff line number	Diff line
		@@ -122,6 +122,7 @@ constexpr auto pid_path = "/tmp/gkfs_proxy.pid";
		constexpr auto fwd_create = true;
		constexpr auto fwd_stat = true;
		constexpr auto fwd_remove = true;
		constexpr auto fwd_get_size = true;
		constexpr auto fwd_update_size = true;
		constexpr auto fwd_io = true;
		constexpr auto fwd_truncate = true;

include/proxy/rpc/forward_metadata.hpp

+3 −0

Original line number	Diff line number	Diff line
		@@ -30,6 +30,9 @@ forward_remove(const std::string& path);
		int
		forward_decr_size(const std::string& path, size_t length);

		std::pair<int, off64_t>
		forward_get_metadentry_size(const std::string& path);

		std::pair<int, off64_t>
		forward_update_metadentry_size(const std::string& path, const size_t size,
		const off64_t offset, const bool append_flag);