diff options
Diffstat (limited to 'src/mongo/db/kill_sessions_local.cpp')
| -rw-r--r-- | src/mongo/db/kill_sessions_local.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/kill_sessions_local.cpp b/src/mongo/db/kill_sessions_local.cpp index 8c217cb7e25..c44234c7568 100644 --- a/src/mongo/db/kill_sessions_local.cpp +++ b/src/mongo/db/kill_sessions_local.cpp @@ -91,7 +91,7 @@ void killSessionsAbortUnpreparedTransactions(OperationContext* opCtx, matcher, [](const ObservableSession& session) { auto participant = TransactionParticipant::get(session); - return participant.inMultiDocumentTransaction() && !participant.transactionIsPrepared(); + return participant.transactionIsOpen() && !participant.transactionIsPrepared(); }, [](OperationContext* opCtx, const SessionToKill& session) { TransactionParticipant::get(session).abortTransactionIfNotPrepared(opCtx); @@ -138,7 +138,7 @@ void killSessionsLocalShutdownAllTransactions(OperationContext* opCtx) { killSessionsAction(opCtx, matcherAllSessions, [](const ObservableSession& session) { - return TransactionParticipant::get(session).inMultiDocumentTransaction(); + return TransactionParticipant::get(session).transactionIsOpen(); }, [](OperationContext* opCtx, const SessionToKill& session) { TransactionParticipant::get(session).shutdown(opCtx); |