summaryrefslogtreecommitdiff
path: root/src/mongo/s
diff options
context:
space:
mode:
authorMathias Stearn <mathias@10gen.com>2017-04-28 16:45:25 -0400
committerMathias Stearn <mathias@10gen.com>2017-05-12 12:07:30 -0400
commitf9b8a9eb2d196d93a08714c9bbcecbb7fe30a5f3 (patch)
tree7b0ddca11558c0c81529e85f07e2cdb8ab1091f5 /src/mongo/s
parentf0e1e116322917c83e0c1d11b56afa088fe6ccd7 (diff)
downloadmongo-f9b8a9eb2d196d93a08714c9bbcecbb7fe30a5f3.tar.gz
SERVER-28814 Add and use ReadPreferenceSetting::secondaryPreferredMetadata()
This is prep for eliminating ServerSelectionMetadata in favor of just ReadPreferenceSetting.
Diffstat (limited to 'src/mongo/s')
-rw-r--r--src/mongo/s/balancer_configuration_test.cpp2
-rw-r--r--src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp2
-rw-r--r--src/mongo/s/catalog/sharding_catalog_append_db_stats_test.cpp2
-rw-r--r--src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp2
-rw-r--r--src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp4
-rw-r--r--src/mongo/s/catalog/sharding_catalog_test.cpp16
-rw-r--r--src/mongo/s/client/shard_remote.cpp7
-rw-r--r--src/mongo/s/cluster_identity_loader_test.cpp2
8 files changed, 17 insertions, 20 deletions
diff --git a/src/mongo/s/balancer_configuration_test.cpp b/src/mongo/s/balancer_configuration_test.cpp
index 72a3b8da06d..9afd5bfaa1d 100644
--- a/src/mongo/s/balancer_configuration_test.cpp
+++ b/src/mongo/s/balancer_configuration_test.cpp
@@ -54,7 +54,7 @@ using unittest::assertGet;
const BSONObj kReplSecondaryOkMetadata{[] {
BSONObjBuilder o;
- o.appendElements(rpc::ServerSelectionMetadata(true, boost::none).toBSON());
+ o.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
o.append(rpc::kReplSetMetadataFieldName, 1);
return o.obj();
}()};
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 a3fee100fd6..d983a489461 100644
--- a/src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp
+++ b/src/mongo/s/catalog/sharding_catalog_add_shard_test.cpp
@@ -70,7 +70,7 @@ using unittest::assertGet;
const BSONObj kReplSecondaryOkMetadata{[] {
BSONObjBuilder o;
- o.appendElements(rpc::ServerSelectionMetadata(true, boost::none).toBSON());
+ o.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
o.append(rpc::kReplSetMetadataFieldName, 1);
return o.obj();
}()};
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 5e2259b56fb..3f6a2782c98 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
@@ -53,7 +53,7 @@ using ShardingCatalogClientAppendDbStatsTest = ShardingCatalogTestFixture;
const BSONObj kReplSecondaryOkMetadata{[] {
BSONObjBuilder o;
- o.appendElements(rpc::ServerSelectionMetadata(true, boost::none).toBSON());
+ o.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
o.append(rpc::kReplSetMetadataFieldName, 1);
return o.obj();
}()};
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 b9b8285ce33..fa3d295dce4 100644
--- a/src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp
+++ b/src/mongo/s/catalog/sharding_catalog_remove_shard_test.cpp
@@ -67,7 +67,7 @@ static const Seconds kFutureTimeout{5};
const BSONObj kReplSecondaryOkMetadata{[] {
BSONObjBuilder o;
- o.appendElements(rpc::ServerSelectionMetadata(true, boost::none).toBSON());
+ o.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
o.append(rpc::kReplSetMetadataFieldName, 1);
return o.obj();
}()};
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 f60ead6821e..86b6bfe755c 100644
--- a/src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp
+++ b/src/mongo/s/catalog/sharding_catalog_shard_collection_test.cpp
@@ -75,7 +75,7 @@ using unittest::assertGet;
const BSONObj kReplSecondaryOkMetadata{[] {
BSONObjBuilder o;
- o.appendElements(rpc::ServerSelectionMetadata(true, boost::none).toBSON());
+ o.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
o.append(rpc::kReplSetMetadataFieldName, 1);
return o.obj();
}()};
@@ -739,7 +739,7 @@ TEST_F(ShardCollectionTest, withInitialData) {
ASSERT_EQUALS(0, request.cmdObj["maxSplitPoints"].numberLong());
ASSERT_EQUALS(0, request.cmdObj["maxChunkObjects"].numberLong());
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return BSON("ok" << 1 << "splitKeys"
diff --git a/src/mongo/s/catalog/sharding_catalog_test.cpp b/src/mongo/s/catalog/sharding_catalog_test.cpp
index 7b21c2429f4..fba69fe6445 100644
--- a/src/mongo/s/catalog/sharding_catalog_test.cpp
+++ b/src/mongo/s/catalog/sharding_catalog_test.cpp
@@ -79,7 +79,7 @@ const int kMaxCommandRetry = 3;
const BSONObj kReplSecondaryOkMetadata{[] {
BSONObjBuilder o;
- o.appendElements(rpc::ServerSelectionMetadata(true, boost::none).toBSON());
+ o.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
o.append(rpc::kReplSetMetadataFieldName, 1);
return o.obj();
}()};
@@ -1492,7 +1492,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseSuccess) {
ASSERT_EQUALS("listDatabases", cmdName);
ASSERT_FALSE(request.cmdObj.hasField(repl::ReadConcernArgs::kReadConcernFieldName));
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return BSON("ok" << 1 << "totalSize" << 10);
@@ -1506,7 +1506,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseSuccess) {
ASSERT_EQUALS("listDatabases", cmdName);
ASSERT_FALSE(request.cmdObj.hasField(repl::ReadConcernArgs::kReadConcernFieldName));
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return BSON("ok" << 1 << "totalSize" << 1);
@@ -1519,7 +1519,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseSuccess) {
string cmdName = request.cmdObj.firstElement().fieldName();
ASSERT_EQUALS("listDatabases", cmdName);
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return BSON("ok" << 1 << "totalSize" << 100);
@@ -1774,7 +1774,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseDuplicateKeyOnInsert) {
ASSERT_EQUALS("listDatabases", cmdName);
ASSERT_FALSE(request.cmdObj.hasField(repl::ReadConcernArgs::kReadConcernFieldName));
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return BSON("ok" << 1 << "totalSize" << 10);
@@ -1788,7 +1788,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseDuplicateKeyOnInsert) {
ASSERT_EQUALS("listDatabases", cmdName);
ASSERT_FALSE(request.cmdObj.hasField(repl::ReadConcernArgs::kReadConcernFieldName));
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return BSON("ok" << 1 << "totalSize" << 1);
@@ -1802,7 +1802,7 @@ TEST_F(ShardingCatalogClientTest, createDatabaseDuplicateKeyOnInsert) {
ASSERT_EQUALS("listDatabases", cmdName);
ASSERT_FALSE(request.cmdObj.hasField(repl::ReadConcernArgs::kReadConcernFieldName));
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return BSON("ok" << 1 << "totalSize" << 100);
@@ -1900,7 +1900,7 @@ TEST_F(ShardingCatalogClientTest, EnableShardingNoDBExists) {
ASSERT_EQ("admin", request.dbname);
ASSERT_BSONOBJ_EQ(BSON("listDatabases" << 1), request.cmdObj);
- ASSERT_BSONOBJ_EQ(rpc::ServerSelectionMetadata(true, boost::none).toBSON(),
+ ASSERT_BSONOBJ_EQ(ReadPreferenceSetting::secondaryPreferredMetadata(),
rpc::TrackingMetadata::removeTrackingData(request.metadata));
return fromjson(R"({
diff --git a/src/mongo/s/client/shard_remote.cpp b/src/mongo/s/client/shard_remote.cpp
index 4224df96267..3d0f2570d4e 100644
--- a/src/mongo/s/client/shard_remote.cpp
+++ b/src/mongo/s/client/shard_remote.cpp
@@ -69,9 +69,6 @@ namespace {
// response.
const BSONObj kReplMetadata(BSON(rpc::kReplSetMetadataFieldName << 1));
-// Allow the command to be executed on a secondary (see ServerSelectionMetadata).
-const BSONObj kSecondaryOkMetadata{rpc::ServerSelectionMetadata(true, boost::none).toBSON()};
-
/**
* Returns a new BSONObj describing the same command and arguments as 'cmdObj', but with maxTimeMS
* replaced by maxTimeMSOverride (or removed if maxTimeMSOverride is Milliseconds::max()).
@@ -164,12 +161,12 @@ BSONObj ShardRemote::_appendMetadataForCommand(OperationContext* opCtx,
if (readPref.pref == ReadPreference::PrimaryOnly) {
builder.appendElements(kReplMetadata);
} else {
- builder.appendElements(kSecondaryOkMetadata);
+ builder.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
builder.appendElements(kReplMetadata);
}
} else {
if (readPref.pref != ReadPreference::PrimaryOnly) {
- builder.appendElements(kSecondaryOkMetadata);
+ builder.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
}
}
return builder.obj();
diff --git a/src/mongo/s/cluster_identity_loader_test.cpp b/src/mongo/s/cluster_identity_loader_test.cpp
index fd9c0f474e2..8c1af517e89 100644
--- a/src/mongo/s/cluster_identity_loader_test.cpp
+++ b/src/mongo/s/cluster_identity_loader_test.cpp
@@ -61,7 +61,7 @@ using unittest::assertGet;
const BSONObj kReplSecondaryOkMetadata{[] {
BSONObjBuilder o;
- o.appendElements(rpc::ServerSelectionMetadata(true, boost::none).toBSON());
+ o.appendElements(ReadPreferenceSetting::secondaryPreferredMetadata());
o.append(rpc::kReplSetMetadataFieldName, 1);
return o.obj();
}()};