提交 c594cf11 编写于 作者: J Jin Hai 提交者: JinHai-CN

Increase GRPC concurrency (#2671)

* Increase GRPC concurrency
Signed-off-by: NJinHai-CN <hai.jin@zilliz.com>

* Fix lint
Signed-off-by: NJinHai-CN <hai.jin@zilliz.com>

* Add limitation
Signed-off-by: NJinHai-CN <hai.jin@zilliz.com>

* Fix compilation error
Signed-off-by: NJinHai-CN <hai.jin@zilliz.com>

* Fix compilation error
Signed-off-by: NJinHai-CN <hai.jin@zilliz.com>

* Fix compilation error
Signed-off-by: NJinHai-CN <hai.jin@zilliz.com>
上级 3cbb5cee
...@@ -21,6 +21,7 @@ ...@@ -21,6 +21,7 @@
#include <grpcpp/create_channel.h> #include <grpcpp/create_channel.h>
#include <grpcpp/security/credentials.h> #include <grpcpp/security/credentials.h>
#include <algorithm>
#include <chrono> #include <chrono>
#include <iostream> #include <iostream>
#include <memory> #include <memory>
...@@ -49,7 +50,10 @@ class NoReusePortOption : public ::grpc::ServerBuilderOption { ...@@ -49,7 +50,10 @@ class NoReusePortOption : public ::grpc::ServerBuilderOption {
void void
UpdateArguments(::grpc::ChannelArguments* args) override { UpdateArguments(::grpc::ChannelArguments* args) override {
args->SetInt(GRPC_ARG_ALLOW_REUSEPORT, 0); args->SetInt(GRPC_ARG_ALLOW_REUSEPORT, 0);
args->SetInt(GRPC_ARG_MAX_CONCURRENT_STREAMS, 20); int grpc_concurrency = 4 * std::thread::hardware_concurrency();
grpc_concurrency = std::max(32, grpc_concurrency);
grpc_concurrency = std::min(256, grpc_concurrency);
args->SetInt(GRPC_ARG_MAX_CONCURRENT_STREAMS, grpc_concurrency);
} }
void void
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册