| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/rpc/metadata/ |
| H A D | repl_set_metadata.cpp | 58 const int ReplSetMetadata::kNoPrimary;
60 ReplSetMetadata::ReplSetMetadata(long long term, in ReplSetMetadata() function in mongo::rpc::ReplSetMetadata
75 StatusWith<ReplSetMetadata> ReplSetMetadata::readFromMetadata(const BSONObj& metadataObj) { in readFromMetadata()
123 return ReplSetMetadata( in readFromMetadata()
127 Status ReplSetMetadata::writeToMetadata(BSONObjBuilder* builder) const { in writeToMetadata()
141 std::string ReplSetMetadata::toString() const { in toString()
|
| H A D | repl_set_metadata.h | 48 class ReplSetMetadata {
56 ReplSetMetadata() = default;
57 ReplSetMetadata(long long term,
77 static StatusWith<ReplSetMetadata> readFromMetadata(const BSONObj& doc);
|
| H A D | repl_set_metadata_test.cpp | 44 ASSERT_FALSE(ReplSetMetadata(3, OpTime(), OpTime(), 6, OID(), 12, -1).hasReplicaSetId()); in TEST()
50 ReplSetMetadata metadata(3, opTime, opTime2, 6, OID::gen(), 12, -1); in TEST()
77 auto cloneStatus = ReplSetMetadata::readFromMetadata(serializedObj); in TEST()
98 auto status = ReplSetMetadata::readFromMetadata(obj); in TEST()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/repl/ |
| H A D | oplog_fetcher_test.cpp | 86 void testSyncSourceChecking(rpc::ReplSetMetadata* replMetadata,
355 rpc::ReplSetMetadata replMetadata(1, OpTime(), OpTime(), 1, OID::gen(), -1, -1); in TEST_F()
373 rpc::ReplSetMetadata replMetadata(1, OpTime(), OpTime(), 1, OID::gen(), -1, -1); in TEST_F()
390 rpc::ReplSetMetadata replMetadata(1, OpTime(), OpTime(), 1, OID::gen(), -1, -1); in TEST_F()
407 rpc::ReplSetMetadata replMetadata(1, OpTime(), OpTime(), 1, OID::gen(), -1, -1); in TEST_F()
425 rpc::ReplSetMetadata replMetadata(1, OpTime(), OpTime(), 1, OID::gen(), -1, -1); in TEST_F()
628 void OplogFetcherTest::testSyncSourceChecking(rpc::ReplSetMetadata* replMetadata, in testSyncSourceChecking()
667 rpc::ReplSetMetadata metadata(lastFetched.opTime.getTerm(), in TEST_F()
684 rpc::ReplSetMetadata replMetadata( in TEST_F()
699 rpc::ReplSetMetadata metadata(lastFetched.opTime.getTerm(), in TEST_F()
[all …]
|
| H A D | data_replicator_external_state_mock.h | 54 void processMetadata(const rpc::ReplSetMetadata& metadata,
58 const rpc::ReplSetMetadata& replMetadata,
78 rpc::ReplSetMetadata replMetadataProcessed;
|
| H A D | data_replicator_external_state_impl.cpp | 66 const rpc::ReplSetMetadata& replMetadata, boost::optional<rpc::OplogQueryMetadata> oqMetadata) { in processMetadata()
80 (replMetadata.getPrimaryIndex() != rpc::ReplSetMetadata::kNoPrimary)) { in processMetadata()
87 const rpc::ReplSetMetadata& replMetadata, in shouldStopFetching()
|
| H A D | sync_source_selector.h | 44 class ReplSetMetadata; variable
93 const rpc::ReplSetMetadata& replMetadata,
|
| H A D | data_replicator_external_state.h | 97 virtual void processMetadata(const rpc::ReplSetMetadata& replMetadata,
108 const rpc::ReplSetMetadata& replMetadata,
|
| H A D | data_replicator_external_state_impl.h | 57 void processMetadata(const rpc::ReplSetMetadata& replMetadata,
61 const rpc::ReplSetMetadata& replMetadata,
|
| H A D | data_replicator_external_state_mock.cpp | 59 const rpc::ReplSetMetadata& replMetadata, boost::optional<rpc::OplogQueryMetadata> oqMetadata) { in processMetadata()
69 const rpc::ReplSetMetadata& replMetadata, in shouldStopFetching()
|
| H A D | data_replicator_external_state_initial_sync.cpp | 45 const HostAndPort&, const rpc::ReplSetMetadata&, boost::optional<rpc::OplogQueryMetadata>) { in shouldStopFetching() argument
|
| H A D | data_replicator_external_state_initial_sync.h | 49 const rpc::ReplSetMetadata& replMetadata,
|
| H A D | sync_source_selector_mock.cpp | 62 const rpc::ReplSetMetadata&, in shouldChangeSyncSource() argument
|
| H A D | sync_source_selector_mock.h | 57 const rpc::ReplSetMetadata&,
|
| H A D | replication_coordinator_impl.h | 71 class ReplSetMetadata; variable
212 virtual void processReplSetMetadata(const rpc::ReplSetMetadata& replMetadata) override;
273 const rpc::ReplSetMetadata& replMetadata,
1001 EventHandle _processReplSetMetadata_inlock(const rpc::ReplSetMetadata& replMetadata);
|
| H A D | check_quorum_for_config_change.cpp | 249 StatusWith<rpc::ReplSetMetadata> replMetadata = in _tabulateHeartbeatResponse()
250 rpc::ReplSetMetadata::readFromMetadata(response.metadata); in _tabulateHeartbeatResponse()
|
| H A D | replication_coordinator.h | 66 class ReplSetMetadata; variable
587 virtual void processReplSetMetadata(const rpc::ReplSetMetadata& replMetadata) = 0;
|
| H A D | replication_coordinator_mock.h | 175 virtual void processReplSetMetadata(const rpc::ReplSetMetadata& replMetadata) override;
228 const rpc::ReplSetMetadata& replMetadata,
|
| H A D | replication_coordinator_mock.cpp | 298 void ReplicationCoordinatorMock::processReplSetMetadata(const rpc::ReplSetMetadata& replMetadata) {} in processReplSetMetadata()
423 const rpc::ReplSetMetadata& replMetadata, in shouldChangeSyncSource()
|
| H A D | topology_coordinator.h | 214 const rpc::ReplSetMetadata& replMetadata,
642 rpc::ReplSetMetadata prepareReplSetMetadata(const OpTime& lastVisibleOpTime) const;
|
| H A D | oplog_fetcher.cpp | 471 rpc::ReplSetMetadata replSetMetadata; in _onSuccessfulBatch()
476 auto metadataResult = rpc::ReplSetMetadata::readFromMetadata(metadataObj); in _onSuccessfulBatch()
|
| H A D | replication_coordinator_impl_test.cpp | 4625 StatusWith<rpc::ReplSetMetadata> metadata = rpc::ReplSetMetadata::readFromMetadata(BSON( in TEST_F()
4641 StatusWith<rpc::ReplSetMetadata> metadata2 = rpc::ReplSetMetadata::readFromMetadata(BSON( in TEST_F()
4729 StatusWith<rpc::ReplSetMetadata> metadata = rpc::ReplSetMetadata::readFromMetadata(BSON( in TEST_F()
4747 StatusWith<rpc::ReplSetMetadata> metadata2 = rpc::ReplSetMetadata::readFromMetadata(BSON( in TEST_F()
4765 StatusWith<rpc::ReplSetMetadata> metadata3 = rpc::ReplSetMetadata::readFromMetadata(BSON( in TEST_F()
4811 StatusWith<rpc::ReplSetMetadata> metadata = rpc::ReplSetMetadata::readFromMetadata(BSON( in TEST_F()
4926 auto replMetadata = rpc::ReplSetMetadata::readFromMetadata(metadata); in TEST_F()
4966 StatusWith<rpc::ReplSetMetadata> metadata = rpc::ReplSetMetadata::readFromMetadata(BSON( in TEST_F()
5691 rpc::ReplSetMetadata syncSourceMetadata(optime.getTerm(), optime, optime, 1, OID(), -1, 1); in TEST_F()
5696 auto metadata = unittest::assertGet(rpc::ReplSetMetadata::readFromMetadata(cmd)); in TEST_F()
|
| H A D | bgsync.cpp | 110 const rpc::ReplSetMetadata& replMetadata,
126 const rpc::ReplSetMetadata& replMetadata, in shouldStopFetching()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/catalog/ |
| H A D | sharding_catalog_test.cpp | 70 using rpc::ReplSetMetadata;
123 ReplSetMetadata metadata(10, newOpTime, newOpTime, 100, OID(), 30, -1); in TEST_F()
192 ReplSetMetadata metadata(10, newOpTime, newOpTime, 100, OID(), 30, -1); in TEST_F()
415 ReplSetMetadata metadata(10, newOpTime, newOpTime, 100, OID(), 30, -1); in TEST_F()
830 ReplSetMetadata metadata(10, newOpTime, newOpTime, 100, OID(), 30, -1); in TEST_F()
1343 ReplSetMetadata metadata(10, newOpTime, newOpTime, 100, OID(), 30, -1); in TEST_F()
1379 ReplSetMetadata metadata(10, newOpTime, newOpTime, 100, OID(), 30, -1); in TEST_F()
1408 ReplSetMetadata metadata(10, oldOpTime, oldOpTime, 100, OID(), 30, -1); in TEST_F()
1433 ReplSetMetadata metadata(10, oldOpTime, oldOpTime, 100, OID(), 30, -1); in TEST_F()
1463 ReplSetMetadata metadata(10, newOpTime, newOpTime, 100, OID(), 30, -1); in TEST_F()
[all …]
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/ |
| H A D | sharding_egress_metadata_hook.cpp | 95 auto parseStatus = rpc::ReplSetMetadata::readFromMetadata(metadataObj); in _advanceConfigOpTimeFromShard()
|