blob: a180d23c3e90a8e714c30d9ad5907e35fa9755ab (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
#include "../c++/remote.hpp"
namespace schema {
using namespace saw::schema;
using BasicInterface = Interface<
Member<Function<UInt64, UInt64>, "increment">
>;
}
int main(){
saw::remote<saw::rmt::Sycl> remote_ctx;
saw::own<saw::remote_address<saw::rmt::Sycl>> rmt_addr{};
saw::event_loop loop;
saw::wait_scope wait{loop};
remote_ctx.resolve_address().then([&](auto addr){
rmt_addr = std::move(addr);
}).detach();
wait.poll();
if(!rmt_addr){
return -1;
}
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};
}
};
auto rpc_server = remote_ctx.template listen<schema::BasicInterface, saw::encode::Native<saw::storage::Default>>(*rmt_addr, std::move(iface));
{
auto eov = rpc_server.template call<"increment">({1u});
if(eov.is_error()){
return -2;
}
auto& val = eov.get_value();
std::cout<<"Value: "<<val<<std::endl;
}
return 0;
}
|
