anchor.diff:            end)}.
   
   test_setup() ->
  -    start_link([?MODULE, spawn_test_aggregator_process, [self()]]).
  +    just_start([?MODULE, spawn_test_aggregator_process, [self()]]).
   
   test_teardown(_V) ->
       t.
  
positive.code: %% Description: Initiates the server
  %%--------------------------------------------------------------------
  init([[_Module, _Fun, _ExtraArgs] = AggregatorSpawnArgs])->
      {ok, #state{ets_map = ets:new(ets_map, []),
                  aggregator_spawn_args = AggregatorSpawnArgs,
                  by_mref = ets:new(by_mref, [{keypos, 3}])}}.
  
  %%--------------------------------------------------------------------
  %% Function: %% handle_call(Request, From, State) -> {reply, Reply, State} |
  
negative.code: %%--------------------------------------------------------------------
  handle_call({get_aggregator_for, BucketName}, _From, State) ->
      Pid = case ets:lookup(State#state.ets_map, BucketName) of
                [{_, P}=Tuple] ->
                    case is_process_alive(P) of
                        true -> P;
                        false -> cleanup_dead_aggregator(Tuple, State),
  