blob: 86e73b517c4e56a5f26bd0ea2bc592890d36abc4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
#include "sycl_basic.hpp"
saw::rpc_server<schema::BasicInterface, saw::encode::Native<saw::rmt::Sycl>, 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{
[](saw::data<saw::schema::Array<saw::schema::UInt64>, saw::encode::Native<saw::rmt::Sycl>> in, cl::sycl::queue* q) -> saw::data<saw::schema::UInt64, saw::encode::Native<saw::rmt::Sycl>> {
uint64_t inr = in.size();
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 = ctx.template listen<schema::BasicInterface, saw::encode::Native<saw::rmt::Sycl>>(addr, std::move(iface));
return rpc_server;
}
|
