writelock

This commit is contained in:
Nikita Mikhaylov 2020-01-28 21:19:01 +03:00
parent 8cd434fb15
commit a8628134f2

View File

@ -867,6 +867,8 @@ 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());
@ -881,8 +883,6 @@ 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];