anchor.diff:                            w = W,
                             dw = DW,
                             rw = RW
  -                        }};
  +                         }};
           {error, Reason2} ->
               ?FAIL_MSG("Failed to connect riakc_pb_socket to ~p port ~p: ~p\n",
                         [TargetIp, Port, Reason2])
  
positive.code: 
      Ips  = basho_bench_config:get(riakc_pb_ips, [{127,0,0,1}]),
      Port  = basho_bench_config:get(riakc_pb_port, 8087),
      %% riakc_pb_replies sets defaults for R, W, DW and RW. 
      %% Each can be overridden separately
      Replies = basho_bench_config:get(riakc_pb_replies, 2),
      R = basho_bench_config:get(riakc_pb_r, Replies),
  
negative.code:     end;
  run(update, KeyGen, ValueGen, State) ->
      Key = KeyGen(),
      case riakc_pb_socket:get(State#state.pid, State#state.bucket,
                               Key, [{r, State#state.r}]) 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
                  ok ->
                      {ok, State};
                  {error, Reason} ->
  