anchor.diff:  -module(riak_kv_pb_crdt).
   
   -include_lib("riak_pb/include/riak_dt_pb.hrl").
  +-include_lib("riak_pb/include/riak_kv_pb.hrl").
   -include_lib("riak_pb/include/riak_pb_kv_codec.hrl").
   -include_lib("riak_kv_types.hrl").
   
  
positive.code: timeout(_) ->
      ?DEFAULT_TIMEOUT.
  
  get_key(undefined) ->
      %% Generate a key, the user didn't supply one
      Key = list_to_binary(riak_core_util:unique_id_62()),
  
negative.code: 
  -import(riak_pb_kv_codec, [decode_quorum/1]).
  
  -record(state, {client,
                  type,
                  mod,
                  op,
                  op_type,
                  return_key,
                  return_ctx,
                  return_value}).
  
  -define(DEFAULT_TIMEOUT, 60000).
  -define(DEFAULT_BUCKET, <<"default">>).
  
  %% @doc init/0 callback. Returns the service internal start
  %% state.
  