anchor.diff:          {tcp_closed, Sock} ->
               {error, closed};
           {tcp, Sock, Data} ->
  -            [MsgCode|MsgData] = Data,
  +            <<MsgCode:8, MsgData/binary>> = Data,
               case riak_pb_codec:decode(MsgCode, MsgData) of
                   rpbstarttls ->
                       Options = [{verify, verify_peer},
  
positive.code: %% it should drop through and be ignored.
  handle_info({Proto, Sock, Data}, State=#state{sock = Sock, active = Active})
          when Proto == tcp; Proto == ssl ->
      [MsgCode|MsgData] = Data,
      Resp = case Active#request.msg of
          {tunneled, _MsgID} ->
              %% don't decode tunneled replies, we may not recognize the msgid
  
negative.code: connect(State) when State#state.sock =:= undefined ->
      #state{address = Address, port = Port, connects = Connects} = State,
      case gen_tcp:connect(Address, Port,
                           [binary, {active, once}, {packet, 4}],
                           State#state.connect_timeout) of
          {ok, Sock} ->
              State1 = State#state{sock = Sock, connects = Connects+1,
  