diff options
Diffstat (limited to 'src/mongo/db/repl/oplog.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplog.cpp | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/src/mongo/db/repl/oplog.cpp b/src/mongo/db/repl/oplog.cpp index eb9b8953415..7e10d3762d7 100644 --- a/src/mongo/db/repl/oplog.cpp +++ b/src/mongo/db/repl/oplog.cpp @@ -1081,7 +1081,6 @@ Status applyOperation_inlock(OperationContext* opCtx, str::stream() << "Failed to apply insert due to missing collection: " << redact(opOrGroupedInserts.toBSON()), collection); - if (opOrGroupedInserts.isGroupedInserts()) { // Grouped inserts. @@ -1101,8 +1100,11 @@ Status applyOperation_inlock(OperationContext* opCtx, WriteUnitOfWork wuow(opCtx); OpDebug* const nullOpDebug = nullptr; - Status status = collection->insertDocuments( - opCtx, insertObjs.begin(), insertObjs.end(), nullOpDebug, true); + Status status = collection->insertDocuments(opCtx, + insertObjs.begin(), + insertObjs.end(), + nullOpDebug, + false /* fromMigrate */); if (!status.isOK()) { return status; } @@ -1177,8 +1179,10 @@ Status applyOperation_inlock(OperationContext* opCtx, } OpDebug* const nullOpDebug = nullptr; - Status status = collection->insertDocument( - opCtx, InsertStatement(o, timestamp, term), nullOpDebug, true); + Status status = collection->insertDocument(opCtx, + InsertStatement(o, timestamp, term), + nullOpDebug, + false /* fromMigrate */); if (status.isOK()) { wuow.commit(); |