anchor.diff:  %%      to ClientPid.
   %%      See the map/reduce documentation for explanation of behavior.
   mapred_stream(Pid, Inputs, Query, ClientPid) ->
  -    mapred_stream(Pid, Inputs, Query, ClientPid,?DEFAULT_TIMEOUT).
  +    mapred_stream(Pid, Inputs, Query, ClientPid, default_timeout(mapred_stream)).
   
   %% @spec mapred_stream(Pid :: pid(),
   %%                     Inputs :: list(),
  
positive.code: %% @doc Perform a map/reduce job against a bucket across the cluster.
  %%      See the map/reduce documentation for explanation of behavior.
  mapred_bucket(Pid, Bucket, Query) ->
      mapred_bucket(Pid, Bucket, Query, ?DEFAULT_TIMEOUT).
  
  %% @spec mapred_bucket(Pid :: pid(),
  %%                     Bucket :: bucket(),
  
negative.code:     ReqMsg = #rpbmapredreq{request = encode_mapred_req(MapRed),
                             content_type = <<"application/x-erlang-binary">>},
      ReqId = mk_reqid(),
      %% Add an extra 100ms to the mapred timeout and use that for the 
      %% socket timeout.  This should give the map/reduce a chance to fail and let us know.
      Timeout = proplists:get_value(timeout, MapRed, default_timeout(mapred)) + 100,
      gen_server:call(Pid, {req, ReqMsg, Timeout, {ReqId, ClientPid}}).
  
  %% @private
  %% Make a new request that can be sent or queued
  