diff options
author | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2017-06-21 20:01:36 -0400 |
---|---|---|
committer | Kaloian Manassiev <kaloian.manassiev@mongodb.com> | 2017-06-26 10:43:02 -0400 |
commit | 95dae0d467d6798b015a5328073a5e3c9e75cdc8 (patch) | |
tree | 6ddaeee1c17a2288abdc882feda7ab5adf7592f4 /src | |
parent | b798e8d10ee53e1448a6ef0542d9d022037d2ea7 (diff) | |
download | mongo-95dae0d467d6798b015a5328073a5e3c9e75cdc8.tar.gz |
SERVER-29804 Remove 'undefined behaviour' in the sharding catalog unit-tests
Diffstat (limited to 'src')
7 files changed, 45 insertions, 63 deletions
diff --git a/src/mongo/s/balancer_configuration_test.cpp b/src/mongo/s/balancer_configuration_test.cpp index 90ef685b740..834d3d12157 100644 --- a/src/mongo/s/balancer_configuration_test.cpp +++ b/src/mongo/s/balancer_configuration_test.cpp @@ -51,12 +51,12 @@ using executor::RemoteCommandRequest; using std::vector; using unittest::assertGet; -const BSONObj kReplSecondaryOkMetadata{[] { +BSONObj getReplSecondaryOkMetadata() { BSONObjBuilder o; ReadPreferenceSetting(ReadPreference::Nearest).toContainingBSON(&o); o.append(rpc::kReplSetMetadataFieldName, 1); return o.obj(); -}()}; +} class BalancerConfigurationTestFixture : public ShardingTestFixture { protected: @@ -66,7 +66,7 @@ protected: */ void expectSettingsQuery(StringData key, StatusWith<boost::optional<BSONObj>> result) { onFindCommand([&](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); diff --git a/src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp b/src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp index 2b018ac7e1a..d3921a83cd5 100644 --- a/src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp @@ -36,11 +36,8 @@ #include "mongo/client/remote_command_targeter_factory_mock.h" #include "mongo/client/remote_command_targeter_mock.h" #include "mongo/db/commands.h" -#include "mongo/db/query/query_request.h" -#include "mongo/db/repl/member_state.h" #include "mongo/db/repl/replication_coordinator_mock.h" #include "mongo/db/s/type_shard_identity.h" -#include "mongo/rpc/metadata/repl_set_metadata.h" #include "mongo/s/catalog/config_server_version.h" #include "mongo/s/catalog/sharding_catalog_manager.h" #include "mongo/s/catalog/type_changelog.h" @@ -67,13 +64,6 @@ using executor::RemoteCommandResponse; using std::vector; using unittest::assertGet; -const BSONObj kReplSecondaryOkMetadata{[] { - BSONObjBuilder o; - ReadPreferenceSetting(ReadPreference::Nearest).toContainingBSON(&o); - o.append(rpc::kReplSetMetadataFieldName, 1); - return o.obj(); -}()}; - // TODO (SERVER-27029): This value was chosen to be greater than the time it takes for the hang // analyzer to kick in. Remove once the cause for the test failure has been figured out. const Hours kLongFutureTimeout(8); diff --git a/src/mongo/s/catalog/sharding_catalog_append_db_stats_test.cpp b/src/mongo/s/catalog/sharding_catalog_append_db_stats_test.cpp index 3cbe14fc0d4..69222f3d06e 100644 --- a/src/mongo/s/catalog/sharding_catalog_append_db_stats_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_append_db_stats_test.cpp @@ -50,12 +50,12 @@ using executor::RemoteCommandResponse; using ShardingCatalogClientAppendDbStatsTest = ShardingCatalogTestFixture; -const BSONObj kReplSecondaryOkMetadata{[] { +BSONObj getReplSecondaryOkMetadata() { BSONObjBuilder o; ReadPreferenceSetting(ReadPreference::PrimaryPreferred).toContainingBSON(&o); o.append(rpc::kReplSetMetadataFieldName, 1); return o.obj(); -}()}; +} TEST_F(ShardingCatalogClientAppendDbStatsTest, BasicAppendDBStats) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); @@ -67,7 +67,7 @@ TEST_F(ShardingCatalogClientAppendDbStatsTest, BasicAppendDBStats) { }); onCommand([](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ("admin", request.dbname); @@ -130,7 +130,7 @@ TEST_F(ShardingCatalogClientAppendDbStatsTest, AppendDBStatsWithFilter) { }); onCommand([](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ("admin", request.dbname); diff --git a/src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp b/src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp index 5197b4ba3cd..b5d903cf41b 100644 --- a/src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp @@ -62,14 +62,14 @@ using std::string; using std::vector; using unittest::assertGet; -static const Seconds kFutureTimeout{5}; +const Seconds kFutureTimeout{5}; -const BSONObj kReplSecondaryOkMetadata{[] { +BSONObj getReplSecondaryOkMetadata() { BSONObjBuilder o; ReadPreferenceSetting(ReadPreference::Nearest).toContainingBSON(&o); o.append(rpc::kReplSetMetadataFieldName, 1); return o.obj(); -}()}; +} class RemoveShardTest : public ShardingCatalogTestFixture { public: @@ -181,7 +181,7 @@ TEST_F(RemoveShardTest, RemoveShardStartDraining) { // Respond to request to reload information about existing shards onFindCommand([&](const RemoteCommandRequest& request) { ASSERT_EQUALS(configHost, request.target); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -355,7 +355,7 @@ TEST_F(RemoveShardTest, RemoveShardCompletion) { // Respond to request to reload information about existing shards onFindCommand([&](const RemoteCommandRequest& request) { ASSERT_EQUALS(configHost, request.target); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); diff --git a/src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp b/src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp index 87b62c3f7c8..48316b7775c 100644 --- a/src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp @@ -34,13 +34,13 @@ #include <string> #include <vector> +#include "mongo/client/read_preference.h" #include "mongo/client/remote_command_targeter_factory_mock.h" #include "mongo/client/remote_command_targeter_mock.h" #include "mongo/db/client.h" #include "mongo/db/commands.h" #include "mongo/executor/network_interface_mock.h" #include "mongo/executor/task_executor.h" -#include "mongo/rpc/metadata/repl_set_metadata.h" #include "mongo/rpc/metadata/tracking_metadata.h" #include "mongo/s/catalog/dist_lock_catalog_impl.h" #include "mongo/s/catalog/sharding_catalog_manager_impl.h" @@ -74,13 +74,6 @@ using std::string; using std::vector; using unittest::assertGet; -const BSONObj kReplSecondaryOkMetadata{[] { - BSONObjBuilder o; - ReadPreferenceSetting(ReadPreference::Nearest).toContainingBSON(&o); - o.append(rpc::kReplSetMetadataFieldName, 1); - return o.obj(); -}()}; - class ShardCollectionTest : public ConfigServerTestFixture { public: void expectCount(const HostAndPort& receivingHost, diff --git a/src/mongo/s/catalog/sharding_catalog_test.cpp b/src/mongo/s/catalog/sharding_catalog_test.cpp index 8ead7bf2408..60fb60873cb 100644 --- a/src/mongo/s/catalog/sharding_catalog_test.cpp +++ b/src/mongo/s/catalog/sharding_catalog_test.cpp @@ -76,12 +76,12 @@ using ShardingCatalogClientTest = ShardingCatalogTestFixture; const int kMaxCommandRetry = 3; -const BSONObj kReplSecondaryOkMetadata{[] { +BSONObj getReplSecondaryOkMetadata() { BSONObjBuilder o; ReadPreferenceSetting(ReadPreference::Nearest).toContainingBSON(&o); o.append(rpc::kReplSetMetadataFieldName, 1); return o.obj(); -}()}; +} TEST_F(ShardingCatalogClientTest, GetCollectionExisting) { configTargeter()->setFindHostReturnValue(HostAndPort("TestHost1")); @@ -102,7 +102,7 @@ TEST_F(ShardingCatalogClientTest, GetCollectionExisting) { onFindWithMetadataCommand( [this, &expectedColl, newOpTime](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -170,7 +170,7 @@ TEST_F(ShardingCatalogClientTest, GetDatabaseExisting) { const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); ASSERT_EQ(nss.ns(), DatabaseType::ConfigNS); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); auto query = assertGet(QueryRequest::makeFromFindCommand(nss, request.cmdObj, false)); @@ -287,7 +287,7 @@ TEST_F(ShardingCatalogClientTest, GetAllShardsValid) { }); onFindCommand([this, &s1, &s2, &s3](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -385,7 +385,7 @@ TEST_F(ShardingCatalogClientTest, GetChunksForNSWithSortAndLimit) { onFindWithMetadataCommand( [this, &chunksQuery, chunkA, chunkB, newOpTime](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -439,7 +439,7 @@ TEST_F(ShardingCatalogClientTest, GetChunksForNSNoSortNoLimit) { }); onFindCommand([this, &chunksQuery](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -801,7 +801,7 @@ TEST_F(ShardingCatalogClientTest, GetCollectionsValidResultsNoDb) { onFindWithMetadataCommand( [this, coll1, coll2, coll3, newOpTime](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -859,7 +859,7 @@ TEST_F(ShardingCatalogClientTest, GetCollectionsValidResultsWithDb) { }); onFindCommand([this, coll1, coll2](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -911,7 +911,7 @@ TEST_F(ShardingCatalogClientTest, GetCollectionsInvalidCollectionType) { const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); ASSERT_EQ(nss.ns(), CollectionType::ConfigNS); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); auto query = assertGet(QueryRequest::makeFromFindCommand(nss, request.cmdObj, false)); @@ -955,7 +955,7 @@ TEST_F(ShardingCatalogClientTest, GetDatabasesForShardValid) { }); onFindCommand([this, dbt1, dbt2](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -1031,7 +1031,7 @@ TEST_F(ShardingCatalogClientTest, GetTagsForCollection) { }); onFindCommand([this, tagA, tagB](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -1328,7 +1328,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseSuccess) { onFindCommand([&](const RemoteCommandRequest& request) { ASSERT_EQUALS(configHost, request.target); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -1372,7 +1372,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseSuccess) { onFindCommand([&](const RemoteCommandRequest& request) { ASSERT_EQUALS(configHost, request.target); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(DatabaseType::ConfigNS, nss.ns()); checkReadConcern(request.cmdObj, Timestamp(0, 0), repl::OpTime::kUninitializedTerm); @@ -1490,7 +1490,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseDBExists) { }); onFindCommand([this, dbname](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -1527,7 +1527,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseDBExistsDifferentCase) { }); onFindCommand([this, dbname, dbnameDiffCase](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); @@ -1564,7 +1564,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseNoShards) { // Report no databases with the same name already exist onFindCommand([this, dbname](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); ASSERT_EQ(DatabaseType::ConfigNS, nss.ns()); @@ -1574,7 +1574,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseNoShards) { // Report no shards exist onFindCommand([this](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); auto query = assertGet(QueryRequest::makeFromFindCommand(nss, request.cmdObj, false)); @@ -1614,7 +1614,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseDuplicateKeyOnInsert) { onFindCommand([&](const RemoteCommandRequest& request) { ASSERT_EQUALS(configHost, request.target); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); auto query = assertGet(QueryRequest::makeFromFindCommand(nss, request.cmdObj, false)); @@ -1656,7 +1656,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseDuplicateKeyOnInsert) { // Report no databases with the same name already exist onFindCommand([&](const RemoteCommandRequest& request) { ASSERT_EQUALS(configHost, request.target); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); ASSERT_EQ(DatabaseType::ConfigNS, nss.ns()); @@ -1774,7 +1774,7 @@ TEST_F(ShardingCatalogClientTest, EnableShardingNoDBExists) { // Query to find if db already exists in config. onFindCommand([this](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); ASSERT_EQ(DatabaseType::ConfigNS, nss.toString()); @@ -2029,7 +2029,7 @@ TEST_F(ShardingCatalogClientTest, BasicReadAfterOpTime) { onCommandWithMetadata([this, &newOpTime, &lastOpTime](const RemoteCommandRequest& request) { ASSERT_EQUALS("test", request.dbname); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(string("dummy"), request.cmdObj.firstElementFieldName()); @@ -2065,7 +2065,7 @@ TEST_F(ShardingCatalogClientTest, ReadAfterOpTimeShouldNotGoBack) { onCommandWithMetadata([this, &newOpTime, &highestOpTime](const RemoteCommandRequest& request) { ASSERT_EQUALS("test", request.dbname); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(string("dummy"), request.cmdObj.firstElementFieldName()); @@ -2094,7 +2094,7 @@ TEST_F(ShardingCatalogClientTest, ReadAfterOpTimeShouldNotGoBack) { onCommandWithMetadata([this, &oldOpTime, &highestOpTime](const RemoteCommandRequest& request) { ASSERT_EQUALS("test", request.dbname); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(string("dummy"), request.cmdObj.firstElementFieldName()); @@ -2119,7 +2119,7 @@ TEST_F(ShardingCatalogClientTest, ReadAfterOpTimeShouldNotGoBack) { onCommandWithMetadata([this, &oldOpTime, &highestOpTime](const RemoteCommandRequest& request) { ASSERT_EQUALS("test", request.dbname); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(string("dummy"), request.cmdObj.firstElementFieldName()); @@ -2147,7 +2147,7 @@ TEST_F(ShardingCatalogClientTest, ReadAfterOpTimeFindThenCmd) { onFindWithMetadataCommand( [this, &newOpTime, &highestOpTime](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); checkReadConcern(request.cmdObj, highestOpTime.getTimestamp(), highestOpTime.getTerm()); @@ -2179,7 +2179,7 @@ TEST_F(ShardingCatalogClientTest, ReadAfterOpTimeFindThenCmd) { onCommand([this, &oldOpTime, &highestOpTime](const RemoteCommandRequest& request) { ASSERT_EQUALS("test", request.dbname); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(string("dummy"), request.cmdObj.firstElementFieldName()); @@ -2207,7 +2207,7 @@ TEST_F(ShardingCatalogClientTest, ReadAfterOpTimeCmdThenFind) { onCommandWithMetadata([this, &newOpTime, &highestOpTime](const RemoteCommandRequest& request) { ASSERT_EQUALS("test", request.dbname); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(string("dummy"), request.cmdObj.firstElementFieldName()); @@ -2232,7 +2232,7 @@ TEST_F(ShardingCatalogClientTest, ReadAfterOpTimeCmdThenFind) { const OpTime oldOpTime(Timestamp(3, 10), 5); onFindCommand([this, &oldOpTime, &highestOpTime](const RemoteCommandRequest& request) { - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); ASSERT_EQ(string("find"), request.cmdObj.firstElementFieldName()); diff --git a/src/mongo/s/cluster_identity_loader_test.cpp b/src/mongo/s/cluster_identity_loader_test.cpp index da54b11bb26..24b77c5d8eb 100644 --- a/src/mongo/s/cluster_identity_loader_test.cpp +++ b/src/mongo/s/cluster_identity_loader_test.cpp @@ -55,15 +55,14 @@ namespace { using executor::NetworkInterfaceMock; using executor::RemoteCommandRequest; using executor::TaskExecutor; -using stdx::async; using unittest::assertGet; -const BSONObj kReplSecondaryOkMetadata{[] { +BSONObj getReplSecondaryOkMetadata() { BSONObjBuilder o; ReadPreferenceSetting(ReadPreference::Nearest).toContainingBSON(&o); o.append(rpc::kReplSetMetadataFieldName, 1); return o.obj(); -}()}; +} class ClusterIdentityTest : public ShardingTestFixture { public: @@ -76,7 +75,7 @@ public: void expectConfigVersionLoad(StatusWith<OID> result) { onFindCommand([&](const RemoteCommandRequest& request) { ASSERT_EQUALS(configHost, request.target); - ASSERT_BSONOBJ_EQ(kReplSecondaryOkMetadata, + ASSERT_BSONOBJ_EQ(getReplSecondaryOkMetadata(), rpc::TrackingMetadata::removeTrackingData(request.metadata)); const NamespaceString nss(request.dbname, request.cmdObj.firstElement().String()); |