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