| 1429 | } |
| 1430 | |
| 1431 | DatabaseContext::DatabaseContext(Reference<AsyncVar<Reference<IClusterConnectionRecord>>> connectionRecord, |
| 1432 | Reference<AsyncVar<ClientDBInfo>> clientInfo, |
| 1433 | Reference<AsyncVar<Optional<ClientLeaderRegInterface>> const> coordinator, |
| 1434 | Future<Void> clientInfoMonitor, |
| 1435 | TaskPriority taskID, |
| 1436 | LocalityData const& clientLocality, |
| 1437 | EnableLocalityLoadBalance enableLocalityLoadBalance, |
| 1438 | LockAware lockAware, |
| 1439 | IsInternal internal, |
| 1440 | int _apiVersion, |
| 1441 | IsSwitchable switchable, |
| 1442 | Optional<TenantName> defaultTenant) |
| 1443 | : lockAware(lockAware), switchable(switchable), connectionRecord(connectionRecord), proxyProvisional(false), |
| 1444 | clientLocality(clientLocality), enableLocalityLoadBalance(enableLocalityLoadBalance), defaultTenant(defaultTenant), |
| 1445 | internal(internal), cc("TransactionMetrics"), transactionReadVersions("ReadVersions", cc), |
| 1446 | transactionReadVersionsThrottled("ReadVersionsThrottled", cc), |
| 1447 | transactionReadVersionsCompleted("ReadVersionsCompleted", cc), |
| 1448 | transactionReadVersionBatches("ReadVersionBatches", cc), |
| 1449 | transactionBatchReadVersions("BatchPriorityReadVersions", cc), |
| 1450 | transactionDefaultReadVersions("DefaultPriorityReadVersions", cc), |
| 1451 | transactionImmediateReadVersions("ImmediatePriorityReadVersions", cc), |
| 1452 | transactionBatchReadVersionsCompleted("BatchPriorityReadVersionsCompleted", cc), |
| 1453 | transactionDefaultReadVersionsCompleted("DefaultPriorityReadVersionsCompleted", cc), |
| 1454 | transactionImmediateReadVersionsCompleted("ImmediatePriorityReadVersionsCompleted", cc), |
| 1455 | transactionLogicalReads("LogicalUncachedReads", cc), transactionPhysicalReads("PhysicalReadRequests", cc), |
| 1456 | transactionPhysicalReadsCompleted("PhysicalReadRequestsCompleted", cc), |
| 1457 | transactionGetKeyRequests("GetKeyRequests", cc), transactionGetValueRequests("GetValueRequests", cc), |
| 1458 | transactionGetRangeRequests("GetRangeRequests", cc), |
| 1459 | transactionGetMappedRangeRequests("GetMappedRangeRequests", cc), |
| 1460 | transactionGetRangeStreamRequests("GetRangeStreamRequests", cc), transactionWatchRequests("WatchRequests", cc), |
| 1461 | transactionGetAddressesForKeyRequests("GetAddressesForKeyRequests", cc), transactionBytesRead("BytesRead", cc), |
| 1462 | transactionKeysRead("KeysRead", cc), transactionMetadataVersionReads("MetadataVersionReads", cc), |
| 1463 | transactionCommittedMutations("CommittedMutations", cc), |
| 1464 | transactionCommittedMutationBytes("CommittedMutationBytes", cc), transactionSetMutations("SetMutations", cc), |
| 1465 | transactionClearMutations("ClearMutations", cc), transactionAtomicMutations("AtomicMutations", cc), |
| 1466 | transactionsCommitStarted("CommitStarted", cc), transactionsCommitCompleted("CommitCompleted", cc), |
| 1467 | transactionKeyServerLocationRequests("KeyServerLocationRequests", cc), |
| 1468 | transactionKeyServerLocationRequestsCompleted("KeyServerLocationRequestsCompleted", cc), |
| 1469 | transactionStatusRequests("StatusRequests", cc), transactionsTooOld("TooOld", cc), |
| 1470 | transactionsFutureVersions("FutureVersions", cc), transactionsNotCommitted("NotCommitted", cc), |
| 1471 | transactionsMaybeCommitted("MaybeCommitted", cc), transactionsResourceConstrained("ResourceConstrained", cc), |
| 1472 | transactionsProcessBehind("ProcessBehind", cc), transactionsThrottled("Throttled", cc), |
| 1473 | transactionsExpensiveClearCostEstCount("ExpensiveClearCostEstCount", cc), |
| 1474 | transactionGrvFullBatches("NumGrvFullBatches", cc), transactionGrvTimedOutBatches("NumGrvTimedOutBatches", cc), |
| 1475 | transactionCommitVersionNotFoundForSS("CommitVersionNotFoundForSS", cc), bgReadInputBytes("BGReadInputBytes", cc), |
| 1476 | bgReadOutputBytes("BGReadOutputBytes", cc), usedAnyChangeFeeds(false), ccFeed("ChangeFeedClientMetrics"), |
| 1477 | feedStreamStarts("FeedStreamStarts", ccFeed), feedMergeStreamStarts("FeedMergeStreamStarts", ccFeed), |
| 1478 | feedErrors("FeedErrors", ccFeed), feedNonRetriableErrors("FeedNonRetriableErrors", ccFeed), |
| 1479 | feedPops("FeedPops", ccFeed), feedPopsFallback("FeedPopsFallback", ccFeed), latencies(1000), readLatencies(1000), |
| 1480 | commitLatencies(1000), GRVLatencies(1000), mutationsPerCommit(1000), bytesPerCommit(1000), bgLatencies(1000), |
| 1481 | bgGranulesPerRequest(1000), outstandingWatches(0), sharedStatePtr(nullptr), lastGrvTime(0.0), cachedReadVersion(0), |
| 1482 | lastRkBatchThrottleTime(0.0), lastRkDefaultThrottleTime(0.0), lastProxyRequestTime(0.0), |
| 1483 | transactionTracingSample(false), taskID(taskID), clientInfo(clientInfo), clientInfoMonitor(clientInfoMonitor), |
| 1484 | coordinator(coordinator), apiVersion(_apiVersion), mvCacheInsertLocation(0), healthMetricsLastUpdated(0), |
| 1485 | detailedHealthMetricsLastUpdated(0), smoothMidShardSize(CLIENT_KNOBS->SHARD_STAT_SMOOTH_AMOUNT), |
| 1486 | specialKeySpace(std::make_unique<SpecialKeySpace>(specialKeys.begin, specialKeys.end, /* test */ false)), |
| 1487 | connectToDatabaseEventCacheHolder(format("ConnectToDatabase/%s", dbId.toString().c_str())) { |
| 1488 |
nothing calls this directly
no test coverage detected