anchor.diff:  run(update, KeyGen, ValueGen, State) ->
       Key = KeyGen(),
       case riakc_pb_socket:get(State#state.pid, State#state.bucket,
  -                             Key, [{r, State#state.r}]) of
  +                             Key, [{r, State#state.r}], State#state.timeout_read) of
           {ok, Robj} ->
               Robj2 = riakc_obj:update_value(Robj, ValueGen()),
               case riakc_pb_socket:put(State#state.pid, Robj2, [{w, State#state.w},
  -                                                              {dw, State#state.dw}]) of
  +                                                              {dw, State#state.dw}], State#state.timeout_write) of
                   ok ->
                       {ok, State};
                   {error, Reason} ->
  
positive.code:     Robj0 = riakc_obj:new(State#state.bucket, KeyGen()),
      Robj = riakc_obj:update_value(Robj0, ValueGen()),
      case riakc_pb_socket:put(State#state.pid, Robj, [{w, State#state.w},
                                                       {dw, State#state.dw}]) of
          ok ->
              {ok, State};
          {error, Reason} ->
  
negative.code: %% ====================================================================
  
  mapred(State, Input, Query) ->
      case riakc_pb_socket:mapred(State#state.pid, Input, Query, State#state.timeout_mapreduce) of
          {ok, Result} ->
              case check_result(State, Input, Query, Result) of
                  ok ->
  