aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--library/cpp/yt/containers/expiring_set-inl.h8
-rw-r--r--library/cpp/yt/containers/expiring_set.h4
-rw-r--r--library/cpp/yt/containers/unittests/expiring_set_ut.cpp14
-rw-r--r--yt/yt/core/logging/log_manager.cpp2
4 files changed, 14 insertions, 14 deletions
diff --git a/library/cpp/yt/containers/expiring_set-inl.h b/library/cpp/yt/containers/expiring_set-inl.h
index 66cab7203b..5bc000395c 100644
--- a/library/cpp/yt/containers/expiring_set-inl.h
+++ b/library/cpp/yt/containers/expiring_set-inl.h
@@ -9,16 +9,16 @@ namespace NYT {
////////////////////////////////////////////////////////////////////////////////
template <class TItem, class THash, class TEqual>
-void TExpiringSet<TItem, THash, TEqual>::SetTTl(TDuration ttl)
+void TExpiringSet<TItem, THash, TEqual>::SetTtl(TDuration ttl)
{
- TTl_ = ttl;
+ Ttl_ = ttl;
}
template <class TItem, class THash, class TEqual>
void TExpiringSet<TItem, THash, TEqual>::Insert(TInstant now, const TItem& item)
{
Expire(now);
- auto deadline = now + TTl_;
+ auto deadline = now + Ttl_;
ItemToDeadline_[item] = deadline;
ExpirationQueue_.push(TItemPack{.Items = {item}, .Deadline = deadline});
}
@@ -28,7 +28,7 @@ template <class TItems>
void TExpiringSet<TItem, THash, TEqual>::InsertMany(TInstant now, const TItems& items)
{
Expire(now);
- auto deadline = now + TTl_;
+ auto deadline = now + Ttl_;
for (const auto& item : items) {
ItemToDeadline_[item] = deadline;
}
diff --git a/library/cpp/yt/containers/expiring_set.h b/library/cpp/yt/containers/expiring_set.h
index 101c7d8ac1..44e9d7e07d 100644
--- a/library/cpp/yt/containers/expiring_set.h
+++ b/library/cpp/yt/containers/expiring_set.h
@@ -15,7 +15,7 @@ template <class TItem, class THash = THash<TItem>, class TEqual = TEqualTo<TItem
class TExpiringSet
{
public:
- void SetTTl(TDuration ttl);
+ void SetTtl(TDuration ttl);
void Insert(TInstant now, const TItem& item);
template <class TItems>
@@ -33,7 +33,7 @@ public:
int GetSize() const;
private:
- TDuration TTl_;
+ TDuration Ttl_;
struct TItemPack
{
diff --git a/library/cpp/yt/containers/unittests/expiring_set_ut.cpp b/library/cpp/yt/containers/unittests/expiring_set_ut.cpp
index 2de32c1f3f..96e09d6416 100644
--- a/library/cpp/yt/containers/unittests/expiring_set_ut.cpp
+++ b/library/cpp/yt/containers/unittests/expiring_set_ut.cpp
@@ -23,7 +23,7 @@ TEST(TExpiringSetTest, Empty)
TEST(TExpiringSetTest, ExpireSingle)
{
TExpiringSet<int> set;
- set.SetTTl(TDuration::Seconds(2));
+ set.SetTtl(TDuration::Seconds(2));
set.Insert(0_ts, 1);
EXPECT_EQ(set.GetSize(), 1);
@@ -38,7 +38,7 @@ TEST(TExpiringSetTest, ExpireSingle)
TEST(TExpiringSetTest, ExpireBatch)
{
TExpiringSet<int> set;
- set.SetTTl(TDuration::Seconds(2));
+ set.SetTtl(TDuration::Seconds(2));
set.InsertMany(0_ts, std::vector<int>{1, 2, 3});
EXPECT_EQ(set.GetSize(), 3);
@@ -53,7 +53,7 @@ TEST(TExpiringSetTest, ExpireBatch)
TEST(TExpiringSetTest, Reinsert)
{
TExpiringSet<int> set;
- set.SetTTl(TDuration::Seconds(2));
+ set.SetTtl(TDuration::Seconds(2));
set.Insert(0_ts, 1);
EXPECT_EQ(set.GetSize(), 1);
@@ -71,7 +71,7 @@ TEST(TExpiringSetTest, Reinsert)
TEST(TExpiringSetTest, Contains)
{
TExpiringSet<int> set;
- set.SetTTl(TDuration::Seconds(1));
+ set.SetTtl(TDuration::Seconds(1));
EXPECT_FALSE(set.Contains(1));
@@ -85,7 +85,7 @@ TEST(TExpiringSetTest, Contains)
TEST(TExpiringSetTest, Clear)
{
TExpiringSet<int> set;
- set.SetTTl(TDuration::Seconds(1));
+ set.SetTtl(TDuration::Seconds(1));
set.Insert(0_ts, 1);
EXPECT_EQ(set.GetSize(), 1);
@@ -99,7 +99,7 @@ TEST(TExpiringSetTest, Clear)
TEST(TExpiringSetTest, RemoveBeforeExpire)
{
TExpiringSet<int> set;
- set.SetTTl(TDuration::Seconds(1));
+ set.SetTtl(TDuration::Seconds(1));
set.Insert(0_ts, 1);
EXPECT_EQ(set.GetSize(), 1);
@@ -113,7 +113,7 @@ TEST(TExpiringSetTest, RemoveBeforeExpire)
TEST(TExpiringSetTest, RemoveAfterExpire)
{
TExpiringSet<int> set;
- set.SetTTl(TDuration::Seconds(1));
+ set.SetTtl(TDuration::Seconds(1));
set.Insert(0_ts, 1);
set.Expire(2_ts);
diff --git a/yt/yt/core/logging/log_manager.cpp b/yt/yt/core/logging/log_manager.cpp
index 1635715905..5209a25373 100644
--- a/yt/yt/core/logging/log_manager.cpp
+++ b/yt/yt/core/logging/log_manager.cpp
@@ -859,7 +859,7 @@ private:
CompressionThreadPool_->Configure(Config_->CompressionThreadCount);
if (RequestSuppressionEnabled_) {
- SuppressedRequestIdSet_.SetTTl((Config_->RequestSuppressionTimeout + DequeuePeriod) * 2);
+ SuppressedRequestIdSet_.SetTtl((Config_->RequestSuppressionTimeout + DequeuePeriod) * 2);
} else {
SuppressedRequestIdSet_.Clear();
SuppressedRequestIdQueue_.DequeueAll();