File tree Expand file tree Collapse file tree 3 files changed +7
-0
lines changed Expand file tree Collapse file tree 3 files changed +7
-0
lines changed Original file line number Diff line number Diff line change @@ -16,6 +16,9 @@ void TDispatcherConfig::Register(TRegistrar registrar)
16
16
registrar.Parameter (" grpc_thread_count" , &TThis::GrpcThreadCount)
17
17
.GreaterThan (0 )
18
18
.Default (4 );
19
+ registrar.Parameter (" grpc_event_engine_thread_count" , &TThis::GrpcEventEngineThreadCount)
20
+ .GreaterThan (0 )
21
+ .Default (4 );
19
22
}
20
23
21
24
// //////////////////////////////////////////////////////////////////////////////
Original file line number Diff line number Diff line change @@ -18,6 +18,7 @@ class TDispatcherConfig
18
18
public:
19
19
int DispatcherThreadCount;
20
20
int GrpcThreadCount;
21
+ int GrpcEventEngineThreadCount;
21
22
22
23
REGISTER_YSON_STRUCT (TDispatcherConfig);
23
24
Original file line number Diff line number Diff line change 10
10
11
11
#include < contrib/libs/grpc/include/grpc/grpc.h>
12
12
13
+ #include < contrib/libs/grpc/src/core/lib/event_engine/thread_pool.h>
14
+
13
15
#include < contrib/libs/grpc/src/core/lib/iomgr/executor.h>
14
16
15
17
#include < atomic>
@@ -172,6 +174,7 @@ class TDispatcher::TImpl
172
174
YT_VERIFY (!IsInitialized ());
173
175
174
176
grpc_core::Executor::SetThreadsLimit (Config_->GrpcThreadCount );
177
+ grpc_event_engine::experimental::ThreadPool::SetThreadsLimit (Config_->GrpcEventEngineThreadCount );
175
178
176
179
// Initialize grpc only after configuration is done.
177
180
auto grpcLock = New<TGrpcLibraryLock>();
You can’t perform that action at this time.
0 commit comments