| 278 | } |
| 279 | |
| 280 | void RpcMgr::Shutdown() { |
| 281 | if (messenger_.get() == nullptr) return; |
| 282 | for (const auto& service_pool : service_pools_) service_pool->Shutdown(); |
| 283 | acceptor_pool_.reset(); |
| 284 | |
| 285 | messenger_->UnregisterAllServices(); |
| 286 | messenger_->Shutdown(); |
| 287 | service_pools_.clear(); |
| 288 | } |
| 289 | |
| 290 | bool RpcMgr::IsServerTooBusy(const RpcController& rpc_controller) { |
| 291 | const kudu::Status status = rpc_controller.status(); |