anchor.diff:      Updates = decode_au_txn_ops(Ops),
       Clock = binary_to_term(BClock),
       Response =
  -        case Clock of 
  -            ignore -> 
  +        case Clock of
  +            ignore ->
                   antidote:clocksi_bulk_update(Updates);
  -            _ -> 
  +            _ ->
                   antidote:clocksi_bulk_update(Clock, Updates)
           end,
  -    case Response of 
  +    case Response of
           {error, _Reason} ->
               {reply, #fpbatomicupdatetxnresp{success = false}, State};
           {ok, {_Txid, _ReadSet, CommitTime}} ->
  
positive.code: decode_au_txn_op(#fpbatomicupdatetxnop{counterdec=#fpbdecrementreq{key=Key, amount=Amount}}) ->
      [{update, Key, riak_dt_pncounter, {{decrement, Amount}, node()}}];
  %% Set
  decode_au_txn_op(#fpbatomicupdatetxnop{setupdate=#fpbsetupdatereq{key=Key, adds=AddElems, rems=RemElems}}) ->
       Adds = lists:map(fun(X) ->
                                binary_to_term(X)
                        end, AddElems),
  
negative.code: decode_snapshot_read_op(#fpbsnapshotreadtxnop{set=#fpbgetsetreq{key=Key}}) ->
      {read,Key, riak_dt_orset}.
  
  %% @doc encodes the response for snapshot read into pb messages
  encode_snapshot_read_response(Zipped) ->
      lists:map(fun(Resp) ->
                        encode_snapshot_read_resp(Resp)
  