aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorcapone212 <capone212@yandex-team.com>2024-06-22 16:11:18 +0300
committercapone212 <capone212@yandex-team.com>2024-06-22 16:20:37 +0300
commitf5a4da167ff17171da0c8309d1d98b3d614bfae6 (patch)
tree363fb59009c8756532b63d7593b6b83b99cf02f8
parentce7290ebbdeb010502ede0b26ea23dee94661841 (diff)
downloadydb-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.cpp3
-rw-r--r--yt/yt/client/chunk_client/config.h4
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);