anchor.diff:      traverse(sent, gb_trees:iterator(Sent)),
       ok.
   
  --spec send_rrd_metrics() -> fail | ok.
  +-spec send_rrd_metrics() -> ok.
   send_rrd_metrics() ->
       % Statistics in RRD (Load, Latency)
       RRDMetrics =
  
positive.code:   case gb_trees:next(Iter1) of
      none -> ok;
      {Key, {Bytes, _Count}, Iter2} ->
        _ = gmetric(positive, lists:flatten(io_lib:format("~s ~p", [RcvSnd, Key])), "int32", Bytes, "Bytes"),
        traverse(RcvSnd, Iter2)
    end.
  
  -spec agg_check_pending(state()) -> state().
  
negative.code:     % Query DHT Nodes for load, let them reply to the on handler ganglia_dht_node_reply
      % The FD tells us if a node is down
      lists:foreach(fun (PID) ->
                            GlobalPID = comm:make_global(PID),
                            %% Let the failure detector inform ganglia about crashes of this DHT node
                            fd:subscribe(GlobalPID, {ganglia, AggId}),
                            Envelope = comm:reply_as(comm:this(), 4,
                                                     {ganglia_dht_load_aggregation, GlobalPID, AggId , '_'}),
                            comm:send_local(PID, {get_node_details, Envelope, [load]})
                    end, DHTNodes),
      set_agg_pending(length(DHTNodes), State).
  