diff options
Diffstat (limited to 'src/mongo/db/repl/freshness_scanner_test.cpp')
| -rw-r--r-- | src/mongo/db/repl/freshness_scanner_test.cpp | 207 |
1 files changed, 0 insertions, 207 deletions
diff --git a/src/mongo/db/repl/freshness_scanner_test.cpp b/src/mongo/db/repl/freshness_scanner_test.cpp deleted file mode 100644 index cf9c7dbc709..00000000000 --- a/src/mongo/db/repl/freshness_scanner_test.cpp +++ /dev/null @@ -1,207 +0,0 @@ -/** - * Copyright (C) 2016 MongoDB Inc. - * - * This program is free software: you can redistribute it and/or modify - * it under the terms of the GNU Affero General Public License, version 3, - * as published by the Free Software Foundation. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU Affero General Public License for more details. - * - * You should have received a copy of the GNU Affero General Public License - * along with this program. If not, see <http://www.gnu.org/licenses/>. - * - * As a special exception, the copyright holders give permission to link the - * code of portions of this program with the OpenSSL library under certain - * conditions as described in each individual source file and distribute - * linked combinations including the program with the OpenSSL library. You - * must comply with the GNU Affero General Public License in all respects for - * all of the code used other than as permitted herein. If you modify file(s) - * with this exception, you may extend this exception to your version of the - * file(s), but you are not obligated to do so. If you do not wish to do so, - * delete this exception statement from your version. If you delete this - * exception statement from all source files in the program, then also delete - * it in the license file. - */ - -#include "mongo/platform/basic.h" - -#include "mongo/base/status.h" -#include "mongo/db/jsobj.h" -#include "mongo/db/repl/freshness_scanner.h" -#include "mongo/db/repl/replication_coordinator_impl.h" -#include "mongo/executor/network_interface_mock.h" -#include "mongo/executor/thread_pool_task_executor_test_fixture.h" -#include "mongo/stdx/functional.h" -#include "mongo/stdx/memory.h" -#include "mongo/stdx/thread.h" -#include "mongo/unittest/unittest.h" - -namespace mongo { -namespace repl { -namespace { - -using executor::NetworkInterfaceMock; -using executor::RemoteCommandRequest; -using executor::RemoteCommandResponse; -using unittest::assertGet; - -class FreshnessScannerTest : public executor::ThreadPoolExecutorTest { -public: - virtual void setUp() { - executor::ThreadPoolExecutorTest::setUp(); - launchExecutorThread(); - ASSERT_OK(_config.initialize(BSON("_id" - << "rs0" - << "version" - << 1 - << "members" - << BSON_ARRAY(BSON("_id" << 0 << "host" - << "host0") - << BSON("_id" << 1 << "host" - << "host1") - << BSON("_id" << 2 << "host" - << "host2") - << BSON("_id" << 3 << "host" - << "host3" - << "votes" - << 0 - << "priority" - << 0) - << BSON("_id" << 4 << "host" - << "host4" - << "votes" - << 0 - << "priority" - << 0))))); - ASSERT_OK(_config.validate()); - } - -protected: - RemoteCommandRequest requestFrom(std::string hostname) { - return RemoteCommandRequest(HostAndPort(hostname), - "", // fields do not matter in FreshnessScanner - BSONObj(), - nullptr, - Milliseconds(0)); - } - - RemoteCommandResponse makeRemoteCommandResponse(BSONObj response) { - return RemoteCommandResponse( - NetworkInterfaceMock::Response(response, BSONObj(), Milliseconds(10))); - } - - RemoteCommandResponse badRemoteCommandResponse() { - return RemoteCommandResponse(ErrorCodes::NodeNotFound, "not on my watch"); - } - - RemoteCommandResponse goodRemoteCommandResponse(Timestamp timestamp, long long term) { - // OpTime part of replSetGetStatus. - BSONObj response = - BSON("optimes" << BSON("appliedOpTime" << OpTime(timestamp, term).toBSON())); - return makeRemoteCommandResponse(response); - } - - ReplSetConfig _config; -}; - -TEST_F(FreshnessScannerTest, ImmediateGoodResponse) { - FreshnessScanner::Algorithm algo(_config, 0, Milliseconds(2000)); - - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - algo.processResponse(requestFrom("host1"), goodRemoteCommandResponse(Timestamp(1, 100), 1)); - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - algo.processResponse(requestFrom("host2"), goodRemoteCommandResponse(Timestamp(1, 200), 1)); - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - algo.processResponse(requestFrom("host3"), goodRemoteCommandResponse(Timestamp(1, 400), 1)); - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - algo.processResponse(requestFrom("host4"), goodRemoteCommandResponse(Timestamp(1, 300), 1)); - ASSERT_TRUE(algo.hasReceivedSufficientResponses()); - ASSERT_EQUALS((size_t)4, algo.getResult().size()); - ASSERT_EQUALS(3, algo.getResult().front().index); - ASSERT_EQUALS(OpTime(Timestamp(1, 400), 1), algo.getResult().front().opTime); - ASSERT_EQUALS(1, algo.getResult().back().index); - ASSERT_EQUALS(OpTime(Timestamp(1, 100), 1), algo.getResult().back().opTime); -} - -TEST_F(FreshnessScannerTest, ImmediateBadResponse) { - FreshnessScanner::Algorithm algo(_config, 0, Milliseconds(2000)); - - // Cannot access host 1 and host 2. - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - algo.processResponse(requestFrom("host1"), badRemoteCommandResponse()); - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - algo.processResponse(requestFrom("host2"), badRemoteCommandResponse()); - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - - // host 3 is in an old version, which doesn't include OpTimes in the response. - algo.processResponse(requestFrom("host3"), makeRemoteCommandResponse(BSONObj())); - ASSERT_FALSE(algo.hasReceivedSufficientResponses()); - - // Responses from host 4 in PV0 are considered as bad responses. - auto response4 = BSON("optimes" << BSON("appliedOpTime" << Timestamp(1, 300))); - algo.processResponse(requestFrom("host4"), makeRemoteCommandResponse(response4)); - ASSERT_TRUE(algo.hasReceivedSufficientResponses()); - ASSERT_EQUALS((size_t)0, algo.getResult().size()); -} - -TEST_F(FreshnessScannerTest, AllResponsesTimeout) { - Milliseconds timeout(2000); - FreshnessScanner scanner; - scanner.start(&getExecutor(), _config, 0, timeout); - - auto net = getNet(); - net->enterNetwork(); - ASSERT(net->hasReadyRequests()); - // Black hole all requests. - while (net->hasReadyRequests()) { - net->blackHole(net->getNextReadyRequest()); - } - auto later = net->now() + Milliseconds(2010); - ASSERT_EQ(later, net->runUntil(later)); - net->exitNetwork(); - ASSERT_EQUALS((size_t)0, scanner.getResult().size()); -} - - -TEST_F(FreshnessScannerTest, BadResponsesAndTimeout) { - Milliseconds timeout(2000); - FreshnessScanner scanner; - scanner.start(&getExecutor(), _config, 0, timeout); - - auto net = getNet(); - net->enterNetwork(); - - Date_t later = net->now() + Milliseconds(10); - // host 1 returns good response. - ASSERT(net->hasReadyRequests()); - auto noi = net->getNextReadyRequest(); - HostAndPort successfulHost = noi->getRequest().target; - net->scheduleResponse(noi, later, goodRemoteCommandResponse(Timestamp(1, 100), 1)); - - // host 2 has a bad connection. - ASSERT(net->hasReadyRequests()); - net->scheduleResponse(net->getNextReadyRequest(), later, badRemoteCommandResponse()); - - // host 3 and 4 time out. - ASSERT(net->hasReadyRequests()); - net->blackHole(net->getNextReadyRequest()); - ASSERT(net->hasReadyRequests()); - net->blackHole(net->getNextReadyRequest()); - - // Advance the clock. - ASSERT(!net->hasReadyRequests()); - getNet()->runUntil(getNet()->now() + Milliseconds(2010)); - getNet()->exitNetwork(); - - ASSERT_EQUALS((size_t)1, scanner.getResult().size()); - auto freshnessInfo = scanner.getResult().front(); - ASSERT_EQUALS(_config.findMemberIndexByHostAndPort(successfulHost), freshnessInfo.index); - ASSERT_EQUALS(OpTime(Timestamp(1, 100), 1), freshnessInfo.opTime); -} - -} // namespace -} // namespace repl -} // namespace mongo |