diff options
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); } |