Skip to content

Commit a877b3b

Browse files
use fix size threads pool (#3180)
1 parent 96076b1 commit a877b3b

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

ydb/core/protos/flat_scheme_op.proto

+3
Original file line numberDiff line numberDiff line change
@@ -1019,6 +1019,9 @@ message TS3Settings {
10191019
optional uint32 RequestTimeoutMs = 101;
10201020
optional uint32 HttpRequestTimeoutMs = 102;
10211021
optional uint32 ConnectionTimeoutMs = 103;
1022+
1023+
optional uint32 ExecutorThreadsCount = 104 [default = 32];
1024+
optional uint32 MaxConnectionsCount = 105 [default = 32];
10221025
};
10231026

10241027
message TTaskCleaner {

ydb/core/wrappers/s3_storage_config.cpp

+2-2
Original file line numberDiff line numberDiff line change
@@ -107,10 +107,10 @@ Aws::Client::ClientConfiguration TS3ExternalStorageConfig::ConfigFromSettings(co
107107
if (settings.HasHttpRequestTimeoutMs()) {
108108
config.httpRequestTimeoutMs = settings.GetHttpRequestTimeoutMs();
109109
}
110-
config.executor = std::make_shared<Aws::Utils::Threading::PooledThreadExecutor>(1);
110+
config.executor = std::make_shared<Aws::Utils::Threading::PooledThreadExecutor>(settings.GetExecutorThreadsCount());
111111
config.enableTcpKeepAlive = true;
112112
// config.lowSpeedLimit = 0;
113-
config.maxConnections = 5;
113+
config.maxConnections = settings.HasMaxConnectionsCount() ? settings.GetMaxConnectionsCount() : settings.GetExecutorThreadsCount();
114114
config.caPath = "/etc/ssl/certs";
115115

116116
switch (settings.GetScheme()) {

0 commit comments

Comments
 (0)