anchor.diff:  %%--------------------------------------------------------------------
   handle_call({get_aggregator_for, BucketName}, _From, State) ->
       Pid = case ets:lookup(State#state.ets_map, BucketName) of
  -              [{_, P, _}=Tuple] ->
  +              [{_, P}=Tuple] ->
                     case is_process_alive(P) of
                         true -> P;
                         false -> cleanup_dead_aggregator(Tuple, State),
  
positive.code: %%                                       {stop, Reason, State}
  %% Description: Handling all non call/cast messages
  %%--------------------------------------------------------------------
  handle_info({'DOWN', MRef, process, _Item, _Info}=All, State) ->
      ns_log:log(?MODULE, 1, "Got DOWN for %p", [All]),
      case ets:lookup(State#state.by_mref, MRef) of
          [{BucketName, _, _}=Tuple] ->
              ns_log:log(?MODULE, 2, "Aggregator for bucket ~p is down", [BucketName]),
              cleanup_dead_aggregator(Tuple, State);
          [] ->
              ns_log:log(?MODULE, 3, "DOWN is for unknown aggregator. Ignoring")
      end,
      {noreply, State}.
  
  %%--------------------------------------------------------------------
  
negative.code:           end)}.
  
  test_setup() ->
      just_start([?MODULE, spawn_test_aggregator_process, [self()]]).
  
  test_teardown(_V) ->
      t.
  