Skip to content

INDY-2223: add a new view_change test #10

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Toktar wants to merge 2 commits into
base: public/indy-2223-first-step
Choose a base branch
from
Open

INDY-2223: add a new view_change test #10

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
f7ea922
INDY-2223: add a new view_change test
Toktar Sep 23, 2019
89ffde4
INDY-2223: update a test
Toktar Sep 24, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 29 additions & 2 deletions plenum/test/view_change_service/test_view_change_triggered.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,17 +1,21 @@
from functools import partial

import pytest
from plenum.test.delayers import cDelay

from plenum.common.messages.internal_messages import NeedViewChange
from plenum.common.util import getMaxFailures
from plenum.server.consensus.ordering_service_msg_validator import OrderingServiceMsgValidator
from plenum.server.consensus.primary_selector import RoundRobinPrimariesSelector
from plenum.test.helper import checkViewNoForNodes, sdk_send_random_and_check
from plenum.test.helper import checkViewNoForNodes, sdk_send_random_and_check, assertExp
from plenum.test.node_request.helper import sdk_ensure_pool_functional
from plenum.test.pool_transactions.helper import disconnect_node_and_ensure_disconnected
from plenum.test.test_node import ensureElectionsDone
from plenum.test.stasher import delay_rules_without_processing
from plenum.test.test_node import ensureElectionsDone, getNonPrimaryReplicas

from stp_core.common.log import Logger
from stp_core.loop.eventually import eventually

Logger().enableStdLogging()
Logger().setLogLevel(0)

Expand Down Expand Up @@ -80,3 +84,26 @@ def test_view_change_with_next_primary_stopped(looper, txnPoolNodeSet, sdk_pool_
sdk_ensure_pool_functional(looper, txnPoolNodeSet, sdk_wallet_client, sdk_pool_handle)
current_view_no = checkViewNoForNodes(txnPoolNodeSet)
assert current_view_no == old_view_no + 2


def test_view_change_with_next_primary_stopped_and_one_node_lost_commit(looper,
txnPoolNodeSet,
sdk_pool_handle,
sdk_wallet_client):
old_view_no = checkViewNoForNodes(txnPoolNodeSet)
next_primary = get_next_primary_name(txnPoolNodeSet, old_view_no + 1)
slow_node = [r.node for r in getNonPrimaryReplicas(txnPoolNodeSet) if r.node.name != next_primary][0]
last_pp_seq_no = slow_node.master_last_ordered_3PC[1]

with delay_rules_without_processing(slow_node.nodeIbStasher, cDelay()):
sdk_send_random_and_check(looper, txnPoolNodeSet, sdk_pool_handle, sdk_wallet_client, 1)
looper.run(eventually(lambda preprepared: assertExp(any(last_pp_seq_no + 1 == bid.pp_seq_no
for bid in preprepared)),
slow_node.master_replica._consensus_data.preprepared))

disconnect_node_and_ensure_disconnected(looper, txnPoolNodeSet, next_primary)
trigger_view_change(txnPoolNodeSet, old_view_no + 1)
ensureElectionsDone(looper, txnPoolNodeSet)
sdk_ensure_pool_functional(looper, txnPoolNodeSet, sdk_wallet_client, sdk_pool_handle)
current_view_no = checkViewNoForNodes(txnPoolNodeSet)
assert current_view_no == old_view_no + 2