diff options
author | Claudius 'keldu' Holeksa <mail@keldu.de> | 2024-10-22 14:24:32 +0200 |
---|---|---|
committer | Claudius 'keldu' Holeksa <mail@keldu.de> | 2024-10-22 14:24:32 +0200 |
commit | 98cf3372f2ed4e61ccb0acc522549aaa3d18fd59 (patch) | |
tree | 10f876ed648977c6246496801a4525abf123adf1 /modules/remote/c++ | |
parent | f2a1a3f56768d9aa03796808206f067daa5e0aa0 (diff) |
Fixing interface deduction type
Diffstat (limited to 'modules/remote/c++')
-rw-r--r-- | modules/remote/c++/remote.hpp | 23 | ||||
-rw-r--r-- | modules/remote/c++/remote_loopback.hpp | 10 | ||||
-rw-r--r-- | modules/remote/c++/remote_loopback_base.hpp | 4 |
3 files changed, 28 insertions, 9 deletions
diff --git a/modules/remote/c++/remote.hpp b/modules/remote/c++/remote.hpp index 0f508f5..7e846d3 100644 --- a/modules/remote/c++/remote.hpp +++ b/modules/remote/c++/remote.hpp @@ -84,13 +84,32 @@ class rpc_client; namespace impl { template<typename T, typename Encoding, typename Remote> -struct tmpl_group_to_std_data_server_tuple; +struct tmpl_group_to_data_server_ptr_std_tuple; template<typename... T, typename Encoding, typename Remote> -struct tmpl_group_to_std_data_server_ptr_tuple<tmpl_group<T...>, Encoding, Remote> { +struct tmpl_group_to_data_server_ptr_std_tuple<tmpl_group<T...>, Encoding, Remote> { using type = std::tuple<ptr<data_server<T,Encoding,Remote>>...>; }; } +template<typename Remote> +class i_rpc_server { +protected: + virtual ~i_rpc_server() = default; +public: + virtual std::pair<uint32_t,uint32_t> get_class_id() const = 0; + + template<typename To> + error_or<ptr<To>> cast_to(){ + { + auto rhs = get_class_id(); + if(To::class_id.first == rhs.first && To::class_id.second == rhs.second){ + return {ptr<To>{*static_cast<To*>(this)}}; + } + } + + return make_error<err::invalid_state>("Class IDs are not matching."); + } +}; /** * Implementation of a remote server on the backend diff --git a/modules/remote/c++/remote_loopback.hpp b/modules/remote/c++/remote_loopback.hpp index 8763b68..c651589 100644 --- a/modules/remote/c++/remote_loopback.hpp +++ b/modules/remote/c++/remote_loopback.hpp @@ -58,19 +58,19 @@ class rpc_server<Iface, Encode, rmt::Loopback> { public: using InterfaceT = interface<Iface, Encode>; using TypeGroup = typename schema_iface_type_group<Iface>::Type; - using DataServers = typename impl::tmpl_group_to_data_server_ptr_std_tuple<TypeGroup>::type; + using DataServers = typename impl::tmpl_group_to_data_server_ptr_std_tuple<TypeGroup, Encode, rmt::Loopback>::type; private: ptr<remote<rmt::Loopback>> remote_; - const ptr<remote_address<rmt::Loopback>> addr_; + ptr<remote_address<rmt::Loopback>> addr_; InterfaceT iface_; DataServers dat_srvs_; public: - rpc_server(ptr<remote<rmt::Loopback>> remote__, const remote_address<rmt::Loopback>& addr__, InterfaceT iface__, DataServers data_srvs__): + rpc_server(ptr<remote<rmt::Loopback>> remote__, remote_address<rmt::Loopback>& addr__, InterfaceT iface__, DataServers dat_srvs__): remote_{remote__}, addr_{addr__}, iface_{std::move(iface__)}, - data_srvs_{data_srvs__} + dat_srvs_{dat_srvs__} {} template<string_literal Lit> @@ -78,7 +78,7 @@ public: id< typename schema_member_type<Lit, Iface>::type::Response > - > call(id<schema_member_type<Lit, Iface>::type::Request> id_param){ + > call(id<typename schema_member_type<Lit, Iface>::type::Request> id_param){ return make_error<err::not_implemented>(); } diff --git a/modules/remote/c++/remote_loopback_base.hpp b/modules/remote/c++/remote_loopback_base.hpp index 5664f77..5e5e108 100644 --- a/modules/remote/c++/remote_loopback_base.hpp +++ b/modules/remote/c++/remote_loopback_base.hpp @@ -53,13 +53,13 @@ private: std::map<key_t, ptr<i_rpc_server<rmt::Loopback>>> registered_rpc_servers_; template<typename Iface, typename Encoding, uint64_t I> - error_or<void> find_data_servers_ele(typename rpc_server<Iface,Encoding,rmt::Loopback>::DataServers>& ret_val){ + error_or<void> find_data_servers_ele(typename rpc_server<Iface,Encoding,rmt::Loopback>::DataServers& ret_val){ } template<typename Iface, typename Encoding> error_or<typename rpc_server<Iface, Encoding, rmt::Loopback>::DataServers> find_data_servers(){ - typename rpc_server<Iface,Encoding,rmt::Loopback>::DataServers> ret_val; + typename rpc_server<Iface,Encoding,rmt::Loopback>::DataServers ret_val; |