2 files changed, 13 insertions, 1 deletions
diff --git a/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.cpp b/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.cpp
index a1f9ef06b89..3c570f34a48 100644
--- a/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.cpp
+++ b/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.cpp
@@ -29,4 +29,14 @@
 
 #include "mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.h"
 
-namespace mongo {}  // namespace mongo
+#include "mongo/db/transaction/transaction_participant.h"
+
+namespace mongo {
+
+void MongoDSessionCatalogTransactionInterfaceImpl::invalidateSessionToKill(
+    OperationContext* opCtx, const SessionToKill& session) {
+    auto participant = TransactionParticipant::get(session);
+    participant.invalidate(opCtx);
+}
+
+}  // namespace mongo
diff --git a/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.h b/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.h
index b29427ba5c5..6d7751cb885 100644
--- a/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.h
+++ b/src/mongo/db/transaction/session_catalog_mongod_transaction_interface_impl.h
@@ -46,6 +46,8 @@ class MongoDSessionCatalogTransactionInterfaceImpl
 public:
     MongoDSessionCatalogTransactionInterfaceImpl() = default;
     virtual ~MongoDSessionCatalogTransactionInterfaceImpl() = default;
+
+    void invalidateSessionToKill(OperationContext* opCtx, const SessionToKill& session) override;
 };
 
 }  // namespace mongo