@@ -560,7 +560,7 @@ def test_cephfs_mirror_stats(self):
560560
561561 # create a bunch of files in a directory to snap
562562 self .mount_a .run_shell (["mkdir" , "d0" ])
563- for i in range (50 ):
563+ for i in range (100 ):
564564 self .mount_a .write_n_mb (os .path .join ('d0' , f'file.{ i } ' ), 1 )
565565
566566 self .enable_mirroring (self .primary_fs_name , self .primary_fs_id )
@@ -574,7 +574,7 @@ def test_cephfs_mirror_stats(self):
574574 # take a snapshot
575575 self .mount_a .run_shell (["mkdir" , "d0/.snap/snap0" ])
576576
577- time .sleep (30 )
577+ time .sleep (60 )
578578 self .check_peer_status (self .primary_fs_name , self .primary_fs_id ,
579579 "client.mirror_remote@ceph" , '/d0' , 'snap0' , 1 )
580580 self .verify_snapshot ('d0' , 'snap0' )
@@ -586,18 +586,18 @@ def test_cephfs_mirror_stats(self):
586586 self .assertGreater (second ["counters" ]["last_synced_start" ], first ["counters" ]["last_synced_start" ])
587587 self .assertGreater (second ["counters" ]["last_synced_end" ], second ["counters" ]["last_synced_start" ])
588588 self .assertGreater (second ["counters" ]["last_synced_duration" ], 0 )
589- self .assertEquals (second ["counters" ]["last_synced_bytes" ], 52428800 ) # last_synced_bytes = 50 files of 1MB size each
589+ self .assertEquals (second ["counters" ]["last_synced_bytes" ], 104857600 ) # last_synced_bytes = 100 files of 1MB size each
590590
591591 # some more IO
592- for i in range (75 ):
592+ for i in range (150 ):
593593 self .mount_a .write_n_mb (os .path .join ('d0' , f'more_file.{ i } ' ), 1 )
594594
595595 time .sleep (60 )
596596
597597 # take another snapshot
598598 self .mount_a .run_shell (["mkdir" , "d0/.snap/snap1" ])
599599
600- time .sleep (60 )
600+ time .sleep (120 )
601601 self .check_peer_status (self .primary_fs_name , self .primary_fs_id ,
602602 "client.mirror_remote@ceph" , '/d0' , 'snap1' , 2 )
603603 self .verify_snapshot ('d0' , 'snap1' )
@@ -609,7 +609,7 @@ def test_cephfs_mirror_stats(self):
609609 self .assertGreater (third ["counters" ]["last_synced_start" ], second ["counters" ]["last_synced_end" ])
610610 self .assertGreater (third ["counters" ]["last_synced_end" ], third ["counters" ]["last_synced_start" ])
611611 self .assertGreater (third ["counters" ]["last_synced_duration" ], 0 )
612- self .assertEquals (third ["counters" ]["last_synced_bytes" ], 78643200 ) # last_synced_bytes = 75 files of 1MB size each
612+ self .assertEquals (third ["counters" ]["last_synced_bytes" ], 157286400 ) # last_synced_bytes = 150 files of 1MB size each
613613
614614 # delete a snapshot
615615 self .mount_a .run_shell (["rmdir" , "d0/.snap/snap0" ])
0 commit comments