diff --git a/modules/grpc/common/grpc-dest-worker.cpp b/modules/grpc/common/grpc-dest-worker.cpp index d4f46d4a1..134b1cc21 100644 --- 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 index 313f7e6a0..d4a3d4ed7 100644 --- 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)