anchor.diff:  
   start_tls(State=#state{sock=Sock}) ->
       %% Send STARTTLS
  -    io:format("sending starttls~n"),
       StartTLSCode = riak_pb_codec:msg_code(rpbstarttls),
       gen_tcp:send(Sock, <<StartTLSCode:8>>),
       receive
  
positive.code:                                         % if false, exits on connection failure/request timeout
                  queue_if_disconnected = false :: boolean(), % if true, add requests to queue if disconnected
                  sock :: port(),       % gen_tcp socket
                  active :: #request{} | undefined,     % active request
                  queue :: queue() | undefined,      % queue of pending requests
                  connects=0 :: non_neg_integer(), % number of successful connects
  
negative.code:             [MsgCode|MsgData] = Data,
              case riak_pb_codec:decode(MsgCode, MsgData) of
                  rpbauthresp ->
                      ok = ssl:setopts(Sock, [{active, once}]),
                      {ok, State};
                  #rpberrorresp{} = Err ->
                      fmt_err_msg(Err)
              end
      end.
  