From f2a1a3f56768d9aa03796808206f067daa5e0aa0 Mon Sep 17 00:00:00 2001
From: Claudius 'keldu' Holeksa <mail@keldu.de>
Date: Mon, 21 Oct 2024 17:52:46 +0200
Subject: Working towards proper rpc reference example

---
 modules/remote/c++/remote_loopback_base.hpp | 20 ++++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

(limited to 'modules/remote/c++/remote_loopback_base.hpp')

diff --git a/modules/remote/c++/remote_loopback_base.hpp b/modules/remote/c++/remote_loopback_base.hpp
index 6ca244f..5664f77 100644
--- a/modules/remote/c++/remote_loopback_base.hpp
+++ b/modules/remote/c++/remote_loopback_base.hpp
@@ -50,6 +50,21 @@ private:
 	};
 
 	std::map<key_t, ptr<i_data_server<rmt::Loopback>>> registered_data_servers_;
+	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){
+
+	}
+
+	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;
+
+
+
+		return ret_val;
+	}
 public:
 	/**
 	 * Resolves an address for the remote
@@ -68,8 +83,9 @@ public:
 	 * Start listening
 	 */
 	template<typename Iface, typename Encode>
-	rpc_server<Iface, Encode, rmt::Loopback> rpc_listen(const remote_address<rmt::Loopback>& addr, typename rpc_server<Iface,Encode,rmt::Loopback>::InterfaceT iface){
-		return {addr, std::move(iface)};
+	error_or<own<rpc_server<Iface, Encode, rmt::Loopback>>> rpc_listen(const remote_address<rmt::Loopback>& addr, typename rpc_server<Iface,Encode,rmt::Loopback>::InterfaceT iface){
+
+		return heap<rpc_server<Iface,Encode,rmt::Loopback>>({*this}, addr, std::move(iface));
 	}
 
 	/**
-- 
cgit v1.2.3