blob: 3f92cdbbec435c21b014cae6a1f5af3be21ea564 (
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
|
#include "./sycl_basic.hpp"
#include <forstio/codec/schema.hpp>
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;
}
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::data<schema::UInt64, saw::encode::Native<saw::rmt::Sycl>>{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.get_value()<<std::endl;
}
return 0;
}
|
