summaryrefslogtreecommitdiff
path: root/src/mongo/db/transaction_metrics_observer.cpp
diff options
context:
space:
mode:
authorSamy Lanka <samy.lanka@mongodb.com>2019-04-03 17:35:29 -0400
committerSamy Lanka <samy.lanka@mongodb.com>2019-04-03 17:36:14 -0400
commit4459b439700f096a7b6287fdddde592db8934fe2 (patch)
tree9913de37d8eb6d7f9798da1dba7c3dcffb5dbb94 /src/mongo/db/transaction_metrics_observer.cpp
parentc7476a53ab4e33914217b61c8e81f29b8df09322 (diff)
downloadmongo-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.cpp19
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();
}