diff options
author | Mathias Stearn <mathias@10gen.com> | 2017-04-28 16:45:25 -0400 |
---|---|---|
committer | Mathias Stearn <mathias@10gen.com> | 2017-05-12 12:07:30 -0400 |
commit | f9b8a9eb2d196d93a08714c9bbcecbb7fe30a5f3 (patch) | |
tree | 7b0ddca11558c0c81529e85f07e2cdb8ab1091f5 /src/mongo/s | |
parent | f0e1e116322917c83e0c1d11b56afa088fe6ccd7 (diff) | |
download | mongo-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')
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(); }()}; |