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.assertEqual(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
++ self.assertEqual(second["counters"]["last_synced_bytes"], 1048576000) # last_synced_bytes = 10 files of 1024MB 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)
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.assertEqual(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
++ self.assertEqual(third["counters"]["last_synced_bytes"], 1572864000) # last_synced_bytes = 10 files of 1024MB size each
# delete a snapshot
self.mount_a.run_shell(["rmdir", "d0/.snap/snap0"])