diff options
author | danlark <danlark@yandex-team.ru> | 2022-02-10 16:46:08 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:08 +0300 |
commit | 3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (patch) | |
tree | 26154e1e9990f1bb4525d3e3fb5b6dac2c2c1da2 /ydb/core/persqueue/pq_l2_cache.cpp | |
parent | cb68f224c46a8ee52ac3fdd2a32534b8bb8dc134 (diff) | |
download | ydb-3426a9bc7f169ae9da54cef557ad2a33f6e8eee0.tar.gz |
Restoring authorship annotation for <danlark@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'ydb/core/persqueue/pq_l2_cache.cpp')
-rw-r--r-- | ydb/core/persqueue/pq_l2_cache.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/persqueue/pq_l2_cache.cpp b/ydb/core/persqueue/pq_l2_cache.cpp index e56642c39a..0254af0aab 100644 --- a/ydb/core/persqueue/pq_l2_cache.cpp +++ b/ydb/core/persqueue/pq_l2_cache.cpp @@ -97,7 +97,7 @@ void TPersQueueCacheL2::AddBlobs(const TActorContext& ctx, TString topic, const auto oldest = Cache.FindOldest(); Y_VERIFY(oldest != Cache.End(), "Topic '%s' count %" PRIu64 " size %" PRIu64 " maxSize %" PRIu64 " blobSize %" PRIu64 " blobs %" PRIu64 " evicted %" PRIu64, - topic.data(), Cache.Size(), CurrentSize, MaxSize, blob.Value->DataSize(), blobs.size(), outEvicted.size()); + topic.data(), Cache.Size(), CurrentSize, MaxSize, blob.Value->DataSize(), blobs.size(), outEvicted.size()); TCacheValue::TPtr value = oldest.Value(); outEvicted.insert({oldest.Key(), value}); @@ -202,7 +202,7 @@ void TPersQueueCacheL2::Handle(NMon::TEvHttpInfo::TPtr& ev, const TActorContext& if (params.Has("submit")) { TString strParam = params.Get("newCacheLimit"); if (strParam.size()) { - ui32 valueMb = atoll(strParam.data()); + ui32 valueMb = atoll(strParam.data()); MaxSize = SizeInBytes(valueMb); // will be applyed at next AddBlobs } } |