anchor.diff:          {ok, "200", _Header, _Body} ->
               ok;
           {ok, "204", _Header, _Body} ->
  +            ok;
  +        {ok, Code, _Header, _Body} ->
  +            {error, {http_error, Code}};
  +        {error, Reason} ->
  +            {error, Reason}
  +    end.
  +
  +do_copy(Host, Url, Headers, State) ->
  +    case send_request(Host, Url, Headers, put, <<>>, proxy_opts(State)) of
  +        {ok, "200", _Header, _Body} ->
               ok;
           {ok, Code, _Header, _Body} ->
               {error, {http_error, Code}};
  
positive.code:                                'Content-Type', Headers0,
                                 'application/octet-stream')),
      Date = httpd_util:rfc1123_date(),
      Headers = [{'Content-Type', ContentTypeStr},
                 {'Date', Date}|lists:keydelete('Content-Type', 1, Headers0)],
      Uri = element(7, Url),
      Sig = stanchion_auth:request_signature(
              uppercase_verb(Method), Headers, Uri,
              basho_bench_config:get(cs_secret_key, "undefined")),
      AuthStr = ["AWS ", basho_bench_config:get(cs_access_key, "undefined"), ":", Sig],
      HeadersWithAuth = [{'Authorization', AuthStr}|Headers],
      Timeout = basho_bench_config:get(cs_request_timeout, 5000),
      ibrowse_http_client:send_req(Pid, Url, HeadersWithAuth, Method,
                                   Body, Options, Timeout).
  
  %% Setup user, not related to load operations
  
  setup_user_and_bucket(State) ->
      case basho_bench_config:get(cs_access_key, undefined) of
  
negative.code:     Key = KeyGen(),
      Url = url(Host, Port, Bucket, Key),
      case do_delete({Host, Port}, Url, [], State) of
          ok ->
              {ok, S2};
          {error, Reason} ->
              {error, Reason, S2}
      end;
  run2(copy, KeyGen, _ValueGen, #state{bucket = Bucket} = State) ->
      {NextHost, S2} = next_host(State),
      {Host, Port} = NextHost,
      SourceKey = KeyGen(),
      DestKey = SourceKey ++ basho_bench_config:get(cs_copy_suffix, "-copy"),
      Url = url(Host, Port, Bucket, DestKey),
      Headers = [{"x-amz-copy-source", "/" ++ Bucket ++ "/" ++ SourceKey}],
      case do_copy({Host, Port}, Url, Headers, State) of
          ok ->
              {ok, S2};
          {error, Reason} ->
  