@@ -50,49 +50,3 @@ CORO_TEST_F(NeoRadosCls, DNE, NeoRadosTest)
5050 sys::errc::operation_not_supported);
5151 co_return ;
5252}
53-
54- CORO_TEST_F (NeoRadosCls, RemoteReads, NeoRadosTest)
55- {
56- SKIP_IF_CRIMSON ();
57- static constexpr std::size_t object_size = 4096 ;
58- static constexpr std::array oids{" src_object.1" sv, " src_object.2" sv,
59- " src_object.3" sv};
60-
61- std::array<char , object_size> buf;
62- buf.fill (1 );
63-
64- for (const auto & oid : oids) {
65- buffer::list in;
66- in.append (buf.data (), buf.size ());
67- co_await execute (oid, WriteOp{}.write_full (std::move (in)));
68- }
69-
70- // Construct JSON request passed to "test_gather" method, and in
71- // turn, to "test_read" method
72- buffer::list in;
73- {
74- auto formatter = std::make_unique<JSONFormatter>(true );
75- formatter->open_object_section (" foo" );
76- encode_json (" src_objects" , oids, formatter.get ());
77- encode_json (" cls" , " test_remote_reads" , formatter.get ());
78- encode_json (" method" , " test_read" , formatter.get ());
79- encode_json (" pool" , pool_name (), formatter.get ());
80- formatter->close_section ();
81- formatter->flush (in);
82- }
83-
84- static const auto target = " tgt_object" s;
85-
86- // Create target object by combining data gathered from source
87- // objects using "test_read" method
88- co_await execute (target,
89- WriteOp{}.exec (" test_remote_reads" , " test_gather" , in));
90-
91-
92- // Read target object and check its size.
93- buffer::list out;
94- co_await execute (target, ReadOp{}.read (0 , 0 , &out));
95- EXPECT_EQ (3 * object_size, out.length ());
96-
97- co_return ;
98- }
0 commit comments