thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add print

Browse Source
This commit is contained in:
Antonio Andelic 2024-05-07 14:40:45 +02:00
parent 363b4de531
commit 936f94d286
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
utils/keeper-bench/Runner.cpp
View File

@ -635,11 +635,14 @@ struct ZooKeeperRequestFromLogReader
break;
}
case Coordination::OpNum::Check:
case Coordination::OpNum::CheckNotExists:
{
auto check_request = std::make_shared<Coordination::ZooKeeperCheckRequest>();
check_request->path = current_block->getPath(idx_in_block);
if (auto version = current_block->getVersion(idx_in_block))
check_request->version = *version;
if (op_num == Coordination::OpNum::CheckNotExists)
check_request->not_exists = true;
request_from_log.request = check_request;
break;
}
@ -868,10 +871,20 @@ void Runner::runBenchmarkFromLog()
}
ZooKeeperRequestFromLogReader request_reader(input_request_log, global_context);
delay_watch.restart();
while (auto request_from_log = request_reader.getNextRequest())
{
request_from_log->connection = get_zookeeper_connection(request_from_log->session_id);
push_request(std::move(*request_from_log));
if (delay > 0 && delay_watch.elapsedSeconds() > delay)
{
dumpStats("Write", stats.write_requests);
dumpStats("Read", stats.read_requests);
std::cerr << std::endl;
delay_watch.restart();
}
}
}