diff options
author | lukyan <lukyan@yandex-team.com> | 2024-07-13 20:05:53 +0300 |
---|---|---|
committer | lukyan <lukyan@yandex-team.com> | 2024-07-13 20:16:27 +0300 |
commit | b2f8390ca4db821f0f448fbeac528cb84a2a6d1b (patch) | |
tree | f6d5910a246680b8241110ade416fa4dc5bf7183 /yt | |
parent | 84c0a5dced896c21bb6b5252edb39fe779e54d00 (diff) | |
download | ydb-b2f8390ca4db821f0f448fbeac528cb84a2a6d1b.tar.gz |
YT-20430: Drop EPollablePriority
c44335fe13601ff82f864a11f1947a605a91c48e
Diffstat (limited to 'yt')
-rw-r--r-- | yt/yt/core/bus/tcp/connection.cpp | 10 | ||||
-rw-r--r-- | yt/yt/core/bus/tcp/connection.h | 1 | ||||
-rw-r--r-- | yt/yt/core/concurrency/pollable_detail.cpp | 5 | ||||
-rw-r--r-- | yt/yt/core/concurrency/pollable_detail.h | 2 | ||||
-rw-r--r-- | yt/yt/core/concurrency/poller.h | 11 | ||||
-rw-r--r-- | yt/yt/core/concurrency/unittests/thread_pool_poller_ut.cpp | 5 |
6 files changed, 0 insertions, 34 deletions
diff --git a/yt/yt/core/bus/tcp/connection.cpp b/yt/yt/core/bus/tcp/connection.cpp index 650c7c50f1..5a26424aad 100644 --- a/yt/yt/core/bus/tcp/connection.cpp +++ b/yt/yt/core/bus/tcp/connection.cpp @@ -288,16 +288,6 @@ void TTcpConnection::RunPeriodicCheck() } } -EPollablePriority TTcpConnection::GetPriority() const -{ - switch (MultiplexingBand_.load(std::memory_order::relaxed)) { - case EMultiplexingBand::RealTime: - return EPollablePriority::RealTime; - default: - return EPollablePriority::Normal; - } -} - const TString& TTcpConnection::GetLoggingTag() const { return LoggingTag_; diff --git a/yt/yt/core/bus/tcp/connection.h b/yt/yt/core/bus/tcp/connection.h index 81e2c4a3a0..ed395db9df 100644 --- a/yt/yt/core/bus/tcp/connection.h +++ b/yt/yt/core/bus/tcp/connection.h @@ -99,7 +99,6 @@ public: TBusNetworkStatistics GetBusStatistics() const; // IPollable implementation. - NConcurrency::EPollablePriority GetPriority() const override; const TString& GetLoggingTag() const override; void OnEvent(NConcurrency::EPollControl control) override; void OnShutdown() override; diff --git a/yt/yt/core/concurrency/pollable_detail.cpp b/yt/yt/core/concurrency/pollable_detail.cpp index 991a8eea91..b7c0622421 100644 --- a/yt/yt/core/concurrency/pollable_detail.cpp +++ b/yt/yt/core/concurrency/pollable_detail.cpp @@ -14,11 +14,6 @@ void* TPollableBase::GetCookie() const return Cookie_.Get(); } -EPollablePriority TPollableBase::GetPriority() const -{ - return EPollablePriority::Normal; -} - //////////////////////////////////////////////////////////////////////////////// } // namespace NYT::NConcurrency diff --git a/yt/yt/core/concurrency/pollable_detail.h b/yt/yt/core/concurrency/pollable_detail.h index 4270e7c270..62bc27eb51 100644 --- a/yt/yt/core/concurrency/pollable_detail.h +++ b/yt/yt/core/concurrency/pollable_detail.h @@ -14,8 +14,6 @@ public: void SetCookie(TCookiePtr cookie) override; void* GetCookie() const override; - EPollablePriority GetPriority() const override; - private: TCookiePtr Cookie_; }; diff --git a/yt/yt/core/concurrency/poller.h b/yt/yt/core/concurrency/poller.h index 30340eea85..4e7b7dd4c0 100644 --- a/yt/yt/core/concurrency/poller.h +++ b/yt/yt/core/concurrency/poller.h @@ -25,13 +25,6 @@ DEFINE_BIT_ENUM(EPollControl, ((Shutdown) (0x400)) // Shutdown in progress (for external use) ); -//! Poller may provide separate sets of threads for handling pollables of -//! various priorities. -DEFINE_ENUM(EPollablePriority, - ((Normal) (0)) - ((RealTime) (1)) -); - //////////////////////////////////////////////////////////////////////////////// //! Describes an FD-backed pollable entity. @@ -50,10 +43,6 @@ struct IPollable //! Returns a human-readable string used for diagnostic purposes. virtual const TString& GetLoggingTag() const = 0; - //! Returns the priority of this pollable. - //! The result need not be stable (i.e. may vary across calls). - virtual EPollablePriority GetPriority() const = 0; - //! Called by the poller when the appropriate event is triggered for the FD. virtual void OnEvent(EPollControl control) = 0; diff --git a/yt/yt/core/concurrency/unittests/thread_pool_poller_ut.cpp b/yt/yt/core/concurrency/unittests/thread_pool_poller_ut.cpp index 9f939a971b..a4760ad45f 100644 --- a/yt/yt/core/concurrency/unittests/thread_pool_poller_ut.cpp +++ b/yt/yt/core/concurrency/unittests/thread_pool_poller_ut.cpp @@ -43,11 +43,6 @@ public: return LoggingTag_; } - EPollablePriority GetPriority() const override - { - return EPollablePriority::Normal; - } - void OnEvent(EPollControl control) override { // NB: Retry is the only event we trigger in this unittest via |IPoller::Retry|. |