| 2171 | } |
| 2172 | |
| 2173 | void ClientRequestState::WaitUntilRetried() { |
| 2174 | unique_lock<mutex> l(lock_); |
| 2175 | DCHECK(retry_state() != RetryState::NOT_RETRIED); |
| 2176 | while (retry_state() == RetryState::RETRYING) { |
| 2177 | block_until_retried_cv_.Wait(l); |
| 2178 | } |
| 2179 | DCHECK(retry_state() == RetryState::RETRIED |
| 2180 | || exec_state() == ExecState::ERROR); |
| 2181 | } |
| 2182 | |
| 2183 | void ClientRequestState::MarkAsRetried(const TUniqueId& retried_id) { |
| 2184 | DCHECK(retry_state() == RetryState::RETRYING) |