anchor.diff:      
   new_label(MyId, Label, Partition, Seq) ->
       gen_server:cast({global, reg_name(MyId)}, {new_label, Label, Partition, Seq}).
  +
  +label_delivered(MyId, Element) ->
  +    gen_server:cast({global, reg_name(MyId)}, {label_delivered, Element}).
   
   init([MyId]) ->
       {ok, Ring} = riak_core_ring_manager:get_my_ring(),
  
positive.code:             S0#state{vclock=VClock1, seqs=Seqs1}
      end.
  
  deliver_labels(S0=#state{vclock=Clocks, labels=Labels0, myid=MyId}) ->
      StableTime = compute_stable_time(Clocks),
      Labels1 = filter_labels(Labels0, StableTime, MyId),
      S0#state{labels=Labels1}.
  
  compute_stable_time(Clocks) ->
  
negative.code:                     end
                  end, FirstClock, Rest). 
  
  filter_labels([], _StableTime, _MyId, _Delay)->
      [];
  
  filter_labels([H|Rest], StableTime, MyId, Delay) ->
      {TimeStamp, ListLabels} = H,
      case TimeStamp =< StableTime of
          true ->
              Now = saturn_utilities:now_milisec(),
              {FinalStream, Leftovers} = lists:foldl(fun({Time, Label}, {FinalStream0, Leftovers0}) ->
                                                  case (Time + Delay) > Now of
                                                      true ->
                                                          {FinalStream0, Leftovers0 ++ [{Time, Label}]};
                                                      false ->
                                                          {FinalStream0 ++ [Label], Leftovers0 }
                                                  end
                                                end, {[], []}, ListLabels),
              case groups_manager_serv:filter_stream_leaf(FinalStream) of
                  {ok, [], _} ->
                      noop;
                  {ok, _, no_indexnode} ->
  