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:     FragErrs = [F || F <- AllFrags, element(1, F) =:= error],
      case FragErrs of
          [] ->
              {ok, merge_frags(AllFrags, Ring, sets:new())};
          [E|_] -> E
      end.
      
  %% @private
  merge_frags([], _Ring, Acc) ->
      sets:to_list(Acc);
  merge_frags([F|T], Ring, Acc) ->
      Contents = riak_object:get_values(F),
      FSet = 
  
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
  