anchor.diff:          {ssl_closed, Sock} ->
               {error, closed};
           {ssl, Sock, Data} ->
  -            [MsgCode|MsgData] = Data,
  +            <<MsgCode:8, MsgData/binary>> = Data,
               case riak_pb_codec:decode(MsgCode, MsgData) of
                   rpbauthresp ->
                       ok = ssl:setopts(Sock, [{active, once}]),
  
positive.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}, {header, 1}],
                           State#state.connect_timeout) of
          {ok, Sock} ->
              State1 = State#state{sock = Sock, connects = Connects+1,
  
negative.code:         {tcp_closed, Sock} ->
              {error, closed};
          {tcp, Sock, Data} ->
              <<MsgCode:8, MsgData/binary>> = Data,
              case riak_pb_codec:decode(MsgCode, MsgData) of
                  rpbstarttls ->
                      Options = [{verify, verify_peer},
  