anchor.diff:      op_complete(Op, {ok, 1}, ElapsedUs);
   op_complete(Op, {ok, Units}, ElapsedUs) ->
       %% Update the histogram and units counter for the op in question
  -    %folsom_metrics:notify({latencies, Op}, ElapsedUs),
  -    %folsom_metrics:notify({units, Op}, {inc, Units}),
  -    gen_server:cast({global, ?MODULE}, {Op, {ok, Units}, ElapsedUs}),
  +   % io:format("Get distributed: ~p~n", [get_distributed()]),
  +    case get_distributed() of
  +        true ->
  +            gen_server:cast({global, ?MODULE}, {Op, {ok, Units}, ElapsedUs});
  +        false ->
  +            folsom_metrics:notify({latencies, Op}, ElapsedUs),
  +            folsom_metrics:notify({units, Op}, {inc, Units})
  +    end,
       ok;
   op_complete(Op, Result, ElapsedUs) ->
       gen_server:call({global, ?MODULE}, {op, Op, Result, ElapsedUs}).
  
positive.code: %% ====================================================================
  %% Internal functions
  %% ====================================================================
  
  op_csv_file({Label, _Op}) ->
      Fname = normalize_label(Label) ++ "_latencies.csv",
  
negative.code:                  report_interval,
                   errors_since_last_report = false,
                   summary_file,
                   errors_file,
                   last_warn = {0,0,0}}).
  
  -define(WARN_INTERVAL, 1000). % Warn once a second
  %% ====================================================================
  %% API
  %% ====================================================================
  