anchor.diff:                  end,
               lists:foreach(F, ErrCounts)
       end.
  +
  +consume_report_msgs() ->
  +    receive
  +        report ->
  +            consume_report_msgs()
  +    after 0 ->
  +            ok
  +    end.
  
positive.code:     {noreply, State}.
  
  handle_info(report, State) ->
      Now = os:timestamp(),
      process_stats(Now, State),
  
      %% Schedule next report
      erlang:send_after(State#state.report_interval, self(), report),
      {noreply, State#state { last_write_time = Now, errors_since_last_report = false }}.
  
  terminate(_Reason, State) ->
  
negative.code: handle_call(run, _From, State) ->
      %% Schedule next report
      Now = os:timestamp(),
      timer:send_interval(State#state.report_interval, report),
      {reply, ok, State#state { start_time = Now, last_write_time = Now}};
  handle_call({op, Op, {error, Reason}, _ElapsedUs}, _From, State) ->
      increment_error_counter(Op),
  