anchor.diff:      Msg = riak_pb_codec:decode(Code, Bin),
       case Msg of
           #tsqueryreq{query = Q, cover_context = Cover} ->
  +            %% convert error returns to ok's, this menas it will be passed into
  +            %% process which will not process it and return the error.
               case catch decode_query(Q, Cover) of
                   {ok, DecodedQuery} ->
                       PermAndTarget = decode_query_permissions(DecodedQuery),
                       {ok, DecodedQuery, PermAndTarget};
                   {error, Error} ->
  -                    {error, decoder_parse_error_resp(Error)};
  +                    {ok, make_decoder_error_response(Error)};
                   {'EXIT', {Error, _}} ->
  -                    {error, decoder_parse_error_resp(Error)}
  +                    {ok, make_decoder_error_response(Error)}
               end;
           #tsgetreq{table = Table}->
               {ok, Msg, {"riak_kv.ts_get", Table}};
  
positive.code: 
  -spec process(atom() | ts_requests() | ts_query_types(), #state{}) ->
                       {reply, ts_responses(), #state{}}.
  process(M = #tsputreq{table = Table}, State) ->
      check_table_and_call(Table, fun sub_tsputreq/4, M, State);
  
  
negative.code:     [#tscolumndescription{name = Name, type = riak_pb_ts_codec:encode_field_type(Type)}
       || {Name, Type} <- lists:zip(ColumnNames, ColumnTypes)].
  
  make_decoder_error_response({LineNo, riak_ql_parser, Msg}) when is_integer(LineNo) ->
      make_rpberrresp(?E_PARSE_ERROR, flat_format("~ts", [Msg]));
  make_decoder_error_response({Token, riak_ql_parser, _}) when is_binary(Token) ->
      make_rpberrresp(?E_PARSE_ERROR, flat_format("Unexpected token '~s'", [Token]));
  make_decoder_error_response({Token, riak_ql_parser, _}) ->
      make_rpberrresp(?E_PARSE_ERROR, flat_format("Unexpected token '~p'", [Token]));
  make_decoder_error_response(Error) ->
      Error.
  
  flat_format(Format, Args) ->
      lists:flatten(io_lib:format(Format, Args)).
  
  -ifdef(TEST).
  -include_lib("eunit/include/eunit.hrl").
  