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

remove unused mutex

Browse Source
This commit is contained in:
Nikita Mikhaylov 2019-10-23 16:23:42 +03:00
parent c867d7a306
commit 8b17ce492f
2 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dbms/src/DataStreams/ParallelParsingBlockInputStream.cpp
View File

@ -81,10 +81,7 @@ void ParallelParsingBlockInputStream::parserThreadFunction(size_t current_unit_n
auto block = readers[current_unit_number]->read(); auto block = readers[current_unit_number]->read();
blocks[current_unit_number].block.push_back(block); blocks[current_unit_number].block.push_back(block);
{ blocks[current_unit_number].block_missing_values.push_back(readers[current_unit_number]->getMissingValues());
std::lock_guard missing_values_lock(missing_values_mutex);
blocks[current_unit_number].block_missing_values.push_back(readers[current_unit_number]->getMissingValues());
}
if (block == Block()) if (block == Block())
break; break;

2
dbms/src/DataStreams/ParallelParsingBlockInputStream.h
View File

@ -106,7 +106,6 @@ protected:
const BlockMissingValues & getMissingValues() const override const BlockMissingValues & getMissingValues() const override
{ {
std::lock_guard missing_values_lock(missing_values_mutex);
return last_block_missing_values; return last_block_missing_values;
} }
@ -118,7 +117,6 @@ private:
std::atomic<bool> is_exception_occured{false}; std::atomic<bool> is_exception_occured{false};
BlockMissingValues last_block_missing_values; BlockMissingValues last_block_missing_values;
mutable std::mutex missing_values_mutex;
// Original ReadBuffer to read from. // Original ReadBuffer to read from.
ReadBuffer & original_buffer; ReadBuffer & original_buffer;