anchor.diff:              end
       end.
   
  -clear_disconnect_freq(Host) ->
  +clear_disconnect_freq(ConnInfo) ->
       case erlang:get(disconnect_freq) of
           infinity -> ok;
  -        {ops, _Count} -> erlang:put({ops_since_disconnect, Host#url.host}, 0);
  -        _Seconds -> erlang:put({last_disconnect, Host#url.host}, erlang:now())
  +        {ops, _Count} -> erlang:put({ops_since_disconnect, ConnInfo}, 0);
  +        _Seconds -> erlang:put({last_disconnect, ConnInfo}, erlang:now())
       end.
   
   send_request(Host, Url, Headers, Method, Body, Options) ->
       send_request(Host, Url, Headers, Method, Body, Options, 3).
   
  -send_request(Host, _Url, _Headers, _Method, _Body, _Options, 0) ->
  +send_request(_Host, _Url, _Headers, _Method, _Body, _Options, 0) ->
       {error, max_retries};
   send_request(Host, Url, Headers, Method, Body, Options, Count) ->
       Pid = connect(Host),
  
positive.code:         Seconds -> should_disconnect_secs(Seconds,Url) andalso disconnect(Url)
      end.
  
  should_disconnect_ops(Count, #url{host=Host, port=Port}) ->
      Key = {ops_since_disconnect, {Host, Port}},
      case erlang:get(Key) of
          undefined ->
  
negative.code:     {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};
  
  run(_Operation, _KeyGen, _ValueGen, State) ->
  