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

dbms: ProfileEventsTransmitter: better [#METR-10463].

Browse Source
This commit is contained in:
Alexey Milovidov 2014-07-23 03:36:33 +04:00
parent 1be80d3410
commit 32895b3c02
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
dbms/src/Server/Server.cpp
View File

@ -64,11 +64,7 @@ private:
while (true)
{
const auto quit = cond.wait_until(lock, get_next_minute(), [this] {
return this->quit;
});
if (quit)
if (cond.wait_until(lock, get_next_minute(), [this] { return quit; }))
break;
transmitCounters();
@ -80,7 +76,7 @@ private:
GraphiteWriter::KeyValueVector<size_t> key_vals{};
key_vals.reserve(ProfileEvents::END);
for (auto i = 0; i < ProfileEvents::END; ++i)
for (size_t i = 0; i < ProfileEvents::END; ++i)
{
const auto counter = ProfileEvents::counters[i];
const auto counter_increment = counter - prev_counters[i];
@ -95,7 +91,9 @@ private:
Daemon::instance().writeToGraphite(key_vals);
}
/// Значения счётчиков при предыдущей отправке (или нули, если ни разу не отправляли).
decltype(ProfileEvents::counters) prev_counters{};
bool quit = false;
std::mutex mutex;
std::condition_variable cond;