From: myoungwon oh <ohmyoungwon@gmail.com>
Date: Tue, 2 Feb 2021 04:37:55 +0000 (+0900)
Subject: src/test: add SetChunkOp as a TestOp
X-Git-Tag: v17.1.0~2307^2~48
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=cc3c26997df26bb9471255dfa5bf729ecac1190f;p=ceph-ci.git

src/test: add SetChunkOp as a TestOp

Signed-off-by: Myoungwon Oh <myoungwon.oh@samsung.com>
---

diff --git a/src/test/osd/RadosModel.h b/src/test/osd/RadosModel.h
index 7cc4912cf2f..7f20d6ff07e 100644
--- a/src/test/osd/RadosModel.h
+++ b/src/test/osd/RadosModel.h
@@ -64,7 +64,8 @@ enum TestOpType {
   TEST_OP_UNSET_REDIRECT,
   TEST_OP_CHUNK_READ,
   TEST_OP_TIER_PROMOTE,
-  TEST_OP_TIER_FLUSH
+  TEST_OP_TIER_FLUSH,
+  TEST_OP_SET_CHUNK
 };
 
 class TestWatchContext : public librados::WatchCtx2 {
@@ -166,6 +167,7 @@ public:
   set<string> oid_not_flushing;
   set<string> oid_redirect_not_in_use;
   set<string> oid_redirect_in_use;
+  set<string> oid_set_chunk_tgt_pool;
   SharedPtrRegistry<int, int> snaps_in_use;
   int current_snap;
   string pool_name;
@@ -2375,6 +2377,7 @@ public:
     }
 
     if (++done == 1) {
+      context->oid_set_chunk_tgt_pool.insert(oid_tgt);
       context->oid_in_use.erase(oid);
       context->oid_not_in_use.insert(oid);
       context->kick();
diff --git a/src/test/osd/TestRados.cc b/src/test/osd/TestRados.cc
index e4021a03652..53dca91d86c 100644
--- a/src/test/osd/TestRados.cc
+++ b/src/test/osd/TestRados.cc
@@ -227,20 +227,8 @@ public:
 	/* make a chunk (random offset, random length --> 
 	 * target object's random offset)
 	 */
-	ObjectDesc contents, contents2;
-	context.find_object(oid.str(), &contents);
-	uint32_t max_len = contents.most_recent_gen()->get_length(contents.most_recent());
-	uint32_t rand_offset = rand() % max_len;
-	uint32_t rand_length = rand() % max_len;
-	rand_offset = rand_offset - (rand_offset % 512);
-	rand_length = rand_length - (rand_length % 512);
-
-	while (rand_offset + rand_length > max_len || rand_length == 0) {
-	  rand_offset = rand() % max_len;
-	  rand_length = rand() % max_len;
-	  rand_offset = rand_offset - (rand_offset % 512);
-	  rand_length = rand_length - (rand_length % 512);
-	}
+	uint32_t rand_offset = 0, rand_length = 0;
+	get_rand_off_len(context, oid.str(), rand_offset, rand_length);
 	uint32_t rand_tgt_offset = rand_offset;
 	cout << m_op << ": " << "set_chunk oid " << oid.str() << " offset: " << rand_offset 
 	     << " length: " << rand_length <<  " target oid " << oid2.str() 
@@ -274,6 +262,23 @@ public:
     return false;
   }
 
+  void get_rand_off_len(RadosTestContext &context, string oid, uint32_t &rand_offset, uint32_t &rand_length) {
+    ObjectDesc contents;
+    context.find_object(oid, &contents);
+    uint32_t max_len = contents.most_recent_gen()->get_length(contents.most_recent());
+    rand_offset = rand() % max_len;
+    rand_length = rand() % max_len;
+    rand_offset = rand_offset - (rand_offset % 512);
+    rand_length = rand_length - (rand_length % 512);
+
+    while (rand_offset + rand_length > max_len || rand_length == 0) {
+      rand_offset = rand() % max_len;
+      rand_length = rand() % max_len;
+      rand_offset = rand_offset - (rand_offset % 512);
+      rand_length = rand_length - (rand_length % 512);
+    }
+  }
+
 private:
 
   TestOp *gen_op(RadosTestContext &context, TestOpType type)
@@ -440,6 +445,20 @@ private:
       cout << m_op << ": " << "unset_redirect oid " << oid << std::endl;
       return new UnsetRedirectOp(m_op, &context, oid, m_stats);
 
+    case TEST_OP_SET_CHUNK:
+      {
+	ceph_assert(m_enable_dedup);
+	oid = *(rand_choose(context.oid_not_in_use));
+	/* The intention here is to mark the source object as a manifest object */
+	oid2 = *(rand_choose(context.oid_set_chunk_tgt_pool));
+	uint32_t rand_offset = 0, rand_length = 0;
+	get_rand_off_len(context, oid, rand_offset, rand_length);
+	cout << m_op << ": " << "set_chunk oid " << oid << " offset: " << rand_offset 
+	     << " length: " << rand_length <<  " target oid " << oid2 
+	     << " tgt_offset: " << rand_offset << std::endl;
+	return new SetChunkOp(m_op, &context, oid, rand_offset, rand_length, oid2, rand_offset, m_stats);
+      }
+
     default:
       cerr << m_op << ": Invalid op type " << type << std::endl;
       ceph_abort();
@@ -505,6 +524,7 @@ int main(int argc, char **argv)
     { TEST_OP_CHUNK_READ, "chunk_read", true },
     { TEST_OP_TIER_PROMOTE, "tier_promote", true },
     { TEST_OP_TIER_FLUSH, "tier_flush", true },
+    { TEST_OP_SET_CHUNK, "set_chunk", true },
     { TEST_OP_READ /* grr */, NULL },
   };