summaryrefslogtreecommitdiff
path: root/src/mongo/s/transaction_router.h
diff options
context:
space:
mode:
authorJack Mulrow <jack.mulrow@mongodb.com>2018-12-05 11:22:28 -0500
committerJack Mulrow <jack.mulrow@mongodb.com>2018-12-16 14:04:10 -0500
commit2d94c21d3af7d4b4fc32e6c34791ac24a2a35c0a (patch)
tree63d4ae1994fcf5849e0974fa7af897f2bf44bf12 /src/mongo/s/transaction_router.h
parent54c2a4560cbcd5b652c3bdc8543404ea6cc2d485 (diff)
downloadmongo-2d94c21d3af7d4b4fc32e6c34791ac24a2a35c0a.tar.gz
SERVER-38470 Add more logging to TransactionRouter
Diffstat (limited to 'src/mongo/s/transaction_router.h')
-rw-r--r--src/mongo/s/transaction_router.h11
1 files changed, 9 insertions, 2 deletions
diff --git a/src/mongo/s/transaction_router.h b/src/mongo/s/transaction_router.h
index 2cdf38bf389..9791ed2e00e 100644
--- a/src/mongo/s/transaction_router.h
+++ b/src/mongo/s/transaction_router.h
@@ -185,7 +185,7 @@ public:
* Updates the transaction tracking state to allow for a retry attempt on a view resolution
* error.
*/
- void onViewResolutionError();
+ void onViewResolutionError(const NamespaceString& nss);
/**
* Computes and sets the atClusterTime for the current transaction based on the given query
@@ -233,7 +233,8 @@ public:
/**
* Sends abort to all participants and returns the responses from all shards.
*/
- std::vector<AsyncRequestsSender::Response> abortTransaction(OperationContext* opCtx);
+ std::vector<AsyncRequestsSender::Response> abortTransaction(OperationContext* opCtx,
+ bool isImplicit = false);
/**
* Sends abort to all shards in the current participant list. Will retry on retryable errors,
@@ -317,6 +318,12 @@ private:
*/
void _verifyParticipantAtClusterTime(const Participant& participant);
+ /**
+ * Returns a string with the active transaction's transaction number and logical session id
+ * (i.e. the transaction id).
+ */
+ std::string _txnIdToString();
+
// The currently active transaction number on this transaction router (i.e. on the session)
TxnNumber _txnNumber{kUninitializedTxnNumber};