| 7533 | } |
| 7534 | |
| 7535 | ACTOR Future<Standalone<VectorRef<DDMetricsRef>>> waitDataDistributionMetricsList(Database cx, |
| 7536 | KeyRange keys, |
| 7537 | int shardLimit) { |
| 7538 | loop { |
| 7539 | choose { |
| 7540 | when(wait(cx->onProxiesChanged())) {} |
| 7541 | when(ErrorOr<GetDDMetricsReply> rep = |
| 7542 | wait(errorOr(basicLoadBalance(cx->getCommitProxies(UseProvisionalProxies::False), |
| 7543 | &CommitProxyInterface::getDDMetrics, |
| 7544 | GetDDMetricsRequest(keys, shardLimit))))) { |
| 7545 | if (rep.isError()) { |
| 7546 | throw rep.getError(); |
| 7547 | } |
| 7548 | return rep.get().storageMetricsList; |
| 7549 | } |
| 7550 | } |
| 7551 | } |
| 7552 | } |
| 7553 | |
| 7554 | Future<Standalone<VectorRef<ReadHotRangeWithMetrics>>> DatabaseContext::getReadHotRanges(KeyRange const& keys) { |
| 7555 | return ::getReadHotRanges(Database(Reference<DatabaseContext>::addRef(this)), keys); |
| 7556 | } |
| 7557 | |
| 7558 | ACTOR Future<Standalone<VectorRef<KeyRef>>> getRangeSplitPoints(Reference<TransactionState> trState, |
| 7559 | KeyRange keys, |
nothing calls this directly
no test coverage detected