From 75c402b68c0092663916eb25c2270ca853437fcc Mon Sep 17 00:00:00 2001 From: Claudius 'keldu' Holeksa Date: Fri, 30 Aug 2024 13:52:00 +0200 Subject: Chaning to encode::Hip --- modules/remote-hip/c++/rpc.hpp | 8 ++++---- modules/remote-hip/c++/transfer.hpp | 14 +++++++------- 2 files changed, 11 insertions(+), 11 deletions(-) (limited to 'modules') diff --git a/modules/remote-hip/c++/rpc.hpp b/modules/remote-hip/c++/rpc.hpp index f6b519b..905750f 100644 --- a/modules/remote-hip/c++/rpc.hpp +++ b/modules/remote-hip/c++/rpc.hpp @@ -163,7 +163,7 @@ template class rpc_server { public: using InterfaceCtxT = cl::sycl::queue*; - using InterfaceT = interface, InterfaceCtxT>; + using InterfaceT = interface, InterfaceCtxT>; private: /** @@ -224,12 +224,12 @@ public: /** * Object needed if and only if the provided data type is not an id */ - own>> dev_tmp_inp = nullptr; + own>> dev_tmp_inp = nullptr; /** * First check if it's data or an id. * If it's an id, check if it's registered within the storage and retrieve it. */ - auto eoinp = [&,this]() -> error_or>* > { + auto eoinp = [&,this]() -> error_or>* > { if(input.is_id()){ // storage_.maps auto eov = data_server_->template find(input.get_id()); @@ -246,7 +246,7 @@ public: } auto& val = eov.get_value(); - dev_tmp_inp = heap>>(std::move(val)); + dev_tmp_inp = heap>>(std::move(val)); device_->get_handle().wait(); return dev_tmp_inp.get(); } diff --git a/modules/remote-hip/c++/transfer.hpp b/modules/remote-hip/c++/transfer.hpp index 8c2cc02..1fd97e8 100644 --- a/modules/remote-hip/c++/transfer.hpp +++ b/modules/remote-hip/c++/transfer.hpp @@ -15,7 +15,7 @@ class data_server final : public i_data_server> device_; - std::map>> values_; + std::map>> values_; public: data_server(our> device__): device_{std::move(device__)} @@ -54,7 +54,7 @@ public: return make_void(); } - error_or>>> find(id store_id){ + error_or>>> find(id store_id){ auto find_res = values_.find(store_id.get_value()); if(find_res == values_.end()){ return make_error(); @@ -75,7 +75,7 @@ private: /** * Store for the data the server manages. */ - typename impl::data_server_redux, typename tmpl_reduce>::type >::type values_; + typename impl::data_server_redux, typename tmpl_reduce>::type >::type values_; public: /** * Main constructor @@ -89,7 +89,7 @@ public: */ template error_or send(const data& dat, id store_id){ - auto& vals = std::get>>>(values_); + auto& vals = std::get>>>(values_); auto eoval = device_->template copy_to_device(dat); if(eoval.is_error()){ auto& err = eoval.get_error(); @@ -109,7 +109,7 @@ public: template error_or allocate(const data::MetaSchema, Encoding>& dat, id store_id){ - auto& vals = std::get>>>(values_); + auto& vals = std::get>>>(values_); auto eoval = device_->template allocate_on_device(dat); if(eoval.is_error()){ auto& err = eoval.get_error(); @@ -132,7 +132,7 @@ public: */ template error_or> receive(id store_id){ - auto& vals = std::get>>>(values_); + auto& vals = std::get>>>(values_); auto find_res = vals.find(store_id.get_value()); if(find_res == vals.end()){ return make_error(); @@ -161,7 +161,7 @@ public: * Insert operations may invalidate the pointer. */ template - error_or>*> find(id store_id){ + error_or>*> find(id store_id){ auto& vals = std::get>>(values_); auto find_res = vals.find(store_id.get_value()); if(find_res == vals.end()){ -- cgit v1.2.3