| 2529 | } |
| 2530 | |
| 2531 | void ClientRequestState::UnRegisterRemainingRPCs() { |
| 2532 | lock_guard<mutex> l(lock_); |
| 2533 | for (auto rpc_context: pending_rpcs_) { |
| 2534 | rpc_context->UnRegister(); |
| 2535 | } |
| 2536 | track_rpcs_ = false; |
| 2537 | pending_rpcs_.clear(); |
| 2538 | } |
| 2539 | |
| 2540 | void ClientRequestState::CopyRPCs(ClientRequestState& from_request) { |
| 2541 | lock_guard<mutex> l_to(lock_); |