aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/cpp/server
diff options
context:
space:
mode:
authorGravatar Sree Kuchibhotla <sreek@google.com>2018-07-23 23:38:13 -0700
committerGravatar Sree Kuchibhotla <sreek@google.com>2018-07-24 16:35:25 -0700
commitb95772eeb926f78b8ac14e03b36ed3e73b2e1a2c (patch)
treeff760e47e362bdfe86467a2f575cc0a9d8ca76c1 /src/cpp/server
parent7b8be4d6fd0a3b7374d5a28bea1eff319c49fefe (diff)
Add Tests in Core and C++ and fix a few related bugs in thread_manager.cc
Diffstat (limited to 'src/cpp/server')
-rw-r--r--src/cpp/server/server_cc.cc10
1 files changed, 9 insertions, 1 deletions
diff --git a/src/cpp/server/server_cc.cc b/src/cpp/server/server_cc.cc
index 6e6e0bfffe..786ef44e3e 100644
--- a/src/cpp/server/server_cc.cc
+++ b/src/cpp/server/server_cc.cc
@@ -47,6 +47,12 @@
namespace grpc {
namespace {
+// The default value for maximum number of threads that can be created in the
+// sync server. This value of 1500 is empirically chosen. To increase the max
+// number of threads in a sync server, pass a custom ResourceQuota object (with
+// the desired number of max-threads set) to the server builder
+#define DEFAULT_MAX_SYNC_SERVER_THREADS 1500
+
class DefaultGlobalCallbacks final : public Server::GlobalCallbacks {
public:
~DefaultGlobalCallbacks() override {}
@@ -395,7 +401,9 @@ Server::Server(
if (sync_server_cqs_ != nullptr) {
bool default_rq_created = false;
if (server_rq == nullptr) {
- server_rq = grpc_resource_quota_create("SyncServer-Default");
+ server_rq = grpc_resource_quota_create("SyncServer-default-rq");
+ grpc_resource_quota_set_max_threads(server_rq,
+ DEFAULT_MAX_SYNC_SERVER_THREADS);
default_rq_created = true;
}