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

more lock_guard

Browse Source
This commit is contained in:
Nikita Mikhaylov 2020-06-10 18:44:28 +03:00 committed by GitHub
parent 8c19817575
commit bf262a3b04
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Interpreters/SystemLog.h
View File

@ -217,7 +217,7 @@ SystemLog<LogElement>::SystemLog(Context & context_,
template <typename LogElement>
void SystemLog<LogElement>::startup()
{
std::unique_lock lock(mutex);
std::lock_guard lock(mutex);
saving_thread = ThreadFromGlobalPool([this] { savingThreadFunction(); });
}
@ -231,7 +231,7 @@ void SystemLog<LogElement>::add(const LogElement & element)
/// Otherwise the tests like 01017_uniqCombined_memory_usage.sql will be flacky.
auto temporarily_disable_memory_tracker = getCurrentMemoryTrackerActionLock();
std::unique_lock lock(mutex);
std::lock_guard lock(mutex);
if (is_shutdown)
return;
@ -310,7 +310,7 @@ template <typename LogElement>
void SystemLog<LogElement>::stopFlushThread()
{
{
std::unique_lock lock(mutex);
std::lock_guard lock(mutex);
if (!saving_thread.joinable())
{
@ -423,7 +423,7 @@ void SystemLog<LogElement>::flushImpl(const std::vector<LogElement> & to_flush,
}
{
std::unique_lock lock(mutex);
std::lock_guard lock(mutex);
flushed_before = to_flush_end;
flush_event.notify_all();
}