grpc: use local subchannel pool

Signed-off-by: Attila Szakacs <[email protected]>
axoflow · Oct 11, 2024 · 618c0c3 · 618c0c3
1 parent 546d4cc
commit 618c0c3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/modules/grpc/common/grpc-dest-worker.cpp b/modules/grpc/common/grpc-dest-worker.cpp
@@ -64,6 +64,7 @@ DestWorker::create_channel_args()
     args.SetCompressionAlgorithm(GRPC_COMPRESS_GZIP);
 
   args.SetInt(GRPC_ARG_KEEPALIVE_PERMIT_WITHOUT_CALLS, 1);
+  args.SetInt(GRPC_ARG_USE_LOCAL_SUBCHANNEL_POOL, 1);
 
   for (auto nv : this->owner.int_extra_channel_args)
     args.SetInt(nv.first, nv.second);

diff --git a/modules/grpc/common/grpc-source.cpp b/modules/grpc/common/grpc-source.cpp
@@ -74,6 +74,8 @@ SourceDriver::prepare_server_builder(::grpc::ServerBuilder &builder)
 
   builder.AddListeningPort(address, credentials_builder.build());
 
+  builder.AddChannelArgument(GRPC_ARG_USE_LOCAL_SUBCHANNEL_POOL, 1);
+
   for (auto nv : int_extra_channel_args)
     builder.AddChannelArgument(nv.first, nv.second);
   for (auto nv : string_extra_channel_args)