anchor.diff:  -export([start_link/2]).
   
   -export([handle/1,
  -         handle/2,
  -         delayed_delivery_completed/2,
  -         deliver_delayed/4]).
  +         handle/2]).
   
   %% ------------------------------------------------------------------
   %% gen_server Function Exports
  
positive.code: handle_cast(_Msg, State) ->
      {noreply, State}.
  
  handle_info(_Info, State) ->
      {noreply, State}.
  
  terminate(_Reason, _State) ->
  
negative.code:                                                 _ ->
                                                      case groups_manager_serv:interested(Node, BKey) of
                                                          {ok, true} ->
                                                              case Label#label.operation of
                                                                  update ->
                                                                      Now = now_microsec(),
                                                                      Time = Now + Delay;
                                                                  _ ->
                                                                      Time = 0
                                                              end,
                                                              Queue0 = dict:fetch(Node, Acc1),
                                                              Queue1 = queue:in({Time, Label}, Queue0),
                                                              dict:store(Node, Queue1, Acc1);
                                                          {ok, false} -> Acc1
                                                      end
                                              end
                                          end, Acc0, dict:fetch_keys(Queues0))
                            end, Queues0, Stream),
      {Queues2, Busy1} = lists:foldl(fun(Node, {Acc1, Acc2}) ->
                                      case dict:fetch(Node, Busy0) of
                                          false ->
                                              {NewQueue, NewPending} = deliver_labels(dict:fetch(Node, Queues1), Node, MyId, []),
                                              {dict:store(Node, NewQueue, Acc1), dict:store(Node, NewPending, Acc2)};
                                          true ->
                                              OldQueue = dict:fetch(Node, Queues1),
                                              {dict:store(Node, OldQueue, Acc1), dict:store(Node, true, Acc2)}
                                      end
                                     end, {dict:new(), dict:new()}, dict:fetch_keys(Queues1)),
      {reply, ok, S0#state{queues=Queues2, busy=Busy1}};
  
  handle_call(_Request, _From, State) ->
      {reply, ok, State}.
  