diff options
author | matt dannenberg <matt.dannenberg@10gen.com> | 2016-01-05 10:29:01 -0500 |
---|---|---|
committer | matt dannenberg <matt.dannenberg@10gen.com> | 2016-02-04 11:22:18 -0500 |
commit | 2c2e6a38f559f25559c2b24eff51511c6fbc4a5b (patch) | |
tree | 56ea15031ee21b8cb269d2ce6c7bb5b5235c97ed /src/mongo/db/repl/reporter_test.cpp | |
parent | a818421d4f60b61ef81830af396deb1a3bb998de (diff) | |
download | mongo-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.cpp | 14 |
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); } |