thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-12 09:22:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Better comment

Browse Source
This commit is contained in:
kssenii 2023-03-26 22:10:14 +02:00
parent e6e71dc832
commit 1adef76cbd
2 changed files with 5 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/Interpreters/Cache/Metadata.cpp
View File

@ -141,10 +141,11 @@ void CacheMetadata::doCleanup()
auto key_metadata = it->second;
auto key_lock = key_metadata->lock();
/// As in lockKeyMetadata we extract key metadata from cache metadata
/// under CacheMetadataGuard::Lock, but take KeyGuard::Lock only after we
/// released cache CacheMetadataGuard::Lock, then we must to take into
/// account it here.
/// As in lockKeyMetadata we extract key metadata from cache metadata under
/// CacheMetadataGuard::Lock, but take KeyGuard::Lock only after we released
/// cache CacheMetadataGuard::Lock (because CacheMetadataGuard::Lock must be lightweight).
/// So it is possible that a key which was submitted to cleanup queue was afterwards added
/// to cache, so here we need to check this case.
if (key_metadata->getCleanupState(key_lock) == KeyMetadata::CleanupState::NOT_SUBMITTED)
continue;

13
src/Interpreters/tests/gtest_lru_file_cache.cpp
View File

@ -189,36 +189,23 @@ TEST_F(FileCacheTest, get)
std::cerr << "Step 1\n";
auto cache = FileCache(cache_base_path, settings);
std::cerr << "Step 1\n";
cache.initialize();
std::cerr << "Step 1\n";
auto key = cache.createKeyForPath("key1");
std::cerr << "Step 1\n";
{
std::cerr << "Step 1\n";
auto holder = cache.getOrSet(key, 0, 10, {}); /// Add range [0, 9]
std::cerr << "Step 1\n";
assertEqual(holder, { Range(0, 9) }, { State::EMPTY });
std::cerr << "Step 1\n";
download(holder->front());
std::cerr << "Step 1\n";
assertEqual(holder, { Range(0, 9) }, { State::DOWNLOADED });
std::cerr << "Step 1\n";
}
/// Current cache: [__________]
/// ^ ^
/// 0 9
std::cerr << "Step 1\n";
assertEqual(cache.getSnapshot(key), { Range(0, 9) });
std::cerr << "Step 1\n";
assertEqual(cache.dumpQueue(), { Range(0, 9) });
std::cerr << "Step 1\n";
ASSERT_EQ(cache.getFileSegmentsNum(), 1);
std::cerr << "Step 1\n";
ASSERT_EQ(cache.getUsedCacheSize(), 10);
std::cerr << "Step 1\n";
std::cerr << "Step 2\n";