summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/reporter_test.cpp
diff options
context:
space:
mode:
authormatt dannenberg <matt.dannenberg@10gen.com>2016-01-05 10:29:01 -0500
committermatt dannenberg <matt.dannenberg@10gen.com>2016-02-04 11:22:18 -0500
commit2c2e6a38f559f25559c2b24eff51511c6fbc4a5b (patch)
tree56ea15031ee21b8cb269d2ce6c7bb5b5235c97ed /src/mongo/db/repl/reporter_test.cpp
parenta818421d4f60b61ef81830af396deb1a3bb998de (diff)
downloadmongo-2c2e6a38f559f25559c2b24eff51511c6fbc4a5b.tar.gz
SERVER-22276 SERVER-22277 implement "j" flag in write concern apply to secondary as well as primary
Diffstat (limited to 'src/mongo/db/repl/reporter_test.cpp')
-rw-r--r--src/mongo/db/repl/reporter_test.cpp14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mongo/db/repl/reporter_test.cpp b/src/mongo/db/repl/reporter_test.cpp
index c5533d7adb2..01904e81c92 100644
--- a/src/mongo/db/repl/reporter_test.cpp
+++ b/src/mongo/db/repl/reporter_test.cpp
@@ -52,7 +52,7 @@ public:
_result = newResult;
}
- bool prepareReplSetUpdatePositionCommand(BSONObjBuilder* cmdBuilder) {
+ bool prepareOldReplSetUpdatePositionCommand(BSONObjBuilder* cmdBuilder) {
if (!_result) {
return _result;
}
@@ -85,7 +85,7 @@ protected:
std::unique_ptr<Reporter> reporter;
std::unique_ptr<MockProgressManager> posUpdater;
- Reporter::PrepareReplSetUpdatePositionCommandFn prepareReplSetUpdatePositionCommandFn;
+ Reporter::PrepareReplSetUpdatePositionCommandFn prepareOldReplSetUpdatePositionCommandFn;
};
ReporterTest::ReporterTest() {}
@@ -93,16 +93,16 @@ ReporterTest::ReporterTest() {}
void ReporterTest::setUp() {
ReplicationExecutorTest::setUp();
posUpdater.reset(new MockProgressManager());
- prepareReplSetUpdatePositionCommandFn = [this]() -> StatusWith<BSONObj> {
+ prepareOldReplSetUpdatePositionCommandFn = [this]() -> StatusWith<BSONObj> {
BSONObjBuilder bob;
- if (posUpdater->prepareReplSetUpdatePositionCommand(&bob)) {
+ if (posUpdater->prepareOldReplSetUpdatePositionCommand(&bob)) {
return bob.obj();
}
return Status(ErrorCodes::OperationFailed,
"unable to prepare replSetUpdatePosition command object");
};
reporter.reset(new Reporter(&getReplExecutor(),
- [this]() { return prepareReplSetUpdatePositionCommandFn(); },
+ [this]() { return prepareOldReplSetUpdatePositionCommandFn(); },
HostAndPort("h1")));
launchExecutorThread();
}
@@ -138,12 +138,12 @@ TEST_F(ReporterTest, InvalidConstruction) {
UserException);
// null ReplicationExecutor
- ASSERT_THROWS(Reporter(nullptr, prepareReplSetUpdatePositionCommandFn, HostAndPort("h1")),
+ ASSERT_THROWS(Reporter(nullptr, prepareOldReplSetUpdatePositionCommandFn, HostAndPort("h1")),
UserException);
// empty HostAndPort
ASSERT_THROWS(
- Reporter(&getReplExecutor(), prepareReplSetUpdatePositionCommandFn, HostAndPort()),
+ Reporter(&getReplExecutor(), prepareOldReplSetUpdatePositionCommandFn, HostAndPort()),
UserException);
}