summaryrefslogtreecommitdiff
path: root/src/mongo/s/commands/document_shard_key_update_util.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/commands/document_shard_key_update_util.cpp')
-rw-r--r--src/mongo/s/commands/document_shard_key_update_util.cpp13
1 files changed, 7 insertions, 6 deletions
diff --git a/src/mongo/s/commands/document_shard_key_update_util.cpp b/src/mongo/s/commands/document_shard_key_update_util.cpp
index d10b9294110..119193d9ee5 100644
--- a/src/mongo/s/commands/document_shard_key_update_util.cpp
+++ b/src/mongo/s/commands/document_shard_key_update_util.cpp
@@ -142,20 +142,21 @@ bool updateShardKeyForDocument(OperationContext* opCtx,
opCtx, deleteCmdObj, insertCmdObj, nss.db(), documentKeyChangeInfo.getShouldUpsert());
}
-TransactionRouter* startTransactionForShardKeyUpdate(OperationContext* opCtx) {
+void startTransactionForShardKeyUpdate(OperationContext* opCtx) {
auto txnRouter = TransactionRouter::get(opCtx);
invariant(txnRouter);
auto txnNumber = opCtx->getTxnNumber();
invariant(txnNumber);
- txnRouter->beginOrContinueTxn(opCtx, *txnNumber, TransactionRouter::TransactionActions::kStart);
-
- return txnRouter;
+ txnRouter.beginOrContinueTxn(opCtx, *txnNumber, TransactionRouter::TransactionActions::kStart);
}
-BSONObj commitShardKeyUpdateTransaction(OperationContext* opCtx, TransactionRouter* txnRouter) {
- return txnRouter->commitTransaction(opCtx, boost::none);
+BSONObj commitShardKeyUpdateTransaction(OperationContext* opCtx) {
+ auto txnRouter = TransactionRouter::get(opCtx);
+ invariant(txnRouter);
+
+ return txnRouter.commitTransaction(opCtx, boost::none);
}
BSONObj constructShardKeyDeleteCmdObj(const NamespaceString& nss,