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: -define(QSIZE, 1000).
  -define(NFRAGS, 1024).
  -define(FLUSH_INTERVAL, 1000).
  -record(state, {ops, ring, tref}).
  
  % State.ops is a dict, keys are bucketname atoms, vals are lists of operations,
  % where operations are tuples of {Op::[add|del], riak_object:key()}
  
negative.code:         error ->   [{OpType,Key}];
          {ok, L} -> [{OpType,Key}|L]
      end,
      NewOps = dict:store(BucketFrag, OpList, Ops),
      NewCount = Count + 1,
      case NewCount > ?QSIZE of
          true ->
              do_write_all(NewOps,NewState#state.ring),
              {noreply, NewState#state{ops=dict:new(), count=0}, ?FLUSH_INTERVAL};
          false ->
              {noreply,NewState#state{ops=NewOps, count=0}, ?FLUSH_INTERVAL}
      end.
  
  %% @private
  