| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
| H A D | replication_coordinator_impl_elect_v1_test.cpp | 972 auto replCoord = getReplCoord(); in TEST_F() local
1011 auto replCoord = getReplCoord(); in TEST_F() local
1062 auto replCoord = getReplCoord(); in TEST_F() local
1116 auto replCoord = getReplCoord(); in TEST_F() local
1166 auto replCoord = getReplCoord(); in TEST_F() local
1437 ASSERT_EQUALS(ErrorCodes::StaleTerm, replCoord->updateTerm(&opCtx, replCoord->getTerm() + 1)); in TEST_F()
1508 ASSERT_EQUALS(ErrorCodes::StaleTerm, replCoord->updateTerm(&opCtx, replCoord->getTerm() + 1)); in TEST_F()
1610 ASSERT_EQUALS(ErrorCodes::StaleTerm, replCoord->updateTerm(&opCtx, replCoord->getTerm() + 1)); in TEST_F()
1675 ASSERT_EQUALS(ErrorCodes::StaleTerm, replCoord->updateTerm(&opCtx, replCoord->getTerm() + 1)); in TEST_F()
1770 ASSERT_EQUALS(ErrorCodes::StaleTerm, replCoord->updateTerm(&opCtx, replCoord->getTerm() + 1)); in TEST_F()
[all …]
|
| H A D | replication_coordinator_test_fixture.cpp | 330 ASSERT(replCoord->getMemberState().secondary()) << replCoord->getMemberState().toString(); in simulateSuccessfulV1ElectionWithoutExitingDrainMode()
374 ASSERT(replCoord->getMemberState().primary()) << replCoord->getMemberState().toString(); in simulateSuccessfulV1ElectionWithoutExitingDrainMode()
377 replCoord->fillIsMasterForReplSet(&imResponse, {}); in simulateSuccessfulV1ElectionWithoutExitingDrainMode()
392 replCoord->fillIsMasterForReplSet(&imResponse, {}); in simulateSuccessfulV1ElectionAt()
396 ASSERT(replCoord->getMemberState().primary()) << replCoord->getMemberState().toString(); in simulateSuccessfulV1ElectionAt()
403 ASSERT(replCoord->getMemberState().secondary()) << replCoord->getMemberState().toString(); in simulateSuccessfulElection()
444 ASSERT(replCoord->getMemberState().primary()) << replCoord->getMemberState().toString(); in simulateSuccessfulElection()
447 replCoord->fillIsMasterForReplSet(&imResponse, {}); in simulateSuccessfulElection()
452 replCoord->signalDrainComplete(opCtx.get(), replCoord->getTerm()); in simulateSuccessfulElection()
454 replCoord->fillIsMasterForReplSet(&imResponse, {}); in simulateSuccessfulElection()
[all …]
|
| H A D | sync_source_feedback.cpp | 71 ReplicationCoordinator* replCoord, const HostAndPort& syncTarget, BackgroundSync* bgsync) { in makePrepareReplSetUpdatePositionCommandFn() argument
72 return [syncTarget, replCoord, bgsync]() -> StatusWith<BSONObj> { in makePrepareReplSetUpdatePositionCommandFn()
88 if (replCoord->getMemberState().primary()) { in makePrepareReplSetUpdatePositionCommandFn()
94 return replCoord->prepareReplSetUpdatePositionCommand(); in makePrepareReplSetUpdatePositionCommandFn()
147 ReplicationCoordinator* replCoord) { in run() argument
158 keepAliveInterval = calculateKeepAliveInterval(replCoord->getConfig()); in run()
174 MemberState state = replCoord->getMemberState(); in run()
189 MemberState state = replCoord->getMemberState(); in run()
211 keepAliveInterval = calculateKeepAliveInterval(replCoord->getConfig()); in run()
219 makePrepareReplSetUpdatePositionCommandFn(replCoord, syncTarget, bgsync), in run()
|
| H A D | sync_tail.cpp | 185 ApplyBatchFinalizer(ReplicationCoordinator* replCoord) : _replCoord(replCoord) {} in ApplyBatchFinalizer() argument
215 : ApplyBatchFinalizer(replCoord), in ApplyBatchFinalizerForJournal()
734 if (replCoord->isInPrimaryOrSecondaryState()) { in tryToGoLiveAsASecondary()
745 if (replCoord->getMaintenanceMode()) { in tryToGoLiveAsASecondary()
751 MemberState state(replCoord->getMemberState()); in tryToGoLiveAsASecondary()
762 auto lastApplied = replCoord->getMyLastAppliedOpTime(); in tryToGoLiveAsASecondary()
846 auto slaveDelay = replCoord->getSlaveDelaySecs(); in _calculateSlaveDelayLatestTimestamp()
906 _oplogApplication(replCoord, &batcher); in oplogApplication()
913 ? new ApplyBatchFinalizerForJournal(replCoord) in _oplogApplication()
914 : new ApplyBatchFinalizer(replCoord)}; in _oplogApplication()
[all …]
|
| H A D | replication_info.cpp | 82 ReplicationCoordinator* replCoord = getGlobalReplicationCoordinator(); in appendReplicationInfo() local
83 if (replCoord->getSettings().usingReplSets()) { in appendReplicationInfo()
86 replCoord->fillIsMasterForReplSet(&isMasterResponse, horizonParams); in appendReplicationInfo()
89 replCoord->appendSlaveInfoData(&result); in appendReplicationInfo()
164 replCoord->appendSlaveInfoData(&result); in appendReplicationInfo()
205 ReplicationCoordinator* replCoord = getGlobalReplicationCoordinator(); in generateSection() local
206 if (!replCoord->isReplEnabled()) { in generateSection()
212 result.append("latestOptime", replCoord->getMyLastAppliedOpTime().getTimestamp()); in generateSection()
215 replCoord->getReplicationMode() == ReplicationCoordinator::modeReplSet in generateSection()
|
| H A D | repl_client_info.cpp | 55 auto replCoord = repl::ReplicationCoordinator::get(opCtx->getServiceContext()); in setLastOpToSystemLastOpTime() local
56 if (replCoord->isReplEnabled() && opCtx->writesAreReplicated()) { in setLastOpToSystemLastOpTime()
57 auto systemOpTime = replCoord->getMyLastAppliedOpTime(); in setLastOpToSystemLastOpTime()
|
| H A D | resync.cpp | 85 ReplicationCoordinator* replCoord = getGlobalReplicationCoordinator(); in errmsgRun() local
99 const MemberState memberState = replCoord->getMemberState(); in errmsgRun()
108 auto status = replCoord->setFollowerMode(MemberState::RS_STARTUP2); in errmsgRun()
118 uassertStatusOKWithLocation(replCoord->resyncData(opCtx, waitForResync), "resync", 0); in errmsgRun()
|
| H A D | noop_writer.cpp | 154 auto replCoord = ReplicationCoordinator::get(opCtx); in _writeNoop() local
156 if (!replCoord->canAcceptWritesForDatabase(opCtx, "admin")) { in _writeNoop()
161 auto lastAppliedOpTime = replCoord->getMyLastAppliedOpTime(); in _writeNoop()
183 _lastKnownOpTime = replCoord->getMyLastAppliedOpTime(); in _writeNoop()
|
| H A D | rs_rollback_no_uuid.cpp | 440 ReplicationCoordinator* replCoord, in syncFixUp() argument
943 replCoord->resetLastOpTimesFromOplog(opCtx, in syncFixUp()
951 ReplicationCoordinator* replCoord, in _syncRollback() argument
995 OpTime lastCommittedOpTime = replCoord->getLastCommittedOpTime(); in _syncRollback()
1001 invariant(!replCoord->isV1ElectionProtocol() || in _syncRollback()
1013 syncFixUp(opCtx, how, rollbackSource, replCoord, replicationProcess); in _syncRollback()
1046 ReplicationCoordinator* replCoord, in syncRollbackNoUUID() argument
1049 invariant(replCoord); in syncRollbackNoUUID()
1066 ReplicationCoordinator* replCoord, in rollbackNoUUID() argument
1083 auto status = replCoord->setFollowerMode(MemberState::RS_ROLLBACK); in rollbackNoUUID()
[all …]
|
| H A D | rs_rollback.cpp | 881 ReplicationCoordinator* replCoord, in _syncRollback() argument
929 OpTime lastCommittedOpTime = replCoord->getLastCommittedOpTime(); in _syncRollback()
935 invariant(!replCoord->isV1ElectionProtocol() || in _syncRollback()
949 syncFixUp(opCtx, how, rollbackSource, replCoord, replicationProcess); in _syncRollback()
981 ReplicationCoordinator* replCoord, in syncFixUp() argument
1447 replCoord->resetLastOpTimesFromOplog(opCtx, in syncFixUp()
1455 ReplicationCoordinator* replCoord, in syncRollback() argument
1458 invariant(replCoord); in syncRollback()
1475 ReplicationCoordinator* replCoord, in rollback() argument
1492 auto status = replCoord->setFollowerMode(MemberState::RS_ROLLBACK); in rollback()
[all …]
|
| H A D | replication_coordinator_impl_test.cpp | 128 auto replCoord = getReplCoord(); in TEST_F() local
141 replCoord->updateTerm_forTest(replCoord->getTerm() + 1, &updateTermResult); in TEST_F()
1065 : _replCoord(replCoord), in ReplicationAwaiter()
4807 auto replCoord = getReplCoord(); in TEST_F() local
4808 auto config = replCoord->getConfig(); in TEST_F()
4961 auto replCoord = getReplCoord(); in TEST_F() local
4962 auto config = replCoord->getConfig(); in TEST_F()
5246 hbResp.setTerm(replCoord->getTerm()); in TEST_F()
5866 auto replCoord = getReplCoord(); in TEST_F() local
5867 auto initialTerm = replCoord->getTerm(); in TEST_F()
[all …]
|
| H A D | rs_sync.cpp | 49 RSDataSync::RSDataSync(BackgroundSync* bgsync, ReplicationCoordinator* replCoord) in RSDataSync() argument
50 : _bgsync(bgsync), _replCoord(replCoord) {} in RSDataSync()
|
| H A D | rs_rollback.h | 149 ReplicationCoordinator* replCoord,
182 ReplicationCoordinator* replCoord,
374 ReplicationCoordinator* replCoord,
|
| H A D | replication_coordinator.cpp | 67 std::unique_ptr<ReplicationCoordinator> replCoord) { in set() argument
69 coordinator = std::move(replCoord); in set()
|
| H A D | replication_coordinator_impl_elect_v1.cpp | 53 LoseElectionGuardV1(ReplicationCoordinatorImpl* replCoord) : _replCoord(replCoord) {} in LoseElectionGuardV1() argument
83 LoseElectionDryRunGuardV1(ReplicationCoordinatorImpl* replCoord) in LoseElectionDryRunGuardV1() argument
84 : LoseElectionGuardV1(replCoord) { in LoseElectionDryRunGuardV1()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/ |
| H A D | read_concern.cpp | 114 invariant(replCoord->isReplEnabled()); in makeNoopWriteIfNeeded()
210 invariant(replCoord); in waitForReadConcern()
221 if (!replCoord->isV1ElectionProtocol()) { in waitForReadConcern()
232 if (!replCoord->getMemberState().primary()) { in waitForReadConcern()
265 if (replCoord->isReplEnabled() && afterClusterTime) { in waitForReadConcern()
273 if (replCoord->isReplEnabled() || !afterClusterTime) { in waitForReadConcern()
284 if (!replCoord->isV1ElectionProtocol()) { in waitForReadConcern()
300 replCoord->waitUntilSnapshotCommitted(opCtx, Timestamp()); in waitForReadConcern()
316 repl::ReplicationCoordinator* replCoord = in waitForLinearizableReadConcern() local
323 if (!replCoord->canAcceptWritesForDatabase(opCtx, "admin")) { in waitForLinearizableReadConcern()
[all …]
|
| H A D | log_process_details.cpp | 74 auto replCoord = repl::getGlobalReplicationCoordinator(); in logProcessDetailsForLogRotate() local
75 if (replCoord != nullptr && in logProcessDetailsForLogRotate()
76 replCoord->getReplicationMode() == repl::ReplicationCoordinator::modeReplSet) { in logProcessDetailsForLogRotate()
77 auto rsConfig = replCoord->getConfig(); in logProcessDetailsForLogRotate()
81 log() << "Replica Set Member State: " << (replCoord->getMemberState()).toString(); in logProcessDetailsForLogRotate()
|
| H A D | write_concern.cpp | 172 auto const replCoord = repl::ReplicationCoordinator::get(opCtx); in waitForWriteConcern() local
182 replCoord->populateUnsetWriteConcernOptionsSyncMode(writeConcern); in waitForWriteConcern()
201 if (replCoord->getReplicationMode() != repl::ReplicationCoordinator::Mode::modeNone) { in waitForWriteConcern()
204 OpTime appliedOpTime = replCoord->getMyLastAppliedOpTime(); in waitForWriteConcern()
206 replCoord->setMyLastDurableOpTimeForward(appliedOpTime); in waitForWriteConcern()
231 replCoord->awaitReplication(opCtx, replOpTime, writeConcernWithPopulatedSyncMode); in waitForWriteConcern()
239 result->writtenTo = replCoord->getHostsWrittenTo(replOpTime, in waitForWriteConcern()
|
| H A D | service_entry_point_mongod.cpp | 237 auto const replCoord = repl::ReplicationCoordinator::get(opCtx); in appendReplyMetadata() local
239 replCoord->getReplicationMode() == repl::ReplicationCoordinator::modeReplSet; in appendReplyMetadata()
249 rpc::ShardingMetadata(lastOpTimeFromClient, replCoord->getElectionId()) in appendReplyMetadata()
318 auto const replCoord = repl::ReplicationCoordinator::get(opCtx); in getClientOperationTime() local
337 auto const replCoord = repl::ReplicationCoordinator::get(opCtx); in computeOperationTime() local
343 return LogicalTime(replCoord->getMyLastAppliedOpTime().getTimestamp()); in computeOperationTime()
582 auto const replCoord = repl::ReplicationCoordinator::get(opCtx); in execCommandDatabase() local
674 !replCoord->canAcceptWritesForDatabase_UNSAFE(opCtx, dbname) && in execCommandDatabase()
675 !replCoord->getMemberState().secondary()) { in execCommandDatabase()
679 !replCoord->getMemberState().recovering()); in execCommandDatabase()
[all …]
|
| H A D | dbdirectclient.cpp | 109 auto const* replCoord = repl::ReplicationCoordinator::get(_opCtx); in isReplicaSetMember() local
110 return replCoord && replCoord->isReplEnabled(); in isReplicaSetMember()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/catalog/ |
| H A D | drop_database.cpp | 100 auto replCoord = repl::ReplicationCoordinator::get(opCtx); in dropDatabase() local
120 opCtx->writesAreReplicated() && !replCoord->canAcceptWritesForDatabase(opCtx, dbName); in dropDatabase()
138 if (nss.isDropPendingNamespace() && replCoord->isReplEnabled() && in dropDatabase()
145 if (replCoord->isOplogDisabledFor(opCtx, nss) || nss.isSystemDotIndexes()) { in dropDatabase()
208 auto result = replCoord->awaitReplication(opCtx, awaitOpTime, kDropDatabaseWriteConcern); in dropDatabase()
243 opCtx->writesAreReplicated() && !replCoord->canAcceptWritesForDatabase(opCtx, dbName); in dropDatabase()
249 << replCoord->getMemberState().toString() in dropDatabase()
|
| H A D | capped_utils_test.cpp | 65 auto replCoord = stdx::make_unique<repl::ReplicationCoordinatorMock>(service); in setUp() local
66 ASSERT_OK(replCoord->setFollowerMode(repl::MemberState::RS_PRIMARY)); in setUp()
67 repl::ReplicationCoordinator::set(service, std::move(replCoord)); in setUp()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/commands/ |
| H A D | conn_pool_stats.cpp | 87 auto const replCoord = repl::ReplicationCoordinator::get(opCtx); in run() local
88 if (replCoord && replCoord->isReplEnabled()) { in run()
89 replCoord->appendConnectionStats(&stats); in run()
|
| H A D | oplog_note.cpp | 58 repl::ReplicationCoordinator* const replCoord = repl::ReplicationCoordinator::get(opCtx); in _performNoopWrite() local
71 if (!replCoord->canAcceptWritesForDatabase(opCtx, "admin")) { in _performNoopWrite()
122 auto replCoord = repl::ReplicationCoordinator::get(opCtx); in run() local
123 if (!replCoord->isReplEnabled()) { in run()
147 auto lastAppliedOpTime = replCoord->getMyLastAppliedOpTime().getTimestamp(); in run()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/client/ |
| H A D | rs_local_client.cpp | 108 auto replCoord = repl::ReplicationCoordinator::get(opCtx); in queryOnce() local
115 Status readConcernStatus = replCoord->waitUntilOpTimeForRead( in queryOnce()
155 replCoord->getCurrentCommittedSnapshotOpTime()}; in queryOnce()
|