/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
H A D | sync_tail.h | 59 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 D | data_replicator_external_state_mock.h | 95 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 D | data_replicator_external_state.h | 144 virtual Status _multiSyncApply(MultiApplier::OperationPtrs* ops) = 0; 152 virtual Status _multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
|
H A D | data_replicator_external_state_impl.h | 75 Status _multiSyncApply(MultiApplier::OperationPtrs* ops) override; 77 Status _multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
|
H A D | multiapplier.h | 64 using OperationPtrs = std::vector<const OplogEntry*>; variable 76 using ApplyOperationFn = stdx::function<Status(OperationPtrs*)>;
|
H A D | sync_tail_test.cpp | 586 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 D | data_replicator_external_state_mock.cpp | 106 Status DataReplicatorExternalStateMock::_multiSyncApply(MultiApplier::OperationPtrs* ops) { in _multiSyncApply() 110 Status DataReplicatorExternalStateMock::_multiInitialSyncApply(MultiApplier::OperationPtrs* ops, in _multiInitialSyncApply()
|
H A D | data_replicator_external_state_impl.cpp | 131 Status DataReplicatorExternalStateImpl::_multiSyncApply(MultiApplier::OperationPtrs* ops) { in _multiSyncApply() 135 Status DataReplicatorExternalStateImpl::_multiInitialSyncApply(MultiApplier::OperationPtrs* ops, in _multiInitialSyncApply()
|
H A D | sync_tail.cpp | 525 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 D | replication_coordinator_external_state.h | 306 virtual Status multiSyncApply(MultiApplier::OperationPtrs* ops) = 0; 313 virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
|
H A D | replication_coordinator_external_state_impl.h | 114 virtual Status multiSyncApply(MultiApplier::OperationPtrs* ops) override; 115 virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
|
H A D | replication_coordinator_external_state_mock.h | 101 virtual Status multiSyncApply(MultiApplier::OperationPtrs* ops) override; 102 virtual Status multiInitialSyncApply(MultiApplier::OperationPtrs* ops,
|
H A D | sync_tail_test_fixture.cpp | 159 MultiApplier::OperationPtrs opsPtrs{&op}; in runOpSteadyState() 173 MultiApplier::OperationPtrs opsPtrs; in runOpsInitialSync()
|
H A D | replication_coordinator_external_state_mock.cpp | 262 Status ReplicationCoordinatorExternalStateMock::multiSyncApply(MultiApplier::OperationPtrs* ops) { in multiSyncApply() 267 MultiApplier::OperationPtrs* ops, const HostAndPort& source, AtomicUInt32* fetchCount) { in multiInitialSyncApply()
|
H A D | sync_tail_test_fixture.h | 61 static Status noopApplyOperationFn(MultiApplier::OperationPtrs*) { in noopApplyOperationFn() argument
|
H A D | multiapplier_test.cpp | 64 Status applyOperation(MultiApplier::OperationPtrs*) { in applyOperation() argument
|
H A D | replication_coordinator_external_state_impl.cpp | 918 Status ReplicationCoordinatorExternalStateImpl::multiSyncApply(MultiApplier::OperationPtrs* ops) { in multiSyncApply() 926 MultiApplier::OperationPtrs* ops, const HostAndPort& source, AtomicUInt32* fetchCount) { in multiInitialSyncApply()
|
H A D | initial_syncer_test.cpp | 3632 MultiApplier::OperationPtrs*, const HostAndPort&, AtomicUInt32* fetchCount) { in TEST_F() argument
|