anchor.diff:                                                          {ok, true} ->
                                                               case Label#label.operation of
                                                                   update ->
  +                                                                    Delay = dict:fetch(Node, Delays),
                                                                       Now = now_microsec(),
                                                                       Time = Now + Delay;
                                                                   _ ->
  
positive.code: 
  -record(state, {queues :: dict(),
                  busy :: dict(),
                  delay, %has to be in microsecs
                  myid}).
  
  %% ------------------------------------------------------------------
  
negative.code:     done;
  
  propagate_stream(Node, Stream, MyId) ->
      %lager:info("Stream to propagate to ~p: ~p", [Node, Stream]),
      case ?PROPAGATION_MODE of
          naive_erlang ->
              case groups_manager_serv:is_leaf(Node) of
  