summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorKaloian Manassiev <kaloian.manassiev@mongodb.com>2017-06-21 20:01:36 -0400
committerKaloian Manassiev <kaloian.manassiev@mongodb.com>2017-06-26 10:43:02 -0400
commit95dae0d467d6798b015a5328073a5e3c9e75cdc8 (patch)
tree6ddaeee1c17a2288abdc882feda7ab5adf7592f4 /src
parentb798e8d10ee53e1448a6ef0542d9d022037d2ea7 (diff)
downloadmongo-95dae0d467d6798b015a5328073a5e3c9e75cdc8.tar.gz
SERVER-29804 Remove 'undefined behaviour' in the sharding catalog unit-tests
Diffstat (limited to 'src')
-rw-r--r--src/mongo/s/balancer_configuration_test.cpp6
-rw-r--r--src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp10
-rw-r--r--src/mongo/s/catalog/sharding_catalog_append_db_stats_test.cpp8
-rw-r--r--src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp10
-rw-r--r--src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp9
-rw-r--r--src/mongo/s/catalog/sharding_catalog_test.cpp58
-rw-r--r--src/mongo/s/cluster_identity_loader_test.cpp7
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());