diff options
| author |  Sree Kuchibhotla <sreek@google.com> | 2018-07-27 16:19:03 -0700 |
|---|---|---|
| committer | Sree Kuchibhotla <sreek@google.com> | 2018-07-27 16:19:03 -0700 |
| commit | c2a22a1ab8e8221c95f8874668eb6260c1e171b4 (patch) | |
| tree | 6a1de70b7e4d8c82ef1eba01c7a92f91c4d31333 /src/cpp/thread_manager/thread_manager.cc | |
| parent | 9bc8ee42c20385214027ced5991b9973a0282655 (diff) | |
Address core review comments
Diffstat (limited to 'src/cpp/thread_manager/thread_manager.cc')
| -rw-r--r-- | src/cpp/thread_manager/thread_manager.cc | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/cpp/thread_manager/thread_manager.cc b/src/cpp/thread_manager/thread_manager.cc index 5d367511e2..57067d4696 100644 --- a/src/cpp/thread_manager/thread_manager.cc +++ b/src/cpp/thread_manager/thread_manager.cc @@ -123,7 +123,7 @@ void ThreadManager::CleanupCompletedThreads() { } void ThreadManager::Initialize() { - if (!grpc_resource_user_alloc_threads(resource_user_, min_pollers_)) { + if (!grpc_resource_user_allocate_threads(resource_user_, min_pollers_)) { gpr_log(GPR_ERROR, "No thread quota available to even create the minimum required " "polling threads (i.e %d). Unable to start the thread manager", @@ -165,9 +165,9 @@ void ThreadManager::MainWorkLoop() { break; case WORK_FOUND: // If we got work and there are now insufficient pollers and there is - // quota available to create a new thread,start a new poller thread + // quota available to create a new thread, start a new poller thread if (!shutdown_ && num_pollers_ < min_pollers_ && - grpc_resource_user_alloc_threads(resource_user_, 1)) { + grpc_resource_user_allocate_threads(resource_user_, 1)) { num_pollers_++; num_threads_++; max_active_threads_sofar_ = |