| 1829 | } |
| 1830 | |
| 1831 | void addTagMapping(GetKeyServerLocationsReply& reply, ProxyCommitData* commitData) { |
| 1832 | for (const auto& [_, shard] : reply.results) { |
| 1833 | for (auto& ssi : shard) { |
| 1834 | auto iter = commitData->storageCache.find(ssi.id()); |
| 1835 | ASSERT_WE_THINK(iter != commitData->storageCache.end()); |
| 1836 | reply.resultsTagMapping.emplace_back(ssi.id(), iter->second->tag); |
| 1837 | } |
| 1838 | } |
| 1839 | } |
| 1840 | |
| 1841 | ACTOR static Future<Void> doKeyServerLocationRequest(GetKeyServerLocationsRequest req, ProxyCommitData* commitData) { |
| 1842 | // We can't respond to these requests until we have valid txnStateStore |
no test coverage detected