diff options
| author | liubov.molchanova <liubov.molchanova@mongodb.com> | 2023-02-26 11:16:55 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-02-26 18:25:36 +0000 |
| commit | 4fa82ec65ce017b254a14cecafb0ac97bdcb141e (patch) | |
| tree | f8d4c66804285f34c32d98821277d12dbec75b37 /src/mongo/db/repl/oplog_applier_impl.cpp | |
| parent | 71f90697444a61f9023c205d8df945d26dd033b7 (diff) | |
| download | mongo-4fa82ec65ce017b254a14cecafb0ac97bdcb141e.tar.gz | |
Revert "SERVER-73118 Implement split prepare/commit/abort oplog application on secondary."
This reverts commit 3a6478a700f1995cdb16ed434a6e124b8567bf60.
Diffstat (limited to 'src/mongo/db/repl/oplog_applier_impl.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplog_applier_impl.cpp | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/mongo/db/repl/oplog_applier_impl.cpp b/src/mongo/db/repl/oplog_applier_impl.cpp index 0e2b669304b..a294d725202 100644 --- a/src/mongo/db/repl/oplog_applier_impl.cpp +++ b/src/mongo/db/repl/oplog_applier_impl.cpp @@ -98,7 +98,7 @@ Status finishAndLogApply(OperationContext* opCtx, logv2::DynamicAttributes attrs; auto redacted = redact(entryOrGroupedInserts.toBSON()); - if (entryOrGroupedInserts.getOp()->getOpType() == OpTypeEnum::kCommand) { + if (entryOrGroupedInserts.getOp().getOpType() == OpTypeEnum::kCommand) { attrs.add("command", redacted); } else { attrs.add("CRUD", redacted); @@ -576,6 +576,7 @@ StatusWith<OpTime> OplogApplierImpl::_applyOplogBatch(OperationContext* opCtx, } { + std::vector<Status> statusVector(_writerPool->getStats().options.maxThreads, Status::OK()); // Doles out all the work to the writer pool threads. writerVectors is not modified, @@ -901,16 +902,16 @@ Status applyOplogEntryOrGroupedInserts(OperationContext* opCtx, &replOpCounters); auto op = entryOrGroupedInserts.getOp(); - if (op->getOpType() == OpTypeEnum::kNoop) { + if (op.getOpType() == OpTypeEnum::kNoop) { // No-ops should never fail application, since there's nothing to do. invariant(status.isOK()); - auto opObj = op->getObject(); + auto opObj = op.getObject(); if (opObj.hasField(ReplicationCoordinator::newPrimaryMsgField) && opObj.getField(ReplicationCoordinator::newPrimaryMsgField).str() == ReplicationCoordinator::newPrimaryMsg) { - ReplicationMetrics::get(opCtx).setParticipantNewTermDates(op->getWallClockTime(), + ReplicationMetrics::get(opCtx).setParticipantNewTermDates(op.getWallClockTime(), applyStartTime); } |