anchor.diff:  handle_info(timeout, State=#state{ops=Ops}) ->
       NewState = ensure_ring(State),
       do_write_all(Ops, NewState#state.ring),
  -    {noreply, NewState#state{ops=dict:new()}};
  +    {noreply, NewState#state{ops=dict:new(), count=0}};
   handle_info(_,State) -> {stop,badmsg,State}.
  
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: -define(QSIZE, 1000).
  -define(NFRAGS, 1024).
  -define(FLUSH_INTERVAL, 1000).
  -record(state, {ops, ring, count=0}).
  
  % 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()}
  