anchor.diff:      {noreply, State}.
   
   handle_info(report, State) ->
  +    consume_report_msgs(),
       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) ->
  
positive.code:     %% Determine how much time has elapsed (seconds) since our last report
      %% If zero seconds, round up to one to avoid divide-by-zeros in reporting
      %% tools.
      Elapsed = erlang:max(trunc(timer:now_diff(Now, State#state.start_time) / 1000000), 1),
      Window  = timer:now_diff(Now, State#state.last_write_time) / 1000000,
  
      %% Time to report latency data to our CSV files
  
negative.code:                 end,
              lists:foreach(F, ErrCounts)
      end.
  
  consume_report_msgs() ->
      receive
          report ->
              consume_report_msgs()
      after 0 ->
              ok
      end.
  