| 461 | choose { |
| 462 | when(wait(self->cx->onProxiesChanged())) {} |
| 463 | when(GetReadVersionReply reply = |
| 464 | wait(basicLoadBalance(self->cx->getGrvProxies(UseProvisionalProxies::False), |
| 465 | &GrvProxyInterface::getConsistentReadVersion, |
| 466 | request, |
| 467 | self->cx->taskID))) { |
| 468 | self->cx->ssVersionVectorCache.applyDelta(reply.ssVersionVectorDelta); |
| 469 | return reply.version; |
| 470 | } |
| 471 | } |
| 472 | } |
| 473 | } |
no test coverage detected