anchor.diff:                             fun(Old) -> rrd:add_now(MemBin, Old) end),
       monitor:monitor_set_value(?MODULE, 'mem_ets',
                              fun(Old) -> rrd:add_now(MemEts, Old) end),
  -    
  +
       {RcvCnt, RcvBytes, SendCnt, SendBytes} = comm_stats:get_stats(),
       monitor:monitor_set_value(?MODULE, 'rcv_count',
                              fun(Old) -> rrd:add_now(RcvCnt, Old) end),
  
positive.code:     % if sending the reply from bulkowner gather fails
      bulkowner:send_reply_failed(Id, Target, BMsg, Parents, self(), FailedTarget),
      State;
  
  on({bulkowner, reply, Id, {gather_stats_response, DataL}} = _Msg,
     {AllNodes, Leader, BenchPid, IgnBenchT} = _State)
  
negative.code:                                {PerfRR2, PerfLH2, rrd:timing_with_hist_merge_fun(0, PerfTX2, PerfTX3)}
                         end, {PerfRR1, PerfLH1, PerfTX1}, Data1)
               end, {undefined, undefined, undefined}, Msgs),
  
      Msg = {?send_to_registered_proc, monitor_perf,
             {gather_stats_response, [{?MODULE, 'read_read', PerfRR},
                                      {dht_node, 'lookup_hops', PerfLH},
  