Moving remote definitions from codec to remote module

1 files changed, 0 insertions, 152 deletions

diff --git a/modules/codec/c++/transfer_loopback.hpp b/modules/codec/c++/transfer_loopback.hpp
deleted file mode 100644
index 6c81c9c..0000000
--- a/modules/codec/c++/transfer_loopback.hpp
+++ /dev/null
@@ -1,152 +0,0 @@
-#pragma once
-
-#include <forstio/reduce_templates.hpp>
-
-#include "transfer.hpp"
-
-namespace saw {
-namespace rmt {
-struct Loopback {};
-}
-
-template<typename... Schema, typename Encoding>
-class data_server<tmpl_group<Schema...>, Encoding, rmt::Loopback> {
-private:
-	typename impl::data_server_redux<Encoding, storage::Default, typename tmpl_reduce<tmpl_group<Schema...>>::type>::type values_;
-public:
-	/**
-	 * Get data from client
-	 */
-	template<typename Sch>
-	error_or<void> send(const data<Sch, Encoding, storage::Default>& dat, id<Sch> store_id){
-		auto& vals = std::get<std::unordered_map<uint64_t, data<Sch,Encoding>>>(values_);
-
-		try {
-			auto insert_res = vals.emplace(std::make_pair(store_id.get_value(), std::move(dat)));
-			if(!insert_res.second){
-				return make_error<err::already_exists>();
-			}
-		}catch(std::exception& ){
-			return make_error<err::out_of_memory>();
-		}
-		return void_t{};
-	}
-
-	template<typename Sch>
-	error_or<data<Sch, Encoding, storage::Default>> receive(id<Sch> store_id){
-		auto& vals = std::get<std::unordered_map<uint64_t, data<Sch,Encoding>>>(values_);
-
-		auto find_res = vals.find(store_id.get_value());
-		if(find_res == vals.end()){
-			return make_error<err::not_found>();
-		}
-
-		auto& dat = find_res->second;
-		return dat;
-	}
-
-	template<typename Sch>
-	error_or<void> erase(id<Sch> store_id){
-		auto& vals = std::get<std::unordered_map<uint64_t, data<Sch,Encoding>>>(values_);
-		auto erase_op = vals.erase(store_id.get_value());
-		if(erase_op == 0u){
-			return make_error<err::not_found>();
-		}
-		return void_t{};
-	}
-
-	template<typename Sch>
-	error_or<data<Sch, Encoding, storage::Default>*> find(id<Sch> store_id){
-		auto& vals = std::get<std::unordered_map<uint64_t, data<Sch,Encoding>>>(values_);
-		auto find_res = vals.find(store_id.get_value());
-		if(find_res == vals.end()){
-			return make_error<err::not_found>();
-		}
-
-		auto& dat = find_res->second;
-		return &dat;
-	}
-};
-
-/**
- * Client for transporting data to remote and receiving data back
- */
-template<typename... Schema, typename Encoding>
-class data_client<tmpl_group<Schema...>, Encoding, rmt::Loopback> {
-private:
-	/**
-	 * Corresponding server for this client
-	 */
-	data_server<tmpl_group<Schema...>, Encoding, rmt::Loopback>* srv_;
-
-	/**
-	 * The next id for identifying issues on the remote side.
-	 */
-	uint64_t next_id_;
-public:
-	/**
-	 * Main constructor
-	 */
-	data_client(data_server<tmpl_group<Schema...>, Encoding, rmt::Loopback>& srv__):
-		srv_{&srv__},
-		next_id_{0u}
-	{}
-
-	/**
-	 * Send data to the remote.
-	 */
-	template<typename Sch>
-	error_or<id<Sch>> send(const data<Sch, Encoding, storage::Default>& dat){
-		id<Sch> dat_id{next_id_};
-		auto eov = srv_->send(dat, dat_id);
-		if(eov.is_error()){
-			auto& err = eov.get_error();
-			return std::move(err);
-		}
-
-		++next_id_;
-		return dat_id;
-	}
-
-	/**
-	 * Receive data
-	 */
-	template<typename Sch>
-	conveyor<data<Sch, Encoding, storage::Default>> receive(id<Sch> dat_id){
-		auto eov = srv_->receive(dat_id);
-		if(eov.is_error()){
-			auto& err = eov.get_error();
-			return std::move(err);
-		}
-
-		auto& val = eov.get_value();
-		return std::move(val);
-	}
-
-	/**
-	 * Erase data
-	 */
-	template<typename Sch>
-	error_or<void> erase(id<Sch> dat_id){
-		return srv_->erase(dat_id);
-	}
-
-	/**
-	 * An exception for the Loopback backend. Here we can safely use find from
-	 * the client side.
-	 */
-	template<typename Sch>
-	error_or<data<Sch, Encoding>*> find(id<Sch> dat_id){
-		auto eov = srv_->find(dat_id);
-		if(eov.is_error()){
-			auto& err = eov.get_error();
-			return std::move(err);
-		}
-
-		auto val = eov.get_value();
-		return val;
-	}
-
-};
-
-}