anchor.diff:      lager:info("====================== run benchmark ====================="),
       {ok, Pid} = start_stats_checker(RiakNodes),
   
  -    lager:info("write_concurrency: ~p, write_interval: ~p msec", [Concurrency, Interval]),
  +    lager:info("write_concurrency: ~p, write_interval: ~p msec, DVV: ~p",
  +               [Concurrency, Interval, DVVEnabled]),
   
       Writers = [start_object_writer(UserConfig, Interval) || _ <- lists:seq(1, Concurrency)],
       {ok, Reader} = start_object_reader(UserConfig),
  
positive.code:     Duration = proplists:get_value(duration_sec, RTConfig, 16),
      ?assert(is_integer(Duration) andalso Duration >= 0),
  
      Config = [{cs,
                 [{riak_cs,
                   [{leeway_seconds, 5},
                    {gc_interval, 10},
                    {connection_pools, [{request_pool, {Concurrency*2 + 5, 0}}]}
                   ]}]}],
      {UserConfig, {RiakNodes, CSNodes, _Stanchion}} =
          case proplists:get_value(version, RTConfig, current) of
              current ->
  
negative.code: %%       [{write_concurrency, 2},
  %%        {duration_sec, 30},
  %%        {leave_and_join, 0}, %% number of cluster membership change during the benchmark
  %%        {dvv_enabled, true},
  %%        {version, previous}]
  %%        %%{version, current}]
  %%      },
  