Skip to content

Commit cc8c766

Browse files
committed
test/allocsim: don't join caches
Signed-off-by: Pere Diaz Bou <[email protected]>
1 parent e220338 commit cc8c766

File tree

1 file changed

+1
-14
lines changed

1 file changed

+1
-14
lines changed

src/test/objectstore/allocsim/ops_replayer.cc

Lines changed: 1 addition & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -338,7 +338,6 @@ int main(int argc, char** argv) {
338338
string file("input.txt");
339339
string ceph_conf_path("./ceph.conf");
340340
string pool("test_pool");
341-
string input_ir_output("");
342341
bool skip_do_ops = false;
343342

344343
po::options_description po_options("Options");
@@ -350,7 +349,6 @@ int main(int argc, char** argv) {
350349
("parser-threads", po::value<uint64_t>(&nparser_threads)->default_value(16), "Number of parser threads")
351350
("worker-threads", po::value<uint64_t>(&nworker_threads)->default_value(16), "Number of I/O worker threads")
352351
("pool", po::value<string>(&pool)->default_value("test_pool"), "Pool to use for I/O")
353-
("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")
354352
("skip-do-ops", po::bool_switch(&skip_do_ops)->default_value(false), "Skip doing operations")
355353
;
356354

@@ -402,22 +400,11 @@ int main(int argc, char** argv) {
402400
}
403401
// reduce
404402
for (auto context : parser_contexts) {
405-
string_cache.insert(context->object_cache.begin(), context->object_cache.end());
406-
string_cache.insert(context->collection_cache.begin(), context->collection_cache.end());
407-
string_cache.insert(context->who_cache.begin(), context->who_cache.end());
408403
ops.insert(ops.end(), context->ops.begin(), context->ops.end());
409404
max_buffer_size = max(context->max_buffer_size, max_buffer_size);
410-
context->object_cache.clear();
411-
context->collection_cache.clear();
412-
context->who_cache.clear();
413-
context->ops.clear();
405+
// context->ops.clear();
414406
}
415407

416-
if (!input_ir_output.empty()) {
417-
// Create an optimized file for parsing
418-
ofstream output(input_ir_output, ios::out);
419-
output << "input-optimized" << endl;
420-
}
421408

422409
int ret = cluster.init2("client.admin", "ceph", 0);
423410
if (ret < 0) {

0 commit comments

Comments
 (0)