diff options
author | capone212 <capone212@yandex-team.com> | 2024-06-22 16:11:18 +0300 |
---|---|---|
committer | capone212 <capone212@yandex-team.com> | 2024-06-22 16:20:37 +0300 |
commit | f5a4da167ff17171da0c8309d1d98b3d614bfae6 (patch) | |
tree | 363fb59009c8756532b63d7593b6b83b99cf02f8 | |
parent | ce7290ebbdeb010502ede0b26ea23dee94661841 (diff) | |
download | ydb-f5a4da167ff17171da0c8309d1d98b3d614bfae6.tar.gz |
YT-21906: Throttling collocated network trafic for tab nodes
YT-21906: Throttling collocated network trafic for tab nodes
cf0cee7f7eb6ea0c19215dcef89a1c1f07a4d37d
-rw-r--r-- | yt/yt/client/chunk_client/config.cpp | 3 | ||||
-rw-r--r-- | yt/yt/client/chunk_client/config.h | 4 |
2 files changed, 6 insertions, 1 deletions
diff --git a/yt/yt/client/chunk_client/config.cpp b/yt/yt/client/chunk_client/config.cpp index c7431e126b..49195d4df7 100644 --- a/yt/yt/client/chunk_client/config.cpp +++ b/yt/yt/client/chunk_client/config.cpp @@ -289,6 +289,9 @@ void TReplicationWriterConfig::Register(TRegistrar registrar) registrar.Parameter("testing_delay", &TThis::TestingDelay) .Default(); + registrar.Parameter("enable_local_throttling", &TThis::EnableLocalThrottling) + .Default(false); + registrar.Preprocessor([] (TThis* config) { config->NodeChannel->RetryBackoffTime = TDuration::Seconds(10); config->NodeChannel->RetryAttempts = 100; diff --git a/yt/yt/client/chunk_client/config.h b/yt/yt/client/chunk_client/config.h index 9683176ee8..1904cf0a2a 100644 --- a/yt/yt/client/chunk_client/config.h +++ b/yt/yt/client/chunk_client/config.h @@ -235,7 +235,6 @@ public: //! If |true| reader will retain a set of peers that will be banned for every session. bool BanPeersPermanently; - //! For testing purposes. //! If |true| network throttlers will be applied even in case of requests to local host. bool EnableLocalThrottling; @@ -366,6 +365,9 @@ public: std::optional<TDuration> TestingDelay; + //! If |true| network throttlers will be applied even in case of requests to local host. + bool EnableLocalThrottling; + int GetDirectUploadNodeCount(); REGISTER_YSON_STRUCT(TReplicationWriterConfig); |