aboutsummaryrefslogtreecommitdiffhomepage
path: root/include/grpc++
diff options
context:
space:
mode:
authorGravatar Sree Kuchibhotla <sreek@google.com>2016-10-13 15:12:55 -0700
committerGravatar Sree Kuchibhotla <sreek@google.com>2016-10-13 15:12:55 -0700
commit8f7739bcd6f14e18e2f342cba8e940942f37a48b (patch)
tree807b13ab438322bcec31612fe434a69779b260d2 /include/grpc++
parent96766195a6ed083e5fc239755aa76a2138cd1d7a (diff)
Rename GrpcRpcManager -> ThreadManager
Diffstat (limited to 'include/grpc++')
-rw-r--r--include/grpc++/server.h15
1 files changed, 5 insertions, 10 deletions
diff --git a/include/grpc++/server.h b/include/grpc++/server.h
index 7753013c39..99b5975847 100644
--- a/include/grpc++/server.h
+++ b/include/grpc++/server.h
@@ -107,11 +107,11 @@ class Server GRPC_FINAL : public ServerInterface, private GrpcLibraryCodegen {
class AsyncRequest;
class ShutdownRequest;
- /// SyncRequestManager is an implementation of GrpcRpcManager. This class is
- /// responsible for polling for incoming RPCs and calling the RPC handlers.
+ /// SyncRequestThreadManager is an implementation of ThreadManager. This class
+ /// is responsible for polling for incoming RPCs and calling the RPC handlers.
/// This is only used in case of a Sync server (i.e a server exposing a sync
/// interface)
- class SyncRequestManager;
+ class SyncRequestThreadManager;
class UnimplementedAsyncRequestContext;
class UnimplementedAsyncRequest;
@@ -196,8 +196,8 @@ class Server GRPC_FINAL : public ServerInterface, private GrpcLibraryCodegen {
std::shared_ptr<std::vector<std::unique_ptr<ServerCompletionQueue>>>
sync_server_cqs_;
- /// List of GrpcRpcManager instances (one for each cq in the sync_server_cqs)
- std::vector<std::unique_ptr<SyncRequestManager>> sync_req_mgrs_;
+ /// List of ThreadManager instances (one for each cq in the sync_server_cqs)
+ std::vector<std::unique_ptr<SyncRequestThreadManager>> sync_req_mgrs_;
// Sever status
grpc::mutex mu_;
@@ -205,11 +205,6 @@ class Server GRPC_FINAL : public ServerInterface, private GrpcLibraryCodegen {
bool shutdown_;
bool shutdown_notified_;
- // TODO (sreek) : Remove num_running_cb_ and callback_cv_;
- // The number of threads which are running callbacks.
- // int num_running_cb_;
- // grpc::condition_variable callback_cv_;
-
grpc::condition_variable shutdown_cv_;
std::shared_ptr<GlobalCallbacks> global_callbacks_;