]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
test/allocsim: don't join caches 58439/head
authorPere Diaz Bou <pere-altea@hotmail.com>
Thu, 4 Jul 2024 14:15:10 +0000 (16:15 +0200)
committerPere Diaz Bou <pere-altea@hotmail.com>
Mon, 8 Jul 2024 12:02:45 +0000 (14:02 +0200)
Signed-off-by: Pere Diaz Bou <pere-altea@hotmail.com>
src/test/objectstore/allocsim/ops_replayer.cc

index 3dde5285d5086f8c9005aab045bddf582ac11afe..6f4d9501ee9e106f5d236fcc569389fbd1f980be 100644 (file)
@@ -338,7 +338,6 @@ int main(int argc, char** argv) {
   string file("input.txt");
   string ceph_conf_path("./ceph.conf");
   string pool("test_pool");
-  string input_ir_output("");
   bool skip_do_ops = false;
 
   po::options_description po_options("Options");
@@ -350,7 +349,6 @@ int main(int argc, char** argv) {
     ("parser-threads", po::value<uint64_t>(&nparser_threads)->default_value(16), "Number of parser threads")
     ("worker-threads", po::value<uint64_t>(&nworker_threads)->default_value(16), "Number of I/O worker threads")
     ("pool", po::value<string>(&pool)->default_value("test_pool"), "Pool to use for I/O")
-    ("optimized-input-path", po::value<string>(&input_ir_output)->default_value(""), "Create a new input file that is optimzed for parsing. If not empty it will create it")
     ("skip-do-ops", po::bool_switch(&skip_do_ops)->default_value(false), "Skip doing operations")
     ;
 
@@ -402,22 +400,11 @@ int main(int argc, char** argv) {
   }
   // reduce
   for (auto context : parser_contexts) {
-      string_cache.insert(context->object_cache.begin(), context->object_cache.end());
-      string_cache.insert(context->collection_cache.begin(), context->collection_cache.end());
-      string_cache.insert(context->who_cache.begin(), context->who_cache.end());
       ops.insert(ops.end(), context->ops.begin(), context->ops.end());
       max_buffer_size = max(context->max_buffer_size, max_buffer_size);
-      context->object_cache.clear();
-      context->collection_cache.clear();
-      context->who_cache.clear();
-      context->ops.clear();
+      // context->ops.clear();
   }
 
-  if (!input_ir_output.empty()) {
-    // Create an optimized file for parsing
-    ofstream output(input_ir_output, ios::out);
-    output << "input-optimized" << endl;
-  }
 
   int ret = cluster.init2("client.admin", "ceph", 0);
   if (ret < 0) {