anchor.diff:  %% @private
   get_all_keyfrags(Bucket, Ring) ->
       fix_bucket(Ring),
  -    [get_keysobj(Frag, Ring) || Frag <- all_frags(Bucket)].
  +    [O || O <- [get_keysobj(Frag) || Frag <- all_frags(Bucket)],
  +          O /= undefined].
   
   %% @private
   merge_keysobj(KeysObj, NewReplays) ->
  
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:                 spawn(fun() -> put_keysobj(NewObj, Ring) end),
                  NewSet
          end,
      merge_frags(T, Ring, [FSet|Acc]).
  
  %% @private                    
  fix_bucket(Ring) ->
  