aboutsummaryrefslogtreecommitdiffstats
path: root/ydb/core/persqueue/pq_l2_cache.cpp
diff options
context:
space:
mode:
authordanlark <danlark@yandex-team.ru>2022-02-10 16:46:08 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:08 +0300
commit3426a9bc7f169ae9da54cef557ad2a33f6e8eee0 (patch)
tree26154e1e9990f1bb4525d3e3fb5b6dac2c2c1da2 /ydb/core/persqueue/pq_l2_cache.cpp
parentcb68f224c46a8ee52ac3fdd2a32534b8bb8dc134 (diff)
downloadydb-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.cpp4
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
}
}