anchor.diff:                      {error, Reason, UpModState} ->
                           {{error, Reason}, UpModState}
                   end,
  -            riak_core_vnode:reply(From, {ts_reply, Reply, Type})
  +            riak_core_vnode:reply(From, {ts_reply, Reply, Type}),
  +            update_vnode_stats(vnode_put, Idx, StartTS)
       end,
       {noreply, State#state{modstate=ModState2}}.
   
  
positive.code:     Mod:stop(ModState),
      ok.
  
  handle_info({{ts_reply, From, Type, Bucket, Key, EncodedVal} = _Context, Reply}, State) ->
      update_hashtree(Bucket, Key, EncodedVal, State),
      riak_core_vnode:reply(From, {ts_reply, Reply, Type}),
      {ok, State};
  
  handle_info({set_concurrency_limit, Lock, Limit}, State) ->
  
negative.code:             {reply, ignore, State}
      end;
  
  handle_command({ts_put, Bucket, Key, EncodedVal, Type}, From, State=#state{idx=Idx, mod=Mod, async_put=AsyncPut, modstate=ModState}) ->
      StartTS = os:timestamp(),
      case AsyncPut of
          true ->
              Context = {ts_reply, From, Type, Bucket, Key, EncodedVal, StartTS},
              {_Reply, ModState2} =
                  case Mod:async_put(Context, Bucket, Key, EncodedVal, ModState) of
                      {ok, UpModState} ->
  