@@ -36,6 +36,8 @@ def task(ctx, config):
3636 write_fadvise_dontneed: write behavior like with LIBRADOS_OP_FLAG_FADVISE_DONTNEED.
3737 This mean data don't access in the near future.
3838 Let osd backend don't keep data in cache.
39+ pct_update_delay: delay before primary propogates pct on write pause,
40+ defaults to 5s if balance_reads is set
3941
4042 For example::
4143
@@ -139,6 +141,7 @@ def task(ctx, config):
139141 object_size = int (config .get ('object_size' , 4000000 ))
140142 op_weights = config .get ('op_weights' , {})
141143 testdir = teuthology .get_testdir (ctx )
144+ pct_update_delay = None
142145 args = [
143146 'adjust-ulimits' ,
144147 'ceph-coverage' ,
@@ -166,6 +169,7 @@ def task(ctx, config):
166169 args .extend (['--pool-snaps' ])
167170 if config .get ('balance_reads' , False ):
168171 args .extend (['--balance-reads' ])
172+ pct_update_delay = config .get ('pct_update_delay' , 5 );
169173 if config .get ('localize_reads' , False ):
170174 args .extend (['--localize-reads' ])
171175 if config .get ('max_attr_len' , None ):
@@ -274,6 +278,10 @@ def thread():
274278 if config .get ('fast_read' , False ):
275279 manager .raw_cluster_cmd (
276280 'osd' , 'pool' , 'set' , pool , 'fast_read' , 'true' )
281+ if pct_update_delay :
282+ manager .raw_cluster_cmd (
283+ 'osd' , 'pool' , 'set' , pool ,
284+ 'pct_update_delay' , str (pct_update_delay ));
277285 min_size = config .get ('min_size' , None );
278286 if min_size is not None :
279287 manager .raw_cluster_cmd (
0 commit comments