admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 03:13:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

Increase GRPC concurrency (#2671)

Browse Source 
* Increase GRPC concurrency

Signed-off-by: JinHai-CN <hai.jin@zilliz.com>

* Fix lint

Signed-off-by: JinHai-CN <hai.jin@zilliz.com>

* Add limitation

Signed-off-by: JinHai-CN <hai.jin@zilliz.com>

* Fix compilation error

Signed-off-by: JinHai-CN <hai.jin@zilliz.com>

* Fix compilation error

Signed-off-by: JinHai-CN <hai.jin@zilliz.com>

* Fix compilation error

Signed-off-by: JinHai-CN <hai.jin@zilliz.com>
This commit is contained in:
Jin Hai 2020-06-26 12:16:44 +08:00 committed by GitHub
parent 0fb88f733a
commit 0b16c92ccc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/server/grpc_impl/GrpcServer.cpp
View File

@ -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 {
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