anchor.diff:  
   %% @doc decode/2 callback. Decodes an incoming message.
   decode(Code, Bin) ->
  -    lager:info("Decoding Txn Req ~p",[Code]),
  +    % lager:info("Decoding Txn Req ~p",[Code]),
       Msg = riak_pb_codec:decode(Code, Bin),
       case Msg of
           #fpbatomicupdatetxnreq{} ->
  
positive.code: 
  %% @doc process/2 callback. Handles an incoming request message.
  process(#fpbatomicupdatetxnreq{ops = Ops}, State) ->
      lager:info("Testing txn interface.. Received atomic update request  ~p", [Ops]),
      Updates = decode_au_txn_ops(Ops),
      case antidote:clocksi_bulk_update(Updates) of
          {error, _Reason} ->
  
negative.code:     end;
  
  process(#fpbsnapshotreadtxnreq{ops = Ops}, State) ->
      % lager:info("Testing txn interface.. Received snapshot read request  ~p", [Ops]),
      ReadReqs = decode_snapshot_read_ops(Ops),
      %%TODO: change this to interactive reads
      case antidote:clocksi_execute_tx(ReadReqs) of
  