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:         error ->   [{OpType,Key}];
          {ok, L} -> [{OpType,Key}|L]
      end,
      case length(OpList) > ?QSIZE of
          true ->
              do_write_all(dict:store(BucketFrag, OpList, Ops), 
                           NewState#state.ring),
              {noreply, NewState#state{ops=dict:new()}};
          false ->
              {noreply,NewState#state{ops=dict:store(BucketFrag,OpList,Ops)}}
      end.
  
  %% @private
  
negative.code: %% @private
  get_all_keyfrags(Bucket, Ring) ->
      fix_bucket(Ring),
      [O || O <- [get_keysobj(Frag) || Frag <- all_frags(Bucket)],
            O /= undefined].
  
  %% @private
  merge_keysobj(KeysObj, NewReplays) ->
  