| 215 | } |
| 216 | |
| 217 | void CallOneRpc() { |
| 218 | if (request_count_ > 0) { |
| 219 | CHECK_OK(controller_.status()); |
| 220 | CHECK_EQ(req_.x() + req_.y(), resp_.result()); |
| 221 | } |
| 222 | if (!Acquire_Load(&bench_->should_run_)) { |
| 223 | bench_->stop_.CountDown(); |
| 224 | return; |
| 225 | } |
| 226 | controller_.Reset(); |
| 227 | req_.set_x(request_count_); |
| 228 | req_.set_y(request_count_); |
| 229 | request_count_++; |
| 230 | proxy_->AddAsync(req_, |
| 231 | &resp_, |
| 232 | &controller_, |
| 233 | [this]() { this->CallOneRpc(); }); |
| 234 | } |
| 235 | |
| 236 | void Start() { |
| 237 | CallOneRpc(); |
nothing calls this directly
no test coverage detected