diff options
| author | babenko <babenko@yandex-team.com> | 2023-10-12 10:56:20 +0300 |
|---|---|---|
| committer | babenko <babenko@yandex-team.com> | 2023-10-12 11:28:34 +0300 |
| commit | fbb4e87f5de695c8ddca851a91897ec9665ba029 (patch) | |
| tree | ae6ca342490a4df9f00eebc276ae553b8c215ca0 | |
| parent | 426ead52ebd315acd7e95161aa310378ccdabb53 (diff) | |
| download | ydb-fbb4e87f5de695c8ddca851a91897ec9665ba029.tar.gz | |
Cosmetics
| -rw-r--r-- | yt/yt/core/concurrency/thread_pool_poller.cpp | 7 | ||||
| -rw-r--r-- | yt/yt/core/concurrency/thread_pool_poller.h | 2 |
2 files changed, 6 insertions, 3 deletions
diff --git a/yt/yt/core/concurrency/thread_pool_poller.cpp b/yt/yt/core/concurrency/thread_pool_poller.cpp index 121057dd4d..cc3d69a4f9 100644 --- a/yt/yt/core/concurrency/thread_pool_poller.cpp +++ b/yt/yt/core/concurrency/thread_pool_poller.cpp @@ -135,7 +135,10 @@ class TThreadPoolPoller , public NThreading::TThread { public: - TThreadPoolPoller(int threadCount, const TString& threadNamePrefix, const TDuration pollingPeriod) + TThreadPoolPoller( + int threadCount, + const TString& threadNamePrefix, + TDuration pollingPeriod) : TThread(Format("%v:%v", threadNamePrefix, "Poll")) , Logger(ConcurrencyLogger.WithTag("ThreadNamePrefix: %v", threadNamePrefix)) { @@ -424,7 +427,7 @@ private: IThreadPoolPollerPtr CreateThreadPoolPoller( int threadCount, const TString& threadNamePrefix, - const TDuration pollingPeriod) + TDuration pollingPeriod) { auto poller = New<TThreadPoolPoller>(threadCount, threadNamePrefix, pollingPeriod); poller->Start(); diff --git a/yt/yt/core/concurrency/thread_pool_poller.h b/yt/yt/core/concurrency/thread_pool_poller.h index 4bfa95f590..5083439fdf 100644 --- a/yt/yt/core/concurrency/thread_pool_poller.h +++ b/yt/yt/core/concurrency/thread_pool_poller.h @@ -20,7 +20,7 @@ DEFINE_REFCOUNTED_TYPE(IThreadPoolPoller) IThreadPoolPollerPtr CreateThreadPoolPoller( int threadCount, const TString& threadNamePrefix, - const TDuration pollingPeriod = TDuration::MilliSeconds(10)); + TDuration pollingPeriod = TDuration::MilliSeconds(10)); //////////////////////////////////////////////////////////////////////////////// |