summaryrefslogtreecommitdiff
path: root/modules/remote-filesystem/examples/remote_read_file.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'modules/remote-filesystem/examples/remote_read_file.cpp')
-rw-r--r--modules/remote-filesystem/examples/remote_read_file.cpp59
1 files changed, 59 insertions, 0 deletions
diff --git a/modules/remote-filesystem/examples/remote_read_file.cpp b/modules/remote-filesystem/examples/remote_read_file.cpp
new file mode 100644
index 0000000..b0b2c89
--- /dev/null
+++ b/modules/remote-filesystem/examples/remote_read_file.cpp
@@ -0,0 +1,59 @@
+#include "../c++/transfer.hpp"
+
+#include <forstio/codec/simple.hpp>
+
+#include <iostream>
+
+namespace sch {
+using namespace saw::schema;
+
+using Foo = Struct<
+ Member<String, "a">,
+ Member<Int64, "b">
+>;
+}
+
+int main(){
+ using namespace saw;
+
+ remote<rmt::File> file_remote;
+
+ auto eo_addr = file_remote.parse_address("./example_file");
+ if(eo_addr.is_error()){
+ return 1;
+ }
+ auto& addr = eo_addr.get_value();
+
+ auto eo_dat_srv = file_remote.template data_listen<sch::Foo,encode::KelSimple>({*addr});
+ if(eo_dat_srv.is_error()){
+ return 2;
+ }
+ auto& dat_srv = eo_dat_srv.get_value();
+
+ std::string a = "blafoobla";
+ int64_t b = 42;
+
+ {
+
+ id<sch::Foo> foo_id{0u};
+ auto eo_recv = dat_srv->receive(foo_id);
+ if(eo_recv.is_error()){
+ auto& err = eo_recv.get_error();
+ std::cerr<<"Error: "<<err.get_category()<<" - "<<err.get_message()<<std::endl;
+ return 4;
+ }
+ auto& recv = eo_recv.get_value();
+
+ data<sch::Foo> nat_foo;
+ codec<sch::Foo, encode::KelSimple> smp_cod;
+ auto eov = smp_cod.decode(recv, nat_foo);
+ if(eov.is_error()){
+ return 3;
+ }
+
+ std::cout<<"a: ";
+ for(uint64_t i = 0; i < nat_foo.template get<"a">().size();++i) std::cout<<nat_foo.template get<"a">().at(i);
+ std::cout<<"\nb: "<<nat_foo.template get<"b">().get()<<std::endl;
+ }
+ return 0;
+}