1 files changed, 55 insertions, 0 deletions
diff --git a/src/test/librados/cls_remote_reads.cc b/src/test/librados/cls_remote_reads.cc
new file mode 100644
index 000000000..4256c072f
--- /dev/null
+++ b/src/test/librados/cls_remote_reads.cc
@@ -0,0 +1,55 @@
+#include <set>
+#include <string>
+
+#include "common/ceph_json.h"
+#include "gtest/gtest.h"
+#include "test/librados/test_cxx.h"
+
+#include "crimson_utils.h"
+
+using namespace librados;
+
+TEST(ClsTestRemoteReads, TestGather) {
+  SKIP_IF_CRIMSON();
+  Rados cluster;
+  std::string pool_name = get_temp_pool_name();
+  ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
+  IoCtx ioctx;
+  cluster.ioctx_create(pool_name.c_str(), ioctx);
+
+  bufferlist in, out;
+  int object_size = 4096;
+  char buf[object_size];
+  memset(buf, 1, sizeof(buf));
+
+  // create source objects from which data are gathered
+  in.append(buf, sizeof(buf));
+  ASSERT_EQ(0, ioctx.write_full("src_object.1", in));
+  in.append(buf, sizeof(buf));
+  ASSERT_EQ(0, ioctx.write_full("src_object.2", in));
+  in.append(buf, sizeof(buf));
+  ASSERT_EQ(0, ioctx.write_full("src_object.3", in));
+
+  // construct JSON request passed to "test_gather" method, and in turn, to "test_read" method
+  JSONFormatter *formatter = new JSONFormatter(true);
+  formatter->open_object_section("foo");
+  std::set<std::string> src_objects;
+  src_objects.insert("src_object.1");
+  src_objects.insert("src_object.2");
+  src_objects.insert("src_object.3");
+  encode_json("src_objects", src_objects, formatter);
+  encode_json("cls", "test_remote_reads", formatter);
+  encode_json("method", "test_read", formatter);
+  encode_json("pool", pool_name, formatter);
+  formatter->close_section();
+  in.clear();
+  formatter->flush(in);
+
+  // create target object by combining data gathered from source objects using "test_read" method
+  ASSERT_EQ(0, ioctx.exec("tgt_object", "test_remote_reads", "test_gather", in, out));
+
+  // read target object and check its size
+  ASSERT_EQ(3*object_size, ioctx.read("tgt_object", out, 0, 0));
+
+  ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
+}