@@ -117,6 +117,16 @@ def create_command(self):
117117 + " --no-cleanup"
118118 return rados_bench_write
119119
120+ @staticmethod
121+ def pre_process (env ):
122+ warm_up_time = "30"
123+ env_write_command = "sudo bin/rados bench -p " + env .pool \
124+ + " " + warm_up_time + " write -t 10" \
125+ + " -b " + env .args .block_size \
126+ + " --no-cleanup"
127+ os .system (env_write_command + " >/dev/null" )
128+ print ('ceph osd warmed up.' )
129+
120130 @staticmethod
121131 def post_process (env , test_case_result ):
122132 ratio = env .testclient_threadclass_ratio_map [RadosSeqWriteThread ]
@@ -253,6 +263,7 @@ def analyse(self):
253263 @staticmethod
254264 def pre_process (env ):
255265 image_name_prefix = "fio_test_rbd_"
266+ warm_up_time = "30"
256267 # must be client_num here.
257268 for i in range (env .client_num ):
258269 image_name = image_name_prefix + str (i )
@@ -263,6 +274,13 @@ def pre_process(env):
263274 command += " 2>/dev/null"
264275 os .system (command )
265276 env .images .append (image_name )
277+ print ('all fio rbd images created.' )
278+ env_write_command = "sudo bin/rados bench -p " + env .pool \
279+ + " " + warm_up_time + " write -t 10" \
280+ + " -b " + env .args .block_size \
281+ + " --no-cleanup"
282+ os .system (env_write_command + " >/dev/null" )
283+ print ('ceph osd warmed up.' )
266284
267285 @staticmethod
268286 def post_process (env , test_case_result ):
@@ -705,7 +723,6 @@ def get_disk_name(self):
705723 help = 'path of all output result after integrating' )
706724 parser .add_argument ('--output-horizontal' ,
707725 action = 'store_true' ,
708- default = False ,
709726 help = 'all results of one test case will be in one line' )
710727 parser .add_argument ('--scenario' ,
711728 type = str ,
@@ -714,8 +731,7 @@ def get_disk_name(self):
714731 classic-memstore or classic-bluestore' )
715732 parser .add_argument ('--single-core' ,
716733 action = 'store_true' ,
717- default = False ,
718- help = 'do not run osds in single core' )
734+ help = 'run osds in single core' )
719735
720736 # test case based thread param
721737 parser .add_argument ('--rand-write' ,
@@ -746,19 +762,15 @@ def get_disk_name(self):
746762 # time point based thread param
747763 parser .add_argument ('--reactor-utilization' ,
748764 action = 'store_true' ,
749- default = False ,
750765 help = 'collect the reactor utilization' )
751766 parser .add_argument ('--perf' ,
752767 action = 'store_true' ,
753- default = False ,
754768 help = 'collect perf information' )
755769 parser .add_argument ('--iostat' ,
756770 action = 'store_true' ,
757- default = False ,
758771 help = 'collect iostat information' )
759772 parser .add_argument ('--freq' ,
760773 action = 'store_true' ,
761- default = False ,
762774 help = 'collect cpu frequency information' )
763775 args = parser .parse_args ()
764776
0 commit comments