summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_entry.cpp
diff options
context:
space:
mode:
authorJudah Schvimer <judah@mongodb.com>2018-07-20 13:11:12 -0400
committerJudah Schvimer <judah@mongodb.com>2018-07-20 13:17:19 -0400
commit5b6fbcf0dc4065d725b23c6fd3911a24e078e34d (patch)
treef5da305a6d3dfb072146fa75f592c67099a03bd9 /src/mongo/db/repl/oplog_entry.cpp
parent4cdaee88d7122f3ccba152ae37d3b5b69b3b398f (diff)
downloadmongo-5b6fbcf0dc4065d725b23c6fd3911a24e078e34d.tar.gz
SERVER-35597 SERVER-35598 Ensure prepared transactions can be committed
Diffstat (limited to 'src/mongo/db/repl/oplog_entry.cpp')
-rw-r--r--src/mongo/db/repl/oplog_entry.cpp2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mongo/db/repl/oplog_entry.cpp b/src/mongo/db/repl/oplog_entry.cpp
index 731bde4e43b..32e2880c12b 100644
--- a/src/mongo/db/repl/oplog_entry.cpp
+++ b/src/mongo/db/repl/oplog_entry.cpp
@@ -66,6 +66,8 @@ OplogEntry::CommandType parseCommandType(const BSONObj& objectField) {
return OplogEntry::CommandType::kDropIndexes;
} else if (commandString == "deleteIndexes") {
return OplogEntry::CommandType::kDropIndexes;
+ } else if (commandString == "commitTransaction") {
+ return OplogEntry::CommandType::kCommitTransaction;
} else {
severe() << "Unknown oplog entry command type: " << commandString
<< " Object field: " << redact(objectField);