thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-30 19:42:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

I do not want to think about this code

Browse Source
This commit is contained in:
Alexey Milovidov 2024-07-28 20:23:00 +02:00
parent 47af56e9c0
commit f2b8431867
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/Storages/MergeTree/MergeTreeData.cpp
View File

@ -4405,25 +4405,25 @@ bool MergeTreeData::tryRemovePartImmediately(DataPartPtr && part)
size_t MergeTreeData::getTotalActiveSizeInBytes() const size_t MergeTreeData::getTotalActiveSizeInBytes() const
{ {
return total_active_size_bytes.load(std::memory_order_acquire); return total_active_size_bytes.load();
} }
size_t MergeTreeData::getTotalActiveSizeInRows() const size_t MergeTreeData::getTotalActiveSizeInRows() const
{ {
return total_active_size_rows.load(std::memory_order_acquire); return total_active_size_rows.load();
} }
size_t MergeTreeData::getActivePartsCount() const size_t MergeTreeData::getActivePartsCount() const
{ {
return total_active_size_parts.load(std::memory_order_acquire); return total_active_size_parts.load();
} }
size_t MergeTreeData::getOutdatedPartsCount() const size_t MergeTreeData::getOutdatedPartsCount() const
{ {
return total_outdated_parts_count.load(std::memory_order_relaxed); return total_outdated_parts_count.load();
} }
size_t MergeTreeData::getNumberOfOutdatedPartsWithExpiredRemovalTime() const size_t MergeTreeData::getNumberOfOutdatedPartsWithExpiredRemovalTime() const
@ -8184,16 +8184,16 @@ void MergeTreeData::removePartContributionToDataVolume(const DataPartPtr & part)
void MergeTreeData::increaseDataVolume(ssize_t bytes, ssize_t rows, ssize_t parts) void MergeTreeData::increaseDataVolume(ssize_t bytes, ssize_t rows, ssize_t parts)
{ {
total_active_size_bytes.fetch_add(bytes, std::memory_order_acq_rel); total_active_size_bytes.fetch_add(bytes);
total_active_size_rows.fetch_add(rows, std::memory_order_acq_rel); total_active_size_rows.fetch_add(rows);
total_active_size_parts.fetch_add(parts, std::memory_order_acq_rel); total_active_size_parts.fetch_add(parts);
} }
void MergeTreeData::setDataVolume(size_t bytes, size_t rows, size_t parts) void MergeTreeData::setDataVolume(size_t bytes, size_t rows, size_t parts)
{ {
total_active_size_bytes.store(bytes, std::memory_order_release); total_active_size_bytes.store(bytes);
total_active_size_rows.store(rows, std::memory_order_release); total_active_size_rows.store(rows);
total_active_size_parts.store(parts, std::memory_order_release); total_active_size_parts.store(parts);
} }
bool MergeTreeData::insertQueryIdOrThrow(const String & query_id, size_t max_queries) const bool MergeTreeData::insertQueryIdOrThrow(const String & query_id, size_t max_queries) const