#include "sycl_basic.hpp"

saw::rpc_server<schema::BasicInterface, saw::encode::Native, 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::rmt::Sycl, cl::sycl::queue*> iface{
		/**
		 * This is the increment kernel
		 */
		[](saw::data<saw::schema::Array<saw::schema::UInt64>, saw::encode::Native, saw::rmt::Sycl>& in, cl::sycl::queue* q) -> saw::error_or<void> {

			q->submit([&](cl::sycl::handler& h){
				h.single_task([&] (){
					in.at(0u).set(in.at(0u).get() + 1u);
				});
			});
			q->wait();
			return in;
		}
	};
	auto rpc_server = ctx.template listen<schema::BasicInterface, saw::encode::Native>(dev, std::move(iface));
	
	return rpc_server;
}