Home
last modified time | relevance | path

Searched refs:OperationPtrs (Results 1 – 18 of 18) sorted by relevance

/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/
H A Dsync_tail.h59 using MultiSyncApplyFunc = stdx::function<void(MultiApplier::OperationPtrs* ops, SyncTail* st)>;
279 void multiSyncApply(MultiApplier::OperationPtrs* ops, SyncTail* st);
282 void multiInitialSyncApply_abortOnFailure(MultiApplier::OperationPtrs* ops, SyncTail* st);
285 Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
297 MultiApplier::OperationPtrs* ops,
305 MultiApplier::OperationPtrs* ops,
H A Ddata_replicator_external_state_mock.h95 MultiApplier::OperationPtrs* ops, const HostAndPort& source, AtomicUInt32* fetchCount)>;
97 MultiApplier::OperationPtrs*, const HostAndPort&, AtomicUInt32*) { return Status::OK(); };
106 Status _multiSyncApply(MultiApplier::OperationPtrs* ops) override;
108 Status _multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
H A Ddata_replicator_external_state.h144 virtual Status _multiSyncApply(MultiApplier::OperationPtrs* ops) = 0;
152 virtual Status _multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
H A Ddata_replicator_external_state_impl.h75 Status _multiSyncApply(MultiApplier::OperationPtrs* ops) override;
77 Status _multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
H A Dmultiapplier.h64 using OperationPtrs = std::vector<const OplogEntry*>; variable
76 using ApplyOperationFn = stdx::function<Status(OperationPtrs*)>;
H A Dsync_tail_test.cpp586 MultiApplier::OperationPtrs ops = {&op}; in TEST_F()
602 MultiApplier::OperationPtrs ops = {&op};
613 MultiApplier::OperationPtrs ops = {&op}; in TEST_F()
629 MultiApplier::OperationPtrs ops = {&op}; in TEST_F()
639 MultiApplier::OperationPtrs ops = {&op}; in TEST_F()
697 MultiApplier::OperationPtrs ops = { in TEST_F()
750 MultiApplier::OperationPtrs ops; in TEST_F()
806 MultiApplier::OperationPtrs ops; in TEST_F()
849 MultiApplier::OperationPtrs ops; in TEST_F()
895 MultiApplier::OperationPtrs ops; in TEST_F()
[all …]
H A Ddata_replicator_external_state_mock.cpp106 Status DataReplicatorExternalStateMock::_multiSyncApply(MultiApplier::OperationPtrs* ops) { in _multiSyncApply()
110 Status DataReplicatorExternalStateMock::_multiInitialSyncApply(MultiApplier::OperationPtrs* ops, in _multiInitialSyncApply()
H A Ddata_replicator_external_state_impl.cpp131 Status DataReplicatorExternalStateImpl::_multiSyncApply(MultiApplier::OperationPtrs* ops) { in _multiSyncApply()
135 Status DataReplicatorExternalStateImpl::_multiInitialSyncApply(MultiApplier::OperationPtrs* ops, in _multiInitialSyncApply()
H A Dsync_tail.cpp525 void applyOps(std::vector<MultiApplier::OperationPtrs>& writerVectors, in applyOps()
662 std::vector<MultiApplier::OperationPtrs>* writerVectors, in fillWriterVectors()
719 std::vector<MultiApplier::OperationPtrs>* writerVectors, in fillWriterVectors()
789 auto applyOperation = [this](MultiApplier::OperationPtrs* ops) -> Status { in multiApply()
1258 void multiSyncApply(MultiApplier::OperationPtrs* ops, SyncTail*) { in multiSyncApply()
1270 MultiApplier::OperationPtrs* oplogEntryPointers, in multiSyncApply_noAbort()
1447 void multiInitialSyncApply_abortOnFailure(MultiApplier::OperationPtrs* ops, SyncTail* st) { in multiInitialSyncApply_abortOnFailure()
1454 Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops, in multiInitialSyncApply()
1463 MultiApplier::OperationPtrs* ops, in multiInitialSyncApply_noAbort()
1605 std::vector<MultiApplier::OperationPtrs> writerVectors(workerPool->getStats().numThreads); in multiApply()
H A Dreplication_coordinator_external_state.h306 virtual Status multiSyncApply(MultiApplier::OperationPtrs* ops) = 0;
313 virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
H A Dreplication_coordinator_external_state_impl.h114 virtual Status multiSyncApply(MultiApplier::OperationPtrs* ops) override;
115 virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
H A Dreplication_coordinator_external_state_mock.h101 virtual Status multiSyncApply(MultiApplier::OperationPtrs* ops) override;
102 virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
H A Dsync_tail_test_fixture.cpp159 MultiApplier::OperationPtrs opsPtrs{&op}; in runOpSteadyState()
173 MultiApplier::OperationPtrs opsPtrs; in runOpsInitialSync()
H A Dreplication_coordinator_external_state_mock.cpp262 Status ReplicationCoordinatorExternalStateMock::multiSyncApply(MultiApplier::OperationPtrs* ops) { in multiSyncApply()
267 MultiApplier::OperationPtrs* ops, const HostAndPort& source, AtomicUInt32* fetchCount) { in multiInitialSyncApply()
H A Dsync_tail_test_fixture.h61 static Status noopApplyOperationFn(MultiApplier::OperationPtrs*) { in noopApplyOperationFn() argument
H A Dmultiapplier_test.cpp64 Status applyOperation(MultiApplier::OperationPtrs*) { in applyOperation() argument
H A Dreplication_coordinator_external_state_impl.cpp918 Status ReplicationCoordinatorExternalStateImpl::multiSyncApply(MultiApplier::OperationPtrs* ops) { in multiSyncApply()
926 MultiApplier::OperationPtrs* ops, const HostAndPort& source, AtomicUInt32* fetchCount) { in multiInitialSyncApply()
H A Dinitial_syncer_test.cpp3632 MultiApplier::OperationPtrs*, const HostAndPort&, AtomicUInt32* fetchCount) { in TEST_F() argument