From 001c23fcdb1e881cbcb0532d108218fbdb271cb9 Mon Sep 17 00:00:00 2001
From: Claudius 'keldu' Holeksa <mail@keldu.de>
Date: Fri, 6 Sep 2024 16:57:23 +0200
Subject: Working on a data transfer test

---
 modules/remote-hip/c++/remote.hpp   | 8 +++++++-
 modules/remote-hip/c++/transfer.hpp | 7 ++++++-
 2 files changed, 13 insertions(+), 2 deletions(-)

(limited to 'modules/remote-hip/c++')

diff --git a/modules/remote-hip/c++/remote.hpp b/modules/remote-hip/c++/remote.hpp
index 7263aaf..b814ff2 100644
--- a/modules/remote-hip/c++/remote.hpp
+++ b/modules/remote-hip/c++/remote.hpp
@@ -1,6 +1,7 @@
 #pragma once
 
 #include "common.hpp"
+#include "device.hpp"
 
 namespace saw {
 
@@ -104,7 +105,12 @@ public:
 	 */
 	template<typename Schema, typename Encoding>
 	error_or<own<data_server<Schema, Encoding, rmt::Hip>>> data_listen(remote_address<rmt::Hip>& dev){
-		return heap<data_server<Schema, Encoding, rmt::Hip>>(dev);
+		our<device<rmt::Hip>> dev = nullptr;
+		auto ins = devs_.emplace(std::make_pair(dev.get_device_id(), our<device<rmt::Hip>>{nullptr}));
+		if(ins.second){
+			ins.first->second = share<device<rmt::Hip>>();
+		}
+		return heap<data_server<Schema, Encoding, rmt::Hip>>(ins.first->second);
 	}
 
 	/**
diff --git a/modules/remote-hip/c++/transfer.hpp b/modules/remote-hip/c++/transfer.hpp
index a81f657..4e76436 100644
--- a/modules/remote-hip/c++/transfer.hpp
+++ b/modules/remote-hip/c++/transfer.hpp
@@ -22,7 +22,12 @@ public:
 	{}
 
 	error_or<void> send(const data<Schema,Encoding>& dat, id<Schema> store_id){
-		return make_error<err::not_implemented>();
+		auto ins = values_.emplace(std::make_pair(store_id.get_value(), data<Schema, encode::Hip<Encoding>>{dat}));
+		if(!ins.second){
+			return make_error<err::already_exists>();
+		}
+
+		return make_void();
 	}
 
 	error_or<void> allocate(const data<typename meta_schema<Schema>::MetaSchema, Encoding>& dat, id<Schema> store_id){
-- 
cgit v1.2.3