diff options
| author | Cheahuychou Mao <mao.cheahuychou@gmail.com> | 2021-08-19 05:37:25 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-09-01 22:02:16 +0000 |
| commit | 22beeff23a26e44127a15587e8bfd84f1d1e916c (patch) | |
| tree | bc88a80b18693021bdb60db0399d9ec20630e97c /src/mongo/db/s/migration_destination_manager.cpp | |
| parent | 9486a2779da1e8821b4b6d90ef3327a649c10b62 (diff) | |
| download | mongo-22beeff23a26e44127a15587e8bfd84f1d1e916c.tar.gz | |
SERVER-58752 Support retrying internal transactions on transient transaction errors
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.cpp')
| -rw-r--r-- | src/mongo/db/s/migration_destination_manager.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/s/migration_destination_manager.cpp b/src/mongo/db/s/migration_destination_manager.cpp index 1451fd2eced..5f81beb94fa 100644 --- a/src/mongo/db/s/migration_destination_manager.cpp +++ b/src/mongo/db/s/migration_destination_manager.cpp @@ -108,7 +108,8 @@ void checkOutSessionAndVerifyTxnState(OperationContext* opCtx) { TransactionParticipant::get(opCtx).beginOrContinue(opCtx, *opCtx->getTxnNumber(), boost::none /* autocommit */, - boost::none /* startTransaction */); + boost::none /* startTransaction */, + boost::none /* txnRetryCounter */); } template <typename Callable> @@ -921,7 +922,8 @@ void MigrationDestinationManager::_migrateThread() { txnParticipant.beginOrContinue(opCtx, *opCtx->getTxnNumber(), boost::none /* autocommit */, - boost::none /* startTransaction */); + boost::none /* startTransaction */, + boost::none /* txnRetryCounter */); _migrateDriver(opCtx); } catch (...) { _setStateFail(str::stream() << "migrate failed: " << redact(exceptionToStatus())); |