diff options
Diffstat (limited to 'modules/remote/c++/remote_loopback_base.hpp')
| -rw-r--r-- | modules/remote/c++/remote_loopback_base.hpp | 32 |
1 files changed, 27 insertions, 5 deletions
diff --git a/modules/remote/c++/remote_loopback_base.hpp b/modules/remote/c++/remote_loopback_base.hpp index 7a567b2..d91df37 100644 --- a/modules/remote/c++/remote_loopback_base.hpp +++ b/modules/remote/c++/remote_loopback_base.hpp @@ -53,16 +53,38 @@ 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){ - if + error_or<void> find_data_servers_ele(typename rpc_server<Iface,Encoding,rmt::Loopback>::DataServers& ret_val, ref<remote_address<rmt::Loopback>> addr){ + if constexpr ( I < Iface::size ){ + using DataTypeGroup = typename rpc_server<Iface,Encoding,rmt::Loopback>::TypeGroup; + using Schema = typename tmpl_group_pack_type<I,DataTypeGroup>::type; + + constexpr auto class_id = data_server<Schema, Encoding, rmt::Loopback>::class_id; + key_t key; + key.data = std::array<uint64_t,3>{addr().get_address_id().get(), class_id.first, class_id.second}; + + auto find = registered_data_servers_.find(key); + if(find == registered_data_servers_.end()){ + return make_error<err::not_found>("Server not found"); + } + auto eo_dat_srv = find->second().template cast_to<data_server<Schema, Encoding, rmt::Loopback>>(); + if(eo_dat_srv.is_error()){ + auto& err = eo_dat_srv.get_error(); + return std::move(err); + } + auto dat_srv = eo_dat_srv.get_value(); + std::get<I>(ret_val) = dat_srv; + + return find_data_servers_ele<Iface,Encoding,I+1u>(ret_val, addr); + } + return make_void(); } template<typename Iface, typename Encoding> - error_or<typename rpc_server<Iface, Encoding, rmt::Loopback>::DataServers> find_data_servers(){ + error_or<typename rpc_server<Iface, Encoding, rmt::Loopback>::DataServers> find_data_servers(ref<remote_address<rmt::Loopback>> addr){ typename rpc_server<Iface,Encoding,rmt::Loopback>::DataServers ret_val; { - auto eov = find_data_servers_ele<Iface,Encoding,0u>(ret_val); + auto eov = find_data_servers_ele<Iface,Encoding,0u>(ret_val,addr); if(eov.is_error()){ return std::move(eov.get_error()); } @@ -90,7 +112,7 @@ public: template<typename Iface, typename Encode> error_or<own<rpc_server<Iface, Encode, rmt::Loopback>>> rpc_listen(remote_address<rmt::Loopback>& addr, typename rpc_server<Iface,Encode,rmt::Loopback>::InterfaceT iface){ - auto eo_dat_srvs = find_data_servers<Iface,Encode>(); + auto eo_dat_srvs = find_data_servers<Iface,Encode>(addr); if(eo_dat_srvs.is_error()){ return std::move(eo_dat_srvs.get_error()); } |