anchor.diff:  %% Internal functions
   %% ====================================================================
   
  -insert_or_update(KeyGen, ValueGen, State) ->
  +insert(KeyGen, ValueGen, {Host, Port}) ->
       %% TODO:
       %% bucket needs to be
       %% configurable/generatable
       Bucket = "test",
  -    {NextHost, S2} = next_host(State),
  -    {Host, Port} = NextHost,
       Key = KeyGen(),
       Url = url(Host, Port, Bucket, Key),
       Value = ValueGen(),
  -    do_put({Host, Port}, Url, [], Value),
  -    {ok, S2}.
  +    do_put({Host, Port}, Url, [], Value).
   
   url(Host, Port, Bucket, Key) ->
       UnparsedUrl = lists:concat(["http://", Host, ":", Port, "/", Bucket, "/", Key]),
  
positive.code: 
  -spec run(atom(), fun(), fun(), term()) -> {ok, term()}.
  run(insert, KeyGen, ValueGen, State) ->
      insert_or_update(KeyGen, ValueGen, State);
  run(update, KeyGen, ValueGen, State) ->
      insert_or_update(KeyGen, ValueGen, State);
  run(delete, KeyGen, _ValueGen, State) ->
      Bucket = "test",
      {NextHost, S2} = next_host(State),
      {Host, Port} = NextHost,
      Key = KeyGen(),
      Url = url(Host, Port, Bucket, Key),
      do_delete({Host, Port}, Url, []),
      {ok, S2};
  run(get, KeyGen, _ValueGen, State) ->
      Bucket = "test",
      {NextHost, S2} = next_host(State),
      {Host, Port} = NextHost,
      Key = KeyGen(),
      Url = url(Host, Port, Bucket, Key),
      do_get({Host, Port}, Url, []),
      {ok, S2};
  run(_Operation, _KeyGen, _ValueGen, State) ->
      {ok, State}.
  
  
negative.code:     {error, max_retries};
  send_request(Host, Url, Headers, Method, Body, Options, Count) ->
      Pid = connect(Host),
      HeadersWithAuth = [{'Authorization', basho_bench_config:get(moss_authorization)}|Headers],
      case catch(ibrowse_http_client:send_req(Pid, Url, HeadersWithAuth, Method, Body, Options, basho_bench_config:get(moss_request_timeout, 5000))) of
          {ok, Status, RespHeaders, RespBody} ->
              maybe_disconnect(Host),
              {ok, Status, RespHeaders, RespBody};
  