anchor.diff:  %% it should drop through and be ignored.
   handle_info({tcp, Sock, Data}, State=#state{sock = Sock, active = Active}) ->
       [MsgCode|MsgData] = Data,
  -    Resp = riak_pb_codec:decode(MsgCode, MsgData),
  +    Resp = case Active#request.msg of
  +        {tunneled, _MsgID} ->
  +            %% don't decode tunneled replies, we may not recognize the msgid
  +            {MsgCode, MsgData};
  +        _ ->
  +            riak_pb_codec:decode(MsgCode, MsgData)
  +    end,
       case Resp of
           #rpberrorresp{} ->
               NewState1 = maybe_reply(on_error(Active, Resp, State)),
  
positive.code: process_response(#request{msg = #rpbindexreq{}}, #rpbindexresp{keys=Keys}, State) ->
      {reply, {ok, Keys}, State};
  
  
  process_response(#request{msg = #rpbsearchqueryreq{}}, prbsearchqueryresp, State) ->
      {reply, {error, notfound}, State};
  process_response(#request{msg = #rpbsearchqueryreq{index=Index}},
  
negative.code:     Values = [ {Index, [ riak_pb_codec:decode_pair(Field) || Field <- Doc#rpbsearchdoc.fields] }
                 || Doc <- PBDocs ],
      Result = #search_results{docs=Values, max_score=MaxScore, num_found=NumFound},
      {reply, {ok, Result}, State};
  
  process_response(#request{msg={tunneled,_MsgId}}, Reply, State) ->
      %% Tunneled msg response
      {reply, {ok, Reply}, State};
  
  process_response(Request, Reply, State) ->
      %% Unknown request/response combo
      {reply, {error, {unknown_response, Request, Reply}}, State}.
  
  %%
  %% Called after sending a message - supports returning a
  