TrueCloudLab/frostfs-testcases
25
0
Fork 21
Code Issues 2 Pull requests 3 Releases Activity Actions

Added blocks for epoch ticks to test failover_server #44

Merged
d.zayakin merged 1 commit from d.zayakin/frostfs-testcases:fix-failover-test into master 2023-05-19 12:35:57 +00:00
Conversation 0 Commits 1 Files changed 2 +10 -7
2 changed files with 10 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
pytest_tests/testsuites/failovers/test_failover_server.py
View file

@ -186,12 +186,15 @@ class TestFailoverServer(ClusterTestBase):
node_to_stop.storage_node, self.shell, alive_node=storage_nodes[0] node_to_stop.storage_node, self.shell, alive_node=storage_nodes[0]
) )
count_tick_epoch = alive_nodes[0].ir_node.get_netmap_cleaner_threshold() + 1 count_tick_epoch = alive_nodes[0].ir_node.get_netmap_cleaner_threshold() + 2
with allure.step(f"Tick {count_tick_epoch} epoch, in {storage_nodes[0]} node"):
self.tick_epochs(count_tick_epoch, storage_nodes[0])
with allure.step("Wait 2 block time"): with allure.step(f"Tick {count_tick_epoch} epoch, in {storage_nodes[0]} node"):
time.sleep(datetime_utils.parse_time(MORPH_BLOCK_TIME) * 2) for tick in range(count_tick_epoch):
self.tick_epoch(storage_nodes[0])
time.sleep(datetime_utils.parse_time(MORPH_BLOCK_TIME) * 2)
with allure.step(f"Check if the node {node_to_stop.storage_node} has stopped"):
wait_for_host_offline(self.shell, node_to_stop.storage_node)
with allure.step(f"Check {node_to_stop} in not map"): with allure.step(f"Check {node_to_stop} in not map"):
self.wait_node_not_in_map( self.wait_node_not_in_map(
@ -205,7 +208,7 @@ class TestFailoverServer(ClusterTestBase):
assert not corrupted_objects_list assert not corrupted_objects_list
@allure.title("Temporarily disable a node") @allure.title("Temporarily disable a node")
@pytest.mark.parametrize("containers, storage_objects", [(1, 2)], indirect=True) @pytest.mark.parametrize("containers, storage_objects", [(5, 20)], indirect=True)
def test_temporarily_disable_a_node( def test_temporarily_disable_a_node(
self, self,
containers: list[StorageContainer], containers: list[StorageContainer],

2
requirements.txt
View file

@ -4,7 +4,7 @@ base58==2.1.0
boto3==1.16.33 boto3==1.16.33
botocore==1.19.33 botocore==1.19.33
configobj==5.0.6 configobj==5.0.6
frostfs-testlib==2.0.0 frostfs-testlib>=2.0.1
neo-mamba==1.0.0 neo-mamba==1.0.0
pexpect==4.8.0 pexpect==4.8.0
pyyaml==6.0 pyyaml==6.0