anchor.diff:  %% the remote copy is merged (possibly generating siblings) and `true' is returned.
   -spec merge({metadata_pkey(), metadata_context()}, metadata_object()) -> boolean().
   merge({PKey, _Context}, Obj) ->
  -    gen_server:call(?SERVER, {merge, PKey, Obj}).
  +    gen_server:call(?SERVER, {merge, PKey, Obj}, infinity).
   
   %% @doc Returns false if the update (or a causally newer update) has already been
   %% received (stored locally).
   -spec is_stale({metadata_pkey(), metadata_context()}) -> boolean().
   is_stale({PKey, Context}) ->
  -    gen_server:call(?SERVER, {is_stale, PKey, Context}).
  +    gen_server:call(?SERVER, {is_stale, PKey, Context}, infinity).
   
   %% @doc returns the object associated with the given key and context (message id) if
   %% the currently stored version has an equal context. otherwise stale is returned.
  
positive.code: -spec get(metadata_pkey()) -> metadata_object() | undefined.
  get({{Prefix, SubPrefix}, _Key}=PKey) when (is_binary(Prefix) orelse is_atom(Prefix)) andalso
                                             (is_binary(SubPrefix) orelse is_atom(SubPrefix)) ->
      gen_server:call(?SERVER, {get, PKey}).
  
  %% @doc Return an iterator for keys stored under a prefix. If KeyMatch is undefined then
  %% all keys will may be visted by the iterator. Otherwise only keys matching KeyMatch will be
  
negative.code: put({{Prefix, SubPrefix}, _Key}=PKey, Context, ValueOrFun)
    when (is_binary(Prefix) orelse is_atom(Prefix)) andalso
         (is_binary(SubPrefix) orelse is_atom(SubPrefix)) ->
      gen_server:call(?SERVER, {put, PKey, Context, ValueOrFun}, infinity).
  
  %%%===================================================================
  %%% riak_core_broadcast_handler callbacks
  