summaryrefslogtreecommitdiff
path: root/src/mongo/db/transaction_participant.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/transaction_participant.h')
-rw-r--r--src/mongo/db/transaction_participant.h9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/mongo/db/transaction_participant.h b/src/mongo/db/transaction_participant.h
index 7dbef532bad..ae5ad91db63 100644
--- a/src/mongo/db/transaction_participant.h
+++ b/src/mongo/db/transaction_participant.h
@@ -41,6 +41,7 @@
#include "mongo/db/session.h"
#include "mongo/db/single_transaction_stats.h"
#include "mongo/db/storage/recovery_unit.h"
+#include "mongo/db/transaction_metrics_observer.h"
#include "mongo/util/assert_util.h"
#include "mongo/util/concurrency/with_lock.h"
#include "mongo/util/decorable.h"
@@ -281,7 +282,7 @@ public:
}
SingleTransactionStats getSingleTransactionStats() const {
- return _singleTransactionStats;
+ return _transactionMetricsObserver.getSingleTransactionStats();
}
repl::OpTime getSpeculativeTransactionReadOpTimeForTest() const {
@@ -623,11 +624,11 @@ private:
std::vector<MultikeyPathInfo> _multikeyPathInfo;
- // Tracks metrics for a single multi-document transaction.
- SingleTransactionStats _singleTransactionStats;
-
// Remembers the refresh count this object has read from Session.
long long _lastStateRefreshCount{0};
+
+ // Tracks and updates transaction metrics upon the appropriate transaction event.
+ TransactionMetricsObserver _transactionMetricsObserver;
};
inline StringBuilder& operator<<(StringBuilder& sb,