# create a bunch of files in a directory to snap
self.mount_a.run_shell(["mkdir", "d0"])
for i in range(10):
- self.mount_a.write_n_mb(os.path.join('d0', f'file.{i}'), 1024)
+ self.mount_a.write_n_mb(os.path.join('d0', f'file.{i}'), 100)
time.sleep(60)
self.enable_mirroring(self.primary_fs_name, self.primary_fs_id)
# take a snapshot
self.mount_a.run_shell(["mkdir", "d0/.snap/snap0"])
- time.sleep(500)
+ time.sleep(120)
self.check_peer_status(self.primary_fs_name, self.primary_fs_id,
"client.mirror_remote@ceph", '/d0', 'snap0', 1)
self.verify_snapshot('d0', 'snap0')
second = res[TestMirroring.PERF_COUNTER_KEY_NAME_CEPHFS_MIRROR_PEER][0]
self.assertGreater(second["counters"]["snaps_synced"], first["counters"]["snaps_synced"])
self.assertGreater(second["counters"]["last_synced_start"], first["counters"]["last_synced_start"])
- self.assertGreater(second["counters"]["last_synced_end"], second["counters"]["last_synced_start"])
+ self.assertGreaterEqual(second["counters"]["last_synced_end"], second["counters"]["last_synced_start"])
self.assertGreater(second["counters"]["last_synced_duration"], 0)
- self.assertEquals(second["counters"]["last_synced_bytes"], 10737418240) # last_synced_bytes = 10 files of 1024MB size each
+ self.assertEquals(second["counters"]["last_synced_bytes"], 1048576000) # last_synced_bytes = 10 files of 100MB size each
# some more IO
- for i in range(10):
- self.mount_a.write_n_mb(os.path.join('d0', f'more_file.{i}'), 1024)
+ for i in range(15):
+ self.mount_a.write_n_mb(os.path.join('d0', f'more_file.{i}'), 100)
time.sleep(60)
# take another snapshot
self.mount_a.run_shell(["mkdir", "d0/.snap/snap1"])
- time.sleep(500)
+ time.sleep(240)
self.check_peer_status(self.primary_fs_name, self.primary_fs_id,
"client.mirror_remote@ceph", '/d0', 'snap1', 2)
self.verify_snapshot('d0', 'snap1')
third = res[TestMirroring.PERF_COUNTER_KEY_NAME_CEPHFS_MIRROR_PEER][0]
self.assertGreater(third["counters"]["snaps_synced"], second["counters"]["snaps_synced"])
self.assertGreater(third["counters"]["last_synced_start"], second["counters"]["last_synced_end"])
- self.assertGreater(third["counters"]["last_synced_end"], third["counters"]["last_synced_start"])
+ self.assertGreaterEqual(third["counters"]["last_synced_end"], third["counters"]["last_synced_start"])
self.assertGreater(third["counters"]["last_synced_duration"], 0)
- self.assertEquals(third["counters"]["last_synced_bytes"], 10737418240) # last_synced_bytes = 10 files of 1024MB size each
+ self.assertEquals(third["counters"]["last_synced_bytes"], 1572864000) # last_synced_bytes = 15 files of 100MB size each
# delete a snapshot
self.mount_a.run_shell(["rmdir", "d0/.snap/snap0"])