anchor.diff:  counter_val(Pid, Bucket, Key, Options) ->
       {_, B} = maybe_bucket_type(Bucket),
       Req = counter_val_options(Options, #rpbcountergetreq{bucket=B, key=Key}),
  -    gen_server:call(Pid, {req, Req, default_timeout(get_timeout)}, infinity).
  +    call_infinity(Pid, {req, Req, default_timeout(get_timeout)}).
   
   
   %% @doc Fetches the representation of a convergent datatype from Riak.
  
positive.code: %% @equiv is_connected(Pid, infinity)
  -spec is_connected(pid()) -> true | {false, [connection_failure()]}.
  is_connected(Pid) ->
      is_connected(Pid, infinity).
  
  %% @doc Determines whether the client is connected, with the specified
  %% timeout to the client process. Returns true if connected, or false
  %% and a list of connection failures and frequencies if disconnected.
  %% @see is_connected/1
  -spec is_connected(pid(), timeout()) -> true | {false, [connection_failure()]}.
  is_connected(Pid, Timeout) ->
      gen_server:call(Pid, is_connected, Timeout).
  
  %% @doc Ping the server
  %% @equiv ping(Pid, default_timeout(ping_timeout))
  -spec ping(pid()) -> pong.  % or gen_server:call exception on timeout
  ping(Pid) ->
      ping(Pid, default_timeout(ping_timeout)).
  
  %% @doc Ping the server specifying timeout
  -spec ping(pid(), timeout()) -> pong.  % or gen_server:call exception on timeout
  ping(Pid, Timeout) ->
      gen_server:call(Pid, {req, rpbpingreq, Timeout}, infinity).
  
  %% @doc Get the client id for this connection
  %% @equiv get_client_id(Pid, default_timeout(get_client_id_timeout))
  
negative.code:                           timeout=Timeout},
      ReqId = mk_reqid(),
      Call = {req, Req, Timeout, {ReqId, self()}},
      call_infinity(Pid, Call).
  
  %% @doc Return the default timeout for an operation if none is provided.
  %%      Falls back to the default timeout.
  