summaryrefslogtreecommitdiff
path: root/src/mongo/db/session_catalog_mongod.cpp
diff options
context:
space:
mode:
authorSiyuan Zhou <siyuan.zhou@mongodb.com>2019-01-21 19:11:41 -0500
committerSiyuan Zhou <siyuan.zhou@mongodb.com>2019-01-24 22:49:49 -0500
commitd1933f0b1b88c4c2ad0f2fdd6ab106f7eeacddfa (patch)
treef28cbc8eb44fa4363c9824e0e772014c0306f433 /src/mongo/db/session_catalog_mongod.cpp
parentec4520d72b2a4ff6ba980e913c988b11e7d188a4 (diff)
downloadmongo-d1933f0b1b88c4c2ad0f2fdd6ab106f7eeacddfa.tar.gz
SERVER-38282 Yield locks for prepared transactions on stepdown.
Diffstat (limited to 'src/mongo/db/session_catalog_mongod.cpp')
-rw-r--r--src/mongo/db/session_catalog_mongod.cpp5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/mongo/db/session_catalog_mongod.cpp b/src/mongo/db/session_catalog_mongod.cpp
index dd6072af24e..5aacb745275 100644
--- a/src/mongo/db/session_catalog_mongod.cpp
+++ b/src/mongo/db/session_catalog_mongod.cpp
@@ -28,7 +28,7 @@
* it in the license file.
*/
-#define MONGO_LOG_DEFAULT_COMPONENT ::mongo::logger::LogComponent::kWrite
+#define MONGO_LOG_DEFAULT_COMPONENT ::mongo::logger::LogComponent::kTransaction
#include "mongo/platform/basic.h"
@@ -43,6 +43,7 @@
#include "mongo/db/transaction_participant.h"
#include "mongo/rpc/get_status_from_command_result.h"
#include "mongo/util/concurrency/thread_pool.h"
+#include "mongo/util/log.h"
namespace mongo {
namespace {
@@ -138,6 +139,8 @@ void MongoDSessionCatalog::onStepUp(OperationContext* opCtx) {
MongoDOperationContextSession ocs(newOpCtx.get());
auto txnParticipant =
TransactionParticipant::get(OperationContextSession::get(newOpCtx.get()));
+ LOG(3) << "Restoring locks of prepared transaction. SessionId: " << sessionId.getId()
+ << " TxnNumber: " << txnParticipant->getActiveTxnNumber();
txnParticipant->refreshLocksForPreparedTransaction(newOpCtx.get(), false);
}
}