smeb_y/0g-storage-node
1
0
Fork 0
mirror of https://github.com/0glabs/0g-storage-node.git synced 2025-04-04 15:35:18 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

add snapshot test

Browse Source
This commit is contained in:
Peter Zhang 2024-11-19 11:10:27 +08:00
parent d646c31b1d
commit 9b6097f75d
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/snapshot_test.py
View File

@ -16,12 +16,11 @@ class SnapshotTask(TestFramework):
"auto_sync_enabled": True,
"max_sequential_workers": 3,
"max_random_workers": 3,
"neighbors_only": True,
}
}
def run_test(self):
# Stop the last node to verify historical file sync
# Submit and upload files on node 0
data_root_1 = self.__upload_file__(0, 256 * 1024)
wait_until(lambda: self.nodes[1].zgs_get_file_info(data_root_1) is not None)
@ -34,10 +33,9 @@ class SnapshotTask(TestFramework):
self.start_storage_node(1)
self.nodes[1].wait_for_rpc_connection()
# Submit and upload files on node 0
data_root_1 = self.__upload_file__(1, 256 * 1024)
wait_until(lambda: self.nodes[0].zgs_get_file_info(data_root_1) is not None)
wait_until(lambda: self.nodes[0].zgs_get_file_info(data_root_1)["finalized"])
wait_until(lambda: self.nodes[1].zgs_get_file_info(data_root_1) is not None)
wait_until(lambda: self.nodes[1].zgs_get_file_info(data_root_1)["finalized"])
if __name__ == "__main__":
SnapshotTask().main()