diff options
| author | Wenbin Zhu <wenbin.zhu@mongodb.com> | 2023-02-27 17:00:39 +0000 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2023-02-27 19:40:30 +0000 |
| commit | eb053ea6c479d5d001fcb688613787b6f2c105f0 (patch) | |
| tree | 69d4da912a8b80e32f030d18d9f8a7a13f910720 /src/mongo/db/repl/oplog_applier_impl.cpp | |
| parent | 2285ffddafaab361411832956e15c20fd42513b2 (diff) | |
| download | mongo-eb053ea6c479d5d001fcb688613787b6f2c105f0.tar.gz | |
SERVER-73118 Implement split prepare/commit/abort oplog application on secondary.
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, 4 insertions, 5 deletions
diff --git a/src/mongo/db/repl/oplog_applier_impl.cpp b/src/mongo/db/repl/oplog_applier_impl.cpp index a294d725202..0e2b669304b 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,7 +576,6 @@ 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, @@ -902,16 +901,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); } |