Method onStreamReceive

Libraries/Http/HttpAsyncServer.cpp:197–324

    {
        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());
}

Result HttpAsyncServer::beginHttpConnection(HttpConnection& client)
{
    client.response.setWritableStream(client.getWritableTransportStream());

    EventDataListener dataListener{*this, client};
    SC_TRY_MSG(client.getReadableTransportStream().eventData.addListener(dataListener),
               "HttpAsyncServer readable data listener unavailable");
    if (client.getReadableTransportStream().canStart())
    {
        SC_TRY(client.getReadableTransportStream().start());
    }
    else
    {
        client.getReadableTransportStream().resumeReading();
    }
    return Result(true);
}

Result HttpAsyncServer::beginTransportConnection(HttpConnection& client)
{
    if (not transportSetup.isValid())
    {
        return beginHttpConnection(client);