blob: bc4d99700d700aac5ba93203af0ad49c1fd45627 (
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
#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 device = remote_ctx.connect_device(*rmt_addr);
auto rpc_server = listen_basic_sycl(remote_ctx, device, *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};
saw::data<schema::Array<schema::UInt64>, saw::encode::Native> ex_data{1u};
ex_data.at(0u).set(50u);
{
auto eov = client.template call<"increment">(
ex_data
);
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 rmt_data = rpc_server.request_data<schema::Array<schema::UInt64>, saw::storage::Default>(id_zero);
auto eo_rd = rmt_data.wait();
if(eo_rd.is_error()){
auto& err = eo_rd.get_error();
std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
return -2;
}
auto& val = eo_rd.get_value();
std::cout<<"Values: "<<val.size()<<"\n";
for(uint64_t i = 0; i < val.size(); ++i){
std::cout<<val.at(i).get()<<'\t';
}
std::cout<<std::endl;
}
saw::id<schema::Array<schema::UInt64>> id_one{1u};
{
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;
}
id_one = eov.get_value();
}
{
auto rmt_data = rpc_server.request_data<schema::Array<schema::UInt64>, saw::storage::Default>(id_one);
auto eo_rd = rmt_data.wait();
if(eo_rd.is_error()){
auto& err = eo_rd.get_error();
std::cerr<<"Error: "<<err.get_category()<<" : "<<err.get_message()<<std::endl;
return -2;
}
auto& val = eo_rd.get_value();
std::cout<<"Values: "<<val.size()<<"\n";
for(uint64_t i = 0; i < val.size(); ++i){
std::cout<<val.at(i).get()<<'\t';
}
std::cout<<std::endl;
}
return 0;
}
|
