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

[#370] Fix internal interface tests. Add APE rule for container
All checks were successful
DCO check / DCO (pull_request) Successful in 31s
Details

Browse source 
Signed-off-by: Dmitriy Zayakin <d.zayakin@yadro.com>
This commit is contained in:
Dmitriy Zayakin 2025-02-18 09:23:57 +03:00
parent f8785fa299
commit eedb915283
1 changed files with 11 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
pytest_tests/testsuites/failovers/test_frostfs_failover_network.py
View file

@ -18,7 +18,7 @@ from frostfs_testlib.testing.parallel import parallel
from frostfs_testlib.utils.failover_utils import wait_object_replication from frostfs_testlib.utils.failover_utils import wait_object_replication
from frostfs_testlib.utils.file_utils import generate_file, get_file_hash from frostfs_testlib.utils.file_utils import generate_file, get_file_hash
from ...helpers.container_request import PUBLIC_WITH_POLICY, REP_2_2_2_PUBLIC, requires_container from ...helpers.container_request import APE_EVERYONE_ALLOW_ALL, PUBLIC_WITH_POLICY, REP_2_2_2_PUBLIC, ContainerRequest, requires_container
logger = logging.getLogger("NeoLogger") logger = logging.getLogger("NeoLogger")
STORAGE_NODE_COMMUNICATION_PORT = "8080" STORAGE_NODE_COMMUNICATION_PORT = "8080"
@ -354,6 +354,11 @@ class TestFailoverNetwork(ClusterTestBase):
@pytest.mark.interfaces @pytest.mark.interfaces
@pytest.mark.failover_baremetal @pytest.mark.failover_baremetal
@pytest.mark.parametrize(
"container_request",
[ContainerRequest(f"REP %NODE_COUNT% IN X CBF 1 SELECT %NODE_COUNT% FROM * AS X", APE_EVERYONE_ALLOW_ALL)],
indirect=True,
)
@pytest.mark.parametrize("interface", [Interfaces.INTERNAL_0, Interfaces.INTERNAL_1]) @pytest.mark.parametrize("interface", [Interfaces.INTERNAL_0, Interfaces.INTERNAL_1])
@allure.title("Down internal interfaces to all nodes(interface={interface})") @allure.title("Down internal interfaces to all nodes(interface={interface})")
def test_down_internal_interface( def test_down_internal_interface(
@ -364,6 +369,7 @@ class TestFailoverNetwork(ClusterTestBase):
simple_object_size: ObjectSize, simple_object_size: ObjectSize,
restore_down_interfaces: None, restore_down_interfaces: None,
interface: Interfaces, interface: Interfaces,
container: str,
): ):
cluster_nodes = self.cluster.cluster_nodes cluster_nodes = self.cluster.cluster_nodes
latest_block = {} latest_block = {}
@ -380,29 +386,21 @@ class TestFailoverNetwork(ClusterTestBase):
with reporter.step("Tick 1 epoch and wait 2 block for sync all nodes"): with reporter.step("Tick 1 epoch and wait 2 block for sync all nodes"):
self.tick_epochs(1, alive_node=cluster_nodes[0].storage_node, wait_block=2) self.tick_epochs(1, alive_node=cluster_nodes[0].storage_node, wait_block=2)
with reporter.step("Create container"):
cid = create_container(
wallet=default_wallet,
shell=self.shell,
endpoint=self.cluster.default_rpc_endpoint,
rule="REP 4 CBF 1",
)
with reporter.step(f"Put object, after down {interface}"): with reporter.step(f"Put object, after down {interface}"):
file_path = generate_file(simple_object_size.value) file_path = generate_file(simple_object_size.value)
oid = put_object( oid = put_object(
wallet=default_wallet, wallet=default_wallet,
path=file_path, path=file_path,
cid=cid, cid=container,
shell=self.shell, shell=self.shell,
endpoint=self.cluster.default_rpc_endpoint, endpoint=self.cluster.default_rpc_endpoint,
) )
with reporter.step("Get object"): with reporter.step("Get object"):
file_get_path = get_object( get_object(
wallet=default_wallet, wallet=default_wallet,
cid=cid, cid=container,
oid=oid, oid=oid,
shell=self.shell, shell=self.shell,
endpoint=self.cluster.default_rpc_endpoint, endpoint=self.cluster.default_rpc_endpoint,
@ -415,7 +413,7 @@ class TestFailoverNetwork(ClusterTestBase):
now_block[cluster_node] = neo_go_query_height( now_block[cluster_node] = neo_go_query_height(
shell=cluster_node.host.get_shell(), endpoint=cluster_node.morph_chain.get_http_endpoint() shell=cluster_node.host.get_shell(), endpoint=cluster_node.morph_chain.get_http_endpoint()
) )
with reporter.step(f"Compare block"): with reporter.step("Compare block"):
for cluster_node, items in now_block.items(): for cluster_node, items in now_block.items():
with reporter.step( with reporter.step(
f"Node - {cluster_node.host_ip}, old block - {latest_block[cluster_node]['Latest block']}, " f"Node - {cluster_node.host_ip}, old block - {latest_block[cluster_node]['Latest block']}, "