anchor.diff:  pb_test_set_read_write(_Node) ->
       Key = <<"key_read_write_set">>,
       {ok, Pid} = antidotec_pb_socket:start(?ADDRESS, ?PORT),
  -    Bound_object = {Key, riak_dt_orset, <<"bucket">>},
  +    Bound_object = {Key, antidote_crdt_orset, <<"bucket">>},
       {ok, TxId} = antidotec_pb:start_transaction(Pid, term_to_binary(ignore), {}),
       ok = antidotec_pb:update_objects(Pid, [{Bound_object, add, "a"}], TxId),
       {ok, _} = antidotec_pb:commit_transaction(Pid, TxId),
  
positive.code: 
  update_counter_crdt_and_read_test(Key, Amount) ->
      pass = update_counter_crdt_test(Key, <<"bucket">>, Amount),
      pass = get_crdt_check_value(Key, riak_dt_pncounter, <<"bucket">>, Amount).
  
  get_crdt_check_value(Key, Type, Bucket, Expected) ->
      lager:info("Verifying value of updated CRDT..."),
  
negative.code: pb_test_counter_read_write(_Node) ->
      Key = <<"key_read_write">>,
      {ok, Pid} = antidotec_pb_socket:start(?ADDRESS, ?PORT),
      Bound_object = {Key, antidote_crdt_counter, <<"bucket">>},
      {ok, TxId} = antidotec_pb:start_transaction(Pid, term_to_binary(ignore), {}),
      ok = antidotec_pb:update_objects(Pid, [{Bound_object, increment, 1}], TxId),
      {ok, _} = antidotec_pb:commit_transaction(Pid, TxId),
  