anchor.diff:      FragErrs = [F || F <- AllFrags, element(1, F) =:= error],
       case FragErrs of
           [] ->
  -            {ok, merge_frags(AllFrags, Ring, sets:new())};
  +            {ok, merge_frags(AllFrags, Ring, [])};
           [E|_] -> E
       end.
       
   %% @private
   merge_frags([], _Ring, Acc) ->
  -    sets:to_list(Acc);
  +    sets:to_list(sets:union(Acc));
   merge_frags([F|T], Ring, Acc) ->
       Contents = riak_object:get_values(F),
       FSet = 
  
positive.code:                 spawn(fun() -> put_keysobj(NewObj, Ring) end),
                  NewSet
          end,
      merge_frags(T, Ring, sets:union([FSet, Acc])).
  
  %% @private                    
  fix_bucket(Ring) ->
  
negative.code: handle_info(timeout, State=#state{ops=Ops}) ->
      NewState = ensure_ring(State),
      do_write_all(Ops, NewState#state.ring),
      {noreply, NewState#state{ops=dict:new(), count=0}};
  handle_info(_,State) -> {stop,badmsg,State}.
  