thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 09:32:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

random generator is now one for thread

Browse Source
This commit is contained in:
dimarub2000 2019-08-06 16:19:06 +03:00
parent 02878c233a
commit 4f89f8f4dd
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
dbms/programs/benchmark/Benchmark.cpp
View File

@ -307,6 +307,10 @@ private:
{
Query query;
/// Randomly choosing connection index
pcg64 generator(randomSeed());
std::uniform_int_distribution<size_t> distribution(0, connection_entries.size() - 1);
try
{
/// In these threads we do not accept INT signal.
@ -327,7 +331,7 @@ private:
if (shutdown || (max_iterations && queries_executed == max_iterations))
return;
}
execute(connection_entries, query);
execute(connection_entries, query, distribution(generator));
++queries_executed;
}
}
@ -339,13 +343,8 @@ private:
}
}
void execute(EntryPtrs & connection_entries, Query & query)
void execute(EntryPtrs & connection_entries, Query & query, size_t connection_index)
{
/// Randomly choosing connection index
pcg64 generator(randomSeed());
std::uniform_int_distribution<size_t> distribution(0, connection_entries.size() - 1);
size_t connection_index = distribution(generator);
Stopwatch watch;
RemoteBlockInputStream stream(
*(*connection_entries[connection_index]),