thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-13 01:41:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix tsan in test test_temporary_data_in_cache

Browse Source
This commit is contained in:
kssenii 2023-04-19 17:48:56 +02:00
parent 67d695580a
commit 69de3a3c2d
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Interpreters/Cache/FileCache.cpp
View File

@ -34,8 +34,6 @@ FileCache::FileCache(const FileCacheSettings & settings)
if (settings.enable_filesystem_query_cache_limit) if (settings.enable_filesystem_query_cache_limit)
query_limit = std::make_unique<FileCacheQueryLimit>(); query_limit = std::make_unique<FileCacheQueryLimit>();
cleanup_task = Context::getGlobalContextInstance()->getSchedulePool().createTask("FileCacheCleanup", [this]{ cleanupThreadFunc(); });
} }
FileCache::Key FileCache::createKeyForPath(const String & path) FileCache::Key FileCache::createKeyForPath(const String & path)
@ -99,6 +97,8 @@ void FileCache::initialize()
} }
is_initialized = true; is_initialized = true;
cleanup_task = Context::getGlobalContextInstance()->getSchedulePool().createTask("FileCacheCleanup", [this]{ cleanupThreadFunc(); });
cleanup_task->activate(); cleanup_task->activate();
cleanup_task->scheduleAfter(delayed_cleanup_interval_ms); cleanup_task->scheduleAfter(delayed_cleanup_interval_ms);
} }