2 files changed, 28 insertions, 6 deletions

diff --git a/modules/remote-sycl/examples/sycl_basic.cpp b/modules/remote-sycl/examples/sycl_basic.cpp
index abea738..64ec1fe 100644
--- a/modules/remote-sycl/examples/sycl_basic.cpp
+++ b/modules/remote-sycl/examples/sycl_basic.cpp
@@ -1,4 +1,5 @@
 #include "./sycl_basic.hpp"
+#include <forstio/codec/schema.hpp>
 
 int main(){
 	saw::remote<saw::rmt::Sycl> remote_ctx;
@@ -20,15 +21,26 @@ int main(){
 
 	auto rpc_server = listen_basic_sycl(remote_ctx, *rmt_addr);
 
+	saw::id<schema::UInt64> next_id{0u};
 	{
-		auto eov = rpc_server.template call<"increment">(saw::id<schema::UInt64>{1u});
+		auto eov = rpc_server.template call<"increment">(saw::data<schema::UInt64>{1u});
 		if(eov.is_error()){
+			auto& err = eov.get_error();
+			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
+			return -2;
+		}
+		next_id = eov.get_value();
+	}
+	{
+		auto eov = rpc_server.template call<"increment">(next_id);
+		if(eov.is_error()){
+			auto& err = eov.get_error();
+			std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
 			return -2;
 		}
 		auto& val = eov.get_value();
-		// std::cout<<"Value: "<<val<<std::endl;
+		std::cout<<"Value: "<<val.get_value()<<std::endl;
 	}
 
-
 	return 0;
 }
diff --git a/modules/remote-sycl/examples/sycl_basic_kernel.cpp b/modules/remote-sycl/examples/sycl_basic_kernel.cpp
index eb79bb8..18fe9b7 100644
--- a/modules/remote-sycl/examples/sycl_basic_kernel.cpp
+++ b/modules/remote-sycl/examples/sycl_basic_kernel.cpp
@@ -1,12 +1,22 @@
 #include "sycl_basic.hpp"
 
-rpc_server<schema::BasicInterface, encode::Native<storage::Default>, rmt::Sycl> listen_basic_sycl(remote<rmt::Sycl>& ctx, remote_address<rmt::Sycl>& addr){
+saw::rpc_server<schema::BasicInterface, saw::encode::Native<saw::storage::Default>, saw::rmt::Sycl> listen_basic_sycl(saw::remote<saw::rmt::Sycl>& ctx, saw::remote_address<saw::rmt::Sycl>& addr){
 	saw::interface<schema::BasicInterface, saw::encode::Native<saw::storage::Default>, cl::sycl::queue*> iface{
 		[](saw::data<saw::schema::UInt64> in, cl::sycl::queue* q) -> saw::data<saw::schema::UInt64> {
-			return {in.get() + 1u};
+			uint64_t inr = in.get();
+			cl::sycl::buffer<uint64_t,1>  d_inc{ &inr, 1u };
+			q->submit([&](cl::sycl::handler& h){
+				auto a_inc = d_inc.get_access<cl::sycl::access::mode::read_write>(h);
+
+				h.parallel_for(cl::sycl::range<1>(1u), [=] (cl::sycl::id<1> it){
+					a_inc[0] += 1u;
+				});
+			});
+			q->wait();
+			return {inr};
 		}
 	};
-	auto rpc_server = remote_ctx.template listen<schema::BasicInterface, saw::encode::Native<saw::storage::Default>>(*rmt_addr, std::move(iface));
+	auto rpc_server = ctx.template listen<schema::BasicInterface, saw::encode::Native<saw::storage::Default>>(addr, std::move(iface));
 	
 	return rpc_server;
 }