| 271 | } |
| 272 | |
| 273 | void RpcMgr::Join() { |
| 274 | if (services_started_) { |
| 275 | if (messenger_.get() == nullptr) return; |
| 276 | for (const auto& service_pool : service_pools_) service_pool->Join(); |
| 277 | } |
| 278 | } |
| 279 | |
| 280 | void RpcMgr::Shutdown() { |
| 281 | if (messenger_.get() == nullptr) return; |