thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-10-07 17:10:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

atomic added

Browse Source
This commit is contained in:
Nikita Mikhaylov 2020-01-29 13:58:44 +03:00
parent a8628134f2
commit 1f1fabba3b
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dbms/src/Dictionaries/CacheDictionary.cpp
View File

@ -867,8 +867,6 @@ void CacheDictionary::update(const std::vector<Key> & requested_ids, std::unorde
stream->readPrefix();
const ProfilingScopedWriteRWLock write_lock{rw_lock, ProfileEvents::DictCacheLockWriteNs};
while (const auto block = stream->read())
{
const auto id_column = typeid_cast<const ColumnUInt64 *>(block.safeGetByPosition(0).column.get());
@ -883,6 +881,8 @@ void CacheDictionary::update(const std::vector<Key> & requested_ids, std::unorde
ext::range(0, attributes.size()),
[&block](size_t i) { return block.safeGetByPosition(i + 1).column.get(); });
const ProfilingScopedWriteRWLock write_lock{rw_lock, ProfileEvents::DictCacheLockWriteNs};
for (const auto i : ext::range(0, ids.size()))
{
const auto id = ids[i];

2
dbms/src/Dictionaries/CacheDictionary.h
View File

@ -319,7 +319,7 @@ private:
std::unique_ptr<ArenaWithFreeLists> string_arena;
mutable std::exception_ptr last_exception;
mutable size_t error_count = 0;
mutable std::atomic<size_t> error_count = 0;
mutable std::chrono::system_clock::time_point backoff_end_time;
mutable pcg64 rnd_engine;