Method onNewClient

Libraries/Http/HttpAsyncServer.cpp:160–195

{
    SocketDescriptor acceptedClient;
    Result           accepted = result.moveTo(acceptedClient);
    if (not accepted)
    {
        if (onError.isValid())
        {
            onError(accepted);
        }
        return;
    }
    HttpConnection::ID idx;
    // Activation always succeeds because we pause asyncAccept when the there are not available clients
    SC_HTTP_ASSERT_RELEASE(connections.activateNew(idx));

    HttpConnection& client = static_cast<HttpConnection&>(connections.getConnection(idx));

    SC_HTTP_ASSERT_RELEASE(client.readableSocketStream.request.isFree());
    SC_HTTP_ASSERT_RELEASE(client.writableSocketStream.request.isFree());

    client.socket = move(acceptedClient);
    SC_HTTP_TRUST_RESULT(client.readableSocketStream.init(client.buffersPool, *eventLoop, client.socket));
    SC_HTTP_TRUST_RESULT(client.writableSocketStream.init(client.buffersPool, *eventLoop, client.socket));
    client.resetTransportStreams();
    client.readableSocketStream.setAutoDestroy(true);
    client.writableSocketStream.setAutoDestroy(false); // needed for keep-alive logic

    Result setup = beginTransportConnection(client);
    if (not setup)
    {
        if (onError.isValid())
        {
            onError(setup);
        }
        closeAsync(client);
    }

    // Only reactivate asyncAccept if there are available clients (otherwise it's being reactivated in closeAsync)
    result.reactivateRequest(connections.getNumActiveConnections() < connections.getNumTotalConnections());
}