summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_fetcher_test.cpp
diff options
context:
space:
mode:
authorScott Hernandez <scotthernandez@tart.local>2016-05-16 13:13:36 -0400
committerScott Hernandez <scotthernandez@tart.local>2016-06-17 11:53:01 -0400
commit39b48364619c56154148111414101db5bd1e1a8b (patch)
tree9325218f9350d5635e1bd0e8d333bdb4400c2faa /src/mongo/db/repl/oplog_fetcher_test.cpp
parenta3fa7ddda4e6d301a92c9ba993ed56838fa28fe5 (diff)
downloadmongo-39b48364619c56154148111414101db5bd1e1a8b.tar.gz
SERVER-23750: enable slaveOk/Secondary read preference for fetch/oplogFetcher
Diffstat (limited to 'src/mongo/db/repl/oplog_fetcher_test.cpp')
-rw-r--r--src/mongo/db/repl/oplog_fetcher_test.cpp7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/mongo/db/repl/oplog_fetcher_test.cpp b/src/mongo/db/repl/oplog_fetcher_test.cpp
index 6ec6ab36bc4..9f44548aafa 100644
--- a/src/mongo/db/repl/oplog_fetcher_test.cpp
+++ b/src/mongo/db/repl/oplog_fetcher_test.cpp
@@ -36,6 +36,7 @@
#include "mongo/executor/thread_pool_task_executor_test_fixture.h"
#include "mongo/rpc/metadata.h"
#include "mongo/rpc/metadata/repl_set_metadata.h"
+#include "mongo/rpc/metadata/server_selection_metadata.h"
#include "mongo/stdx/memory.h"
#include "mongo/unittest/unittest.h"
@@ -355,7 +356,7 @@ TEST_F(OplogFetcherTest, MetadataObjectContainsReplSetMetadataFieldUnderProtocol
enqueueDocumentsFn,
[](Status, OpTimeWithHash) {})
.getMetadataObject_forTest();
- ASSERT_EQUALS(1, metadataObj.nFields());
+ ASSERT_EQUALS(2, metadataObj.nFields());
ASSERT_EQUALS(1, metadataObj[rpc::kReplSetMetadataFieldName].numberInt());
}
@@ -369,7 +370,9 @@ TEST_F(OplogFetcherTest, MetadataObjectIsEmptyUnderProtocolVersion0) {
enqueueDocumentsFn,
[](Status, OpTimeWithHash) {})
.getMetadataObject_forTest();
- ASSERT_EQUALS(BSONObj(), metadataObj);
+ ASSERT_EQUALS(BSON(rpc::ServerSelectionMetadata::fieldName()
+ << BSON(rpc::ServerSelectionMetadata::kSecondaryOkFieldName << 1)),
+ metadataObj);
}
TEST_F(OplogFetcherTest, RemoteCommandTimeoutShouldEqualElectionTimeout) {