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

Update FileCache.cpp

Browse Source
This commit is contained in:
Kseniia Sumarokova 2023-08-07 14:27:38 +02:00 committed by GitHub
parent 6f6434d50d
commit 57d9697e21
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1023,7 +1023,7 @@ void FileCache::loadMetadataForKeys(const fs::path & keys_dir)
if (limits_satisfied) if (limits_satisfied)
{ {
KeyMetadata::iterator file_segment_metadata_it; bool inserted = false;
try try
{ {
auto file_segment = std::make_shared<FileSegment>(key, offset, size, auto file_segment = std::make_shared<FileSegment>(key, offset, size,
@ -1033,21 +1033,20 @@ void FileCache::loadMetadataForKeys(const fs::path & keys_dir)
key_metadata, key_metadata,
cache_it); cache_it);
auto [_, inserted] = key_metadata->emplace(offset, std::make_shared<FileSegmentMetadata>(std::move(file_segment))); inserted = key_metadata->emplace(offset, std::make_shared<FileSegmentMetadata>(std::move(file_segment))).second;
if (!inserted)
{
cache_it->remove(lockCache());
chassert(false);
}
} }
catch (...) catch (...)
{ {
tryLogCurrentException(__PRETTY_FUNCTION__); tryLogCurrentException(__PRETTY_FUNCTION__);
chassert(false); chassert(false);
}
if (!inserted)
{
cache_it->remove(lockCache()); cache_it->remove(lockCache());
fs::remove(offset_it->path()); fs::remove(offset_it->path());
continue; chassert(false);
} }
} }
else else