diff --git a/ydb/core/tx/columnshard/counters/engine_logs.cpp b/ydb/core/tx/columnshard/counters/engine_logs.cpp index 26c8b99f502a..becf24716a5d 100644 --- a/ydb/core/tx/columnshard/counters/engine_logs.cpp +++ b/ydb/core/tx/columnshard/counters/engine_logs.cpp @@ -91,24 +91,24 @@ void TEngineLogsCounters::OnActualizationTask(const ui32 evictCount, const ui32 } } -void TEngineLogsCounters::TPortionsInfoGuard::OnNewPortion(const std::shared_ptr& portion) const { +void TEngineLogsCounters::TPortionsInfoGuard::OnNewPortion(const std::shared_ptr& portion) { const ui32 producedId = (ui32)portion->GetProduced(); PortionRecordCountGuards[producedId]->Add(portion->GetRecordsCount(), 1); PortionSizeGuards[producedId]->Add(portion->GetTotalBlobBytes(), 1); if (portion->GetTotalBlobBytes() <= GetBadPortionSizeLimit()) { - BadPortionsCount->Add(1); + BadPortionsCount.Add(1); } } -void TEngineLogsCounters::TPortionsInfoGuard::OnDropPortion(const std::shared_ptr& portion) const { +void TEngineLogsCounters::TPortionsInfoGuard::OnDropPortion(const std::shared_ptr& portion) { const ui32 producedId = (ui32)portion->GetProduced(); THashSet blobIds; PortionRecordCountGuards[producedId]->Sub(portion->GetRecordsCount(), 1); PortionSizeGuards[producedId]->Sub(portion->GetTotalBlobBytes(), 1); if (portion->GetTotalBlobBytes() <= GetBadPortionSizeLimit()) { - BadPortionsCount->Sub(1); + BadPortionsCount.Sub(1); } } diff --git a/ydb/core/tx/columnshard/counters/engine_logs.h b/ydb/core/tx/columnshard/counters/engine_logs.h index f9f33a90a10a..1ecd840ead43 100644 --- a/ydb/core/tx/columnshard/counters/engine_logs.h +++ b/ydb/core/tx/columnshard/counters/engine_logs.h @@ -241,13 +241,14 @@ class TEngineLogsCounters: public TCommonCountersOwner { std::vector> BlobGuards; std::vector> PortionRecordCountGuards; std::vector> PortionSizeGuards; - NMonitoring::TDynamicCounters::TCounterPtr BadPortionsCount; + TValueGuard BadPortionsCount; public: TPortionsInfoGuard(const std::vector>& distrBlobs, const std::vector>& distrPortionSize, const std::vector>& distrRecordsCount, - NMonitoring::TDynamicCounters::TCounterPtr badPortionsCount) + NMonitoring::TDynamicCounters::TCounterPtr badPortionsCount) : + BadPortionsCount(badPortionsCount) { for (auto&& i : distrBlobs) { BlobGuards.emplace_back(i->BuildGuard()); @@ -258,12 +259,11 @@ class TEngineLogsCounters: public TCommonCountersOwner { for (auto&& i : distrRecordsCount) { PortionRecordCountGuards.emplace_back(i->BuildGuard()); } - BadPortionsCount = badPortionsCount; } - void OnNewPortion(const std::shared_ptr& portion) const; - void OnDropPortion(const std::shared_ptr& portion) const; + void OnNewPortion(const std::shared_ptr& portion); + void OnDropPortion(const std::shared_ptr& portion); };