diff options
author | Sree Kuchibhotla <sreek@google.com> | 2016-10-13 15:12:55 -0700 |
---|---|---|
committer | Sree Kuchibhotla <sreek@google.com> | 2016-10-13 15:12:55 -0700 |
commit | 8f7739bcd6f14e18e2f342cba8e940942f37a48b (patch) | |
tree | 807b13ab438322bcec31612fe434a69779b260d2 /include/grpc++ | |
parent | 96766195a6ed083e5fc239755aa76a2138cd1d7a (diff) |
Rename GrpcRpcManager -> ThreadManager
Diffstat (limited to 'include/grpc++')
-rw-r--r-- | include/grpc++/server.h | 15 |
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_; |