summaryrefslogtreecommitdiff
path: root/modules/remote
diff options
context:
space:
mode:
authorClaudius "keldu" Holeksa <mail@keldu.de>2024-07-21 22:24:03 +0200
committerClaudius "keldu" Holeksa <mail@keldu.de>2024-07-21 22:24:03 +0200
commit498acb5ee9db90aaf01049ae44e098169219398d (patch)
treea79c5a2cc5bb7aa49cfde2422183644bdbb5cfd5 /modules/remote
parent6ca91987ec91621577468ebf68fd68fc5433284a (diff)
wip
Diffstat (limited to 'modules/remote')
-rw-r--r--modules/remote/c++/transfer_loopback.hpp13
1 files changed, 11 insertions, 2 deletions
diff --git a/modules/remote/c++/transfer_loopback.hpp b/modules/remote/c++/transfer_loopback.hpp
index f148281..9f6dddd 100644
--- a/modules/remote/c++/transfer_loopback.hpp
+++ b/modules/remote/c++/transfer_loopback.hpp
@@ -36,9 +36,18 @@ public:
*
*/
template<typename Sch>
- error_or<void> allocate(id<Sch> store_id){
+ error_or<void> allocate(data<typename meta_schema<Sch>::type, Encoding> meta, id<Sch> store_id){
+ auto& vals = std::get<std::unordered_map<uint64_t, data<Sch,Encoding>>>(values_);
- return make_error<err::not_implemented>();
+ try {
+ auto insert_res = vals.emplace(std::make_pair(store_id.get_value(), {std::move(meta)}));
+ if(!insert_res.second){
+ return make_error<err::already_exists>();
+ }
+ }catch(std::exception& ){
+ return make_error<err::out_of_memory>();
+ }
+ return make_void();
}
template<typename Sch>