anchor.diff:  
   %% @doc Set bucket properties specifying a server side and local call timeout.
   -spec set_bucket(pid(), bucket(), bucket_props(), timeout(), timeout()) -> ok | {error, term()}.
  -set_bucket(Pid, Bucket, BucketProps, Timeout, CallTimeout) ->
  +set_bucket(Pid, Bucket, BucketProps, Timeout, _CallTimeout) ->
       PbProps = riak_pb_codec:encode_bucket_props(BucketProps),
       {T, B} = maybe_bucket_type(Bucket),
       Req = #rpbsetbucketreq{type = T, bucket = B, props = PbProps},
  -    gen_server:call(Pid, {req, Req, Timeout}, CallTimeout).
  +    call_infinity(Pid, {req, Req, Timeout}).
   
   set_bucket_type(Pid, BucketType, BucketProps) ->
       set_bucket_type(Pid, BucketType, BucketProps, default_timeout(set_bucket_timeout)).
  
positive.code: 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).
  
  
  %% @doc Fetches the representation of a convergent datatype from Riak.
  
negative.code:            true ->
                 Timeout
             end,
      call_infinity(Pid, {req, ReqMsg, Timeout1, {ReqId, ClientPid}}).
  
  %% @private
  %% Make a new request that can be sent or queued
  