anchor.diff:                            end, dict:new(), dict:to_list(Delays0)),
       {ok, #state{queues=Queues, myid=MyId, busy=Busy, delays=Delays1}}.
   
  -handle_call({new_stream, Stream, IdSender}, _From, S0=#state{queues=Queues0, busy=Busy0, delays=Delays, myid=MyId}) ->
  +handle_cast({new_stream, Stream, IdSender}, S0=#state{queues=Queues0, busy=Busy0, delays=Delays, myid=MyId}) ->
       Queues1 = lists:foldl(fun(Label, Acc0) ->
                               BKey = Label#label.bkey,
                               lists:foldl(fun(Node, Acc1) ->
  
positive.code:             case groups_manager_serv:is_leaf(Node) of
                  {ok, true} ->
                      ServerName = list_to_atom(integer_to_list(Node) ++ atom_to_list(saturn_leaf_converger)),
                      gen_server:call({global, ServerName}, {new_stream, Stream, MyId}, infinity);
                  {ok, false} ->
                      saturn_internal_serv:handle(Node, {new_stream, Stream, MyId})
              end;
  
negative.code:                                             {dict:store(Node, OldQueue, Acc1), dict:store(Node, true, Acc2)}
                                      end
                                     end, {dict:new(), dict:new()}, dict:fetch_keys(Queues1)),
      {noreply, S0#state{queues=Queues2, busy=Busy1}};
  
  handle_cast(_Msg, State) ->
      {noreply, State}.
  
  handle_call(restart, _From, S0=#state{busy=Busy0, queues=Queues0}) ->
      Queues1 = lists:foldl(fun({Node, _}, Acc) ->
                              dict:store(Node, queue:new(), Acc)
                            end, dict:new(), dict:to_list(Queues0)),
      Busy1 = lists:foldl(fun({Node, _}, Acc) ->
                              dict:store(Node, false, Acc)
                          end, dict:new(), dict:to_list(Busy0)),
      {reply, ok, S0#state{queues=Queues1, busy=Busy1}};
  
  handle_call(_Request, _From, State) ->
      {reply, ok, State}.
  
  handle_info({deliver_labels, Node}, S0=#state{queues=Queues0, busy=Busy0, myid=MyId}) ->
      {NewQueue, NewPending} = deliver_labels(dict:fetch(Node, Queues0), Node, MyId, []),
  