anchor.diff:  %% Description: Initiates the server
   %%--------------------------------------------------------------------
   init([[_Module, _Fun, _ExtraArgs] = AggregatorSpawnArgs])->
  +    process_flag(trap_exit, true),
       {ok, #state{ets_map = ets:new(ets_map, []),
                   aggregator_spawn_args = AggregatorSpawnArgs,
  -                by_mref = ets:new(by_mref, [{keypos, 3}])}}.
  +                by_pid = ets:new(by_pid, [{keypos, 2}])}}.
   
   %%--------------------------------------------------------------------
   %% Function: %% handle_call(Request, From, State) -> {reply, Reply, State} |
  
positive.code:           end)}.
  
  test_setup() ->
      start_link([?MODULE, spawn_test_aggregator_process, [self()]]).
  
  test_teardown(_V) ->
      t.
  
negative.code: 
  -export([get_aggregator_for/1, kill_childs/0, call_aggregator_for/3, call_aggregator_for/2]).
  
  -record(state, {ets_map, aggregator_spawn_args, by_pid}).
  
  get_aggregator_for(BucketName) ->
      gen_server:call(?MODULE, {get_aggregator_for, BucketName}).
  