Method accept_SSL_callback

src/posix/libevent/libevent_ssl_socket.cpp:1129–1279

void LibeventSSLSocketImpl::accept_SSL_callback(AcceptRequest* request)
{
  CHECK(__in_event_loop__);

  // Set up SSL object.
  SSL* ssl = SSL_new(openssl::context());
  if (ssl == nullptr) {
    request->promise.fail("Accept failed, SSL_new");
    delete request;
    return;
  }

  Try<Address> peer_address = network::peer(request->socket);
  if (!peer_address.isSome()) {
    request->promise.fail("Could not determine peer IP for connection.");
    delete request;
    return;
  }

  // NOTE: Right now, the configure callback does not do anything in server
  // mode, but we still pass the correct peer address to enable modules to
  // implement application-level logic in the future.
  Try<Nothing> configured = openssl::configure_socket(
      ssl, openssl::Mode::SERVER, peer_address.get(), None());

  if (configured.isError()) {
    request->promise.fail("Could not configure socket: " + configured.error());
    delete request;
    return;
  }

  // We use 'request->listener' because 'this->listener' may not have
  // been set by the time this function is executed. See comment in
  // the lambda for evconnlistener_new in
  // 'LibeventSSLSocketImpl::listen'.
  event_base* ev_base = evconnlistener_get_base(request->listener);

  // Construct the bufferevent in the accepting state.
  bufferevent* bev = bufferevent_openssl_socket_new(
      ev_base,
      request->socket,
      ssl,
      BUFFEREVENT_SSL_ACCEPTING,
      BEV_OPT_THREADSAFE);

  if (bev == nullptr) {
    request->promise.fail("Accept failed: bufferevent_openssl_socket_new");
    SSL_free(ssl);
    delete request;
    return;
  }

  bufferevent_setcb(
      bev,
      nullptr,
      nullptr,
      [](bufferevent* bev, short events, void* arg) {
        // This handles error states or 'BEV_EVENT_CONNECTED' events