diff options
author | Samy Lanka <samy.lanka@mongodb.com> | 2019-04-03 17:35:29 -0400 |
---|---|---|
committer | Samy Lanka <samy.lanka@mongodb.com> | 2019-04-03 17:36:14 -0400 |
commit | 4459b439700f096a7b6287fdddde592db8934fe2 (patch) | |
tree | 9913de37d8eb6d7f9798da1dba7c3dcffb5dbb94 /src/mongo/db/transaction_metrics_observer.cpp | |
parent | c7476a53ab4e33914217b61c8e81f29b8df09322 (diff) | |
download | mongo-4459b439700f096a7b6287fdddde592db8934fe2.tar.gz |
SERVER-40018 Remove ServerTransactionMetrics::getOldestActiveOpTime and supporting datastructures
Diffstat (limited to 'src/mongo/db/transaction_metrics_observer.cpp')
-rw-r--r-- | src/mongo/db/transaction_metrics_observer.cpp | 19 |
1 files changed, 0 insertions, 19 deletions
diff --git a/src/mongo/db/transaction_metrics_observer.cpp b/src/mongo/db/transaction_metrics_observer.cpp index 195a4d49088..365eba2d689 100644 --- a/src/mongo/db/transaction_metrics_observer.cpp +++ b/src/mongo/db/transaction_metrics_observer.cpp @@ -122,11 +122,6 @@ void TransactionMetricsObserver::onCommit(ServerTransactionsMetrics* serverTrans auto duration = durationCount<Microseconds>(_singleTransactionStats.getDuration(tickSource, curTick)); top->incrementGlobalTransactionLatencyStats(static_cast<uint64_t>(duration)); - - // Remove this transaction's oldest oplog entry OpTime if one was written. - if (oldestOplogEntryOpTime) { - serverTransactionsMetrics->removeActiveOpTime(*oldestOplogEntryOpTime); - } } void TransactionMetricsObserver::_onAbortActive( @@ -152,11 +147,6 @@ void TransactionMetricsObserver::_onAbortActive( serverTransactionsMetrics->incrementTotalPreparedThenAborted(); serverTransactionsMetrics->decrementCurrentPrepared(); } - - // Remove this transaction's oldest oplog entry OpTime if one was written. - if (oldestOplogEntryOpTime) { - serverTransactionsMetrics->removeActiveOpTime(*oldestOplogEntryOpTime); - } } void TransactionMetricsObserver::_onAbortInactive( @@ -173,11 +163,6 @@ void TransactionMetricsObserver::_onAbortInactive( // Server wide transactions metrics. // serverTransactionsMetrics->decrementCurrentInactive(); - - // Remove this transaction's oldest oplog entry OpTime if one was written. - if (oldestOplogEntryOpTime) { - serverTransactionsMetrics->removeActiveOpTime(*oldestOplogEntryOpTime); - } } void TransactionMetricsObserver::onAbort(ServerTransactionsMetrics* serverTransactionsMetrics, @@ -249,10 +234,6 @@ void TransactionMetricsObserver::onPrepare(ServerTransactionsMetrics* serverTran // _singleTransactionStats.setPreparedStartTime(curTick); - // Since we currently only write an oplog entry for an in progress transaction when it is in - // the prepare state, the prepareOpTime is currently the oldest optime written to the - // oplog for this transaction. - serverTransactionsMetrics->addActiveOpTime(prepareOpTime); serverTransactionsMetrics->incrementCurrentPrepared(); serverTransactionsMetrics->incrementTotalPrepared(); } |