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

We get all the objects, then we count the errors #160

Merged
d.zayakin merged 1 commit from d.zayakin/frostfs-testcases:change-corrupted-func-v0.37 into support/v0.37 2023-11-28 08:14:36 +00:00
Conversation 0 Commits 1 Files changed 1 +16 -11
1 changed files with 16 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -99,20 +99,25 @@ class TestFailoverServer(ClusterTestBase):
self, nodes: list[StorageNode], storage_objects: list[StorageObjectInfo] self, nodes: list[StorageNode], storage_objects: list[StorageObjectInfo]
) -> list[StorageObjectInfo]: ) -> list[StorageObjectInfo]:
corrupted_objects = [] corrupted_objects = []
errors_get = []
for node in nodes: for node in nodes:
for storage_object in storage_objects: for storage_object in storage_objects:
got_file_path = get_object( try:
storage_object.wallet_file_path, got_file_path = get_object(
storage_object.cid, storage_object.wallet_file_path,
storage_object.oid, storage_object.cid,
endpoint=node.get_rpc_endpoint(), storage_object.oid,
shell=self.shell, endpoint=node.get_rpc_endpoint(),
timeout="60s", shell=self.shell,
) timeout="60s",
if storage_object.file_hash != get_file_hash(got_file_path): )
corrupted_objects.append(storage_object) if storage_object.file_hash != get_file_hash(got_file_path):
os.remove(got_file_path) corrupted_objects.append(storage_object)
os.remove(got_file_path)
except RuntimeError:
errors_get.append(storage_object.oid)
assert len(errors_get) == 0, f"Get failed - {errors_get}"
return corrupted_objects return corrupted_objects
def check_objects_replication( def check_objects_replication(