diff options
| -rw-r--r-- | src/mongo/db/session.cpp | 1 | ||||
| -rw-r--r-- | src/mongo/db/session.h | 6 | ||||
| -rw-r--r-- | src/mongo/db/single_transaction_stats.h (renamed from src/mongo/db/txn_stats.h) | 5 |
3 files changed, 8 insertions, 4 deletions
diff --git a/src/mongo/db/session.cpp b/src/mongo/db/session.cpp index 95457f11663..dc2997a7a13 100644 --- a/src/mongo/db/session.cpp +++ b/src/mongo/db/session.cpp @@ -651,6 +651,7 @@ void Session::_beginOrContinueTxn(WithLock wl, _setActiveTxn(wl, opCtx, txnNumber, canKillCursors); _autocommit = true; _txnState = MultiDocumentTransactionState::kNone; + _singleTransactionStats = boost::none; } invariant(_transactionOperations.empty()); diff --git a/src/mongo/db/session.h b/src/mongo/db/session.h index c2d29abd55e..9ca248a2c08 100644 --- a/src/mongo/db/session.h +++ b/src/mongo/db/session.h @@ -39,8 +39,8 @@ #include "mongo/db/repl/oplog_entry.h" #include "mongo/db/repl/read_concern_args.h" #include "mongo/db/session_txn_record_gen.h" +#include "mongo/db/single_transaction_stats.h" #include "mongo/db/storage/recovery_unit.h" -#include "mongo/db/txn_stats.h" #include "mongo/platform/atomic_word.h" #include "mongo/stdx/unordered_map.h" #include "mongo/util/concurrency/with_lock.h" @@ -550,8 +550,8 @@ private: // transaction state resets. std::vector<MultikeyPathInfo> _multikeyPathInfo; - // Tracks per-transaction metrics. - TxnStats _txnStats; + // Tracks metrics for a single multi-document transaction. Not used for retryable writes. + boost::optional<SingleTransactionStats> _singleTransactionStats; }; } // namespace mongo diff --git a/src/mongo/db/txn_stats.h b/src/mongo/db/single_transaction_stats.h index 9567528864d..300afb99007 100644 --- a/src/mongo/db/txn_stats.h +++ b/src/mongo/db/single_transaction_stats.h @@ -30,6 +30,9 @@ namespace mongo { -class TxnStats {}; +/** + * Tracks metrics for a single multi-document transaction. + */ +class SingleTransactionStats {}; } // namespace mongo |