diff options
Diffstat (limited to 'searchcore/src/tests/proton/common/pendinglidtracker_test.cpp')
-rw-r--r-- | searchcore/src/tests/proton/common/pendinglidtracker_test.cpp | 105 |
1 files changed, 0 insertions, 105 deletions
diff --git a/searchcore/src/tests/proton/common/pendinglidtracker_test.cpp b/searchcore/src/tests/proton/common/pendinglidtracker_test.cpp deleted file mode 100644 index 575033ad19a..00000000000 --- a/searchcore/src/tests/proton/common/pendinglidtracker_test.cpp +++ /dev/null @@ -1,105 +0,0 @@ -// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. - -#include <vespa/vespalib/testkit/testapp.h> -#include <vespa/searchcore/proton/common/pendinglidtracker.h> - -#include <vespa/log/log.h> -LOG_SETUP("pendinglidtracker_test"); - -using namespace proton; - -constexpr uint32_t LID_1 = 1u; -const std::vector<uint32_t> LIDV_2_1_3({2u, LID_1, 3u}); -const std::vector<uint32_t> LIDV_2_3({2u, 3u}); - -std::ostream & -operator << (std::ostream & os, ILidCommitState::State state) { - switch (state) { - case ILidCommitState::State::NEED_COMMIT: - os << "NEED_COMMIT"; - break; - case ILidCommitState::State::WAITING: - os << "WAITING"; - break; - case ILidCommitState::State::COMPLETED: - os << "COMPLETED"; - break; - } - return os; -} - -void -verifyPhase1ProduceAndNeedCommit(PendingLidTrackerBase & tracker, ILidCommitState::State expected) { - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState()); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LID_1)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_1_3)); - - auto token = tracker.produce(LID_1); - EXPECT_EQUAL(expected, tracker.getState()); - EXPECT_EQUAL(expected, tracker.getState(LID_1)); - EXPECT_EQUAL(expected, tracker.getState(LIDV_2_1_3)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_3)); - { - auto token2 = tracker.produce(LID_1); - EXPECT_EQUAL(expected, tracker.getState()); - EXPECT_EQUAL(expected, tracker.getState(LID_1)); - EXPECT_EQUAL(expected, tracker.getState(LIDV_2_1_3)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_3)); - } - EXPECT_EQUAL(expected, tracker.getState()); - EXPECT_EQUAL(expected, tracker.getState(LID_1)); - EXPECT_EQUAL(expected, tracker.getState(LIDV_2_1_3)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_3)); -} - -TEST("test pendinglidtracker for needcommit") { - PendingLidTracker tracker; - verifyPhase1ProduceAndNeedCommit(tracker, ILidCommitState::State::WAITING); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState()); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LID_1)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_1_3)); - { - ILidCommitState::State incomplete = ILidCommitState::State::WAITING; - auto token = tracker.produce(LID_1); - EXPECT_EQUAL(incomplete, tracker.getState()); - EXPECT_EQUAL(incomplete, tracker.getState(LID_1)); - EXPECT_EQUAL(incomplete, tracker.getState(LIDV_2_1_3)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_3)); - { - auto snapshot = tracker.produceSnapshot(); - EXPECT_EQUAL(incomplete, tracker.getState()); - EXPECT_EQUAL(incomplete, tracker.getState(LID_1)); - EXPECT_EQUAL(incomplete, tracker.getState(LIDV_2_1_3)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_3)); - } - EXPECT_EQUAL(incomplete, tracker.getState()); - EXPECT_EQUAL(incomplete, tracker.getState(LID_1)); - EXPECT_EQUAL(incomplete, tracker.getState(LIDV_2_1_3)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_3)); - } - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState()); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LID_1)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_1_3)); -} - -TEST("test two phase pendinglidtracker for needcommit") { - TwoPhasePendingLidTracker tracker; - ILidCommitState::State incomplete = ILidCommitState::State::NEED_COMMIT; - verifyPhase1ProduceAndNeedCommit(tracker, incomplete); - EXPECT_EQUAL(incomplete, tracker.getState()); - EXPECT_EQUAL(incomplete, tracker.getState(LID_1)); - EXPECT_EQUAL(incomplete, tracker.getState(LIDV_2_1_3)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_3)); - { - ILidCommitState::State waiting = ILidCommitState::State::WAITING; - auto snapshot = tracker.produceSnapshot(); - EXPECT_EQUAL(waiting, tracker.getState()); - EXPECT_EQUAL(waiting, tracker.getState(LID_1)); - EXPECT_EQUAL(waiting, tracker.getState(LIDV_2_1_3)); - } - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState()); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LID_1)); - EXPECT_EQUAL(ILidCommitState::State::COMPLETED, tracker.getState(LIDV_2_1_3)); -} - -TEST_MAIN() { TEST_RUN_ALL(); } |