| 5334 | } |
| 5335 | |
| 5336 | Future<Void> Transaction::watch(Reference<Watch> watch) { |
| 5337 | ++trState->cx->transactionWatchRequests; |
| 5338 | |
| 5339 | trState->cx->addWatch(); |
| 5340 | watches.push_back(watch); |
| 5341 | return ::watch( |
| 5342 | watch, |
| 5343 | trState->cx, |
| 5344 | populateAndGetTenant( |
| 5345 | trState, watch->key, readVersion.isValid() && readVersion.isReady() ? readVersion.get() : latestVersion), |
| 5346 | trState->options.readTags, |
| 5347 | trState->spanContext, |
| 5348 | trState->taskID, |
| 5349 | trState->debugID, |
| 5350 | trState->useProvisionalProxies); |
| 5351 | } |
| 5352 | |
| 5353 | ACTOR Future<Standalone<VectorRef<const char*>>> getAddressesForKeyActor(Reference<TransactionState> trState, |
| 5354 | Future<Version> ver, |