anchor.diff:  -spec init([]) -> {ok, #state{}}.
   init([]) ->
       _ = ets:new(?MODULE, [set, named_table, {read_concurrency, true}]),
  -    ets:insert(?MODULE, {offset, 0}),
  +    {ok, CounterRef} = mz_counter:create_raw(),
  +    ets:insert(?MODULE, {offset_ref, CounterRef}),
       random:seed(erlang:now()),
       ok = perform_sync(),
       TimeSyncIntervalMS = 1000 * application:get_env(mzbench, time_sync_interval_s, undefined),
  
positive.code: 
  -spec get_offset() -> integer().
  get_offset() ->
      ets:lookup_element(?MODULE, offset, 2).
  
  %%%===================================================================
  %%% gen_server callbacks
  
negative.code:         Director when Director == node() -> ok;
          Director ->
              Offset = evaluate_time_offset(Director, 20),
              set_offset(Offset)
      end,
      ok.
  
  set_offset(Offset) ->
      Ref = ets:lookup_element(?MODULE, offset_ref, 2),
      OldOffset = mz_counter:get_value_raw(Ref),
      mz_counter:notify_raw(Ref, Offset - OldOffset).
  
  -spec evaluate_time_offset(Node :: atom(), SleepBetweenAttempts :: non_neg_integer()) -> Offset :: integer().
  evaluate_time_offset(Node, SleepInterval) ->
  