summaryrefslogtreecommitdiff
path: root/modules/remote/tests/remote_loopback.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'modules/remote/tests/remote_loopback.cpp')
-rw-r--r--modules/remote/tests/remote_loopback.cpp92
1 files changed, 0 insertions, 92 deletions
diff --git a/modules/remote/tests/remote_loopback.cpp b/modules/remote/tests/remote_loopback.cpp
index eca107f..bc04605 100644
--- a/modules/remote/tests/remote_loopback.cpp
+++ b/modules/remote/tests/remote_loopback.cpp
@@ -10,12 +10,6 @@ using TestInterface = Interface<
Member<Function<UInt32, Int64>, "foo">
>;
-using GroupedSchemas = saw::tmpl_group<
- UInt64,
- String,
- Array<Int32>,
- Float64
->;
}
SAW_TEST("Remote Loopback Data"){
@@ -95,90 +89,4 @@ SAW_TEST("Remote Loopback Data"){
}
}
-SAW_TEST("Remote Loopback Grouped Data"){
- using namespace saw;
-
- event_loop loop;
- wait_scope wait{loop};
-
- remote<rmt::Loopback> rmt;
-
- auto eov = rmt.parse_address(0u);
- SAW_EXPECT(eov.is_value(), "Didn't parse correctly");
- auto& addr = eov.get_value();
-
- auto eo_srv = rmt.template data_listen<sch::GroupedSchemas, encode::Native>(*addr);
- SAW_EXPECT(eo_srv.is_value(), std::string{"Couldn't listen: "} + std::string{eo_srv.get_error().get_category()});
- auto& srv = eo_srv.get_value();
-
- auto cvr_client = rmt.template data_connect<sch::GroupedSchemas, encode::Native>(*addr);
- auto eo_client = cvr_client.take();
- SAW_EXPECT(eo_client.is_value(), "Couldn't connect.");
- auto& client = eo_client.get_value();
-
- data<sch::UInt64> foo{421};
- id<sch::UInt64> sent_id = [&](){
- auto eov = client.send(foo);
- SAW_EXPECT(eov.is_value(), "Failed send.");
- return eov.get_value();
- }();
-
- {
- auto conv = client.receive(sent_id);
- auto eov = conv.take();
-
- SAW_EXPECT(eov.is_value(), "Failed receive.");
- SAW_EXPECT(eov.get_value() == foo, "Wrong received value.");
- }
- {
- auto eov = client.find(sent_id);
- SAW_EXPECT(eov.is_value(), "Failed find.");
- auto& f_val = eov.get_value();
- SAW_EXPECT(f_val, "Nullptr in find.");
- SAW_EXPECT(*f_val == foo, "Wrong received value.");
- }
- {
- auto eov = client.erase(sent_id);
- SAW_EXPECT(eov.is_value(), "Failed erase.");
- }
- {
- auto conv = client.receive(sent_id);
- auto eov = conv.take();
- SAW_EXPECT(!eov.is_value(), "Failed receive. Value should already be erased.");
- }
-
- id<sch::UInt64> alloc_id = [&](){
- auto eov = client.allocate<sch::UInt64>(data<sch::Void>{});
- SAW_EXPECT(eov.is_value(), "Failed send.");
- return eov.get_value();
- }();
- {
- auto eov = client.find(alloc_id);
- SAW_EXPECT(eov.is_value(), "Failed find.");
- auto& f_val = eov.get_value();
- SAW_EXPECT(f_val, "Nullptr in find.");
- f_val->set(5u);
- }
- {
- auto conv = client.receive(alloc_id);
- auto eov = conv.take();
- SAW_EXPECT(eov.is_value(), "Failed receive.");
- SAW_EXPECT(eov.get_value().get() == 5u, "Wrong received value.");
- }
-
- data<sch::FixedArray<sch::UInt64,1>> arr_meta{{128u}};
-
- id<sch::Array<sch::Int32>> arr_alloc_id = [&](){
- auto eov = client.allocate<sch::Array<sch::Int32>>(arr_meta);
- SAW_EXPECT(eov.is_value(), "Failed send.");
- return eov.get_value();
- }();
- {
- auto eov = client.find(arr_alloc_id);
- SAW_EXPECT(eov.is_value(), "Failed find.");
- auto& f_val = eov.get_value();
- SAW_EXPECT(f_val, "Nullptr in find.");
- SAW_EXPECT(f_val->size() == arr_meta.at(0).get(), "Wrong initialized size.");
- }
-}
}