blob: 2e9a4f8e8e51442386dd98fe3ed3d90c180baa68 (
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
48
49
|
#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::rpc_client<schema::BasicInterface, saw::encode::Native, saw::storage::Default, saw::rmt::Sycl> client{rpc_server};
saw::id<schema::Array<schema::UInt64>> id_zero{0u};
{
auto eov = client.template call<"increment">(saw::data<schema::Array<schema::UInt64>, saw::encode::Native>{1u});
if(eov.is_error()){
auto& err = eov.get_error();
std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
return -2;
}
id_zero = eov.get_value();
}
{
auto eov = client.template call<"increment">(id_zero);
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;
}
{
// auto eo_rd = rpc_server.request_data(id_one);
}
return 0;
}
|
