diff options
Diffstat (limited to 'src/mongo/db/repl/data_replicator.cpp')
| -rw-r--r-- | src/mongo/db/repl/data_replicator.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/mongo/db/repl/data_replicator.cpp b/src/mongo/db/repl/data_replicator.cpp index feb54538c08..660d53e1567 100644 --- a/src/mongo/db/repl/data_replicator.cpp +++ b/src/mongo/db/repl/data_replicator.cpp @@ -1142,8 +1142,7 @@ void DataReplicator::_handleFailedApplyBatch(const TimestampStatus& ts, const Op void DataReplicator::_scheduleApplyAfterFetch(const Operations& ops) { ++_initialSyncState->fetchedMissingDocs; // TODO: check collection.isCapped, like SyncTail::getMissingDoc - const BSONObj failedOplogEntry = ops.begin()->raw; - const BSONElement missingIdElem = failedOplogEntry.getFieldDotted("o2._id"); + const BSONElement missingIdElem = ops.begin()->getIdElement(); const NamespaceString nss(ops.begin()->ns); const BSONObj query = BSON("find" << nss.coll() << "filter" << missingIdElem.wrap()); _tmpFetcher.reset(new QueryFetcher(_exec, @@ -1254,7 +1253,7 @@ Status DataReplicator::_scheduleApplyBatch_inlock(const Operations& ops) { _exec->wait(status.getValue()); }; - _applier.reset(new Applier(_exec, ops, _opts.applierFn, lambda)); + _applier.reset(new MultiApplier(_exec, ops, _opts.applierFn, _opts.multiApplyFn, lambda)); return _applier->start(); } |