Method recvData

src/fl/net/http/stream_server.cpp.hpp:143–183

}

int HttpStreamServer::recvData(fl::span<u8> buffer) {
    if (!isConnected()) {
        return -1;
    }

    // Get list of all client IDs
    fl::vector<u32> clientIds = mNativeServer->getClientIds();
    if (clientIds.empty()) {
        return 0;  // No clients connected
    }

    // Round-robin through clients to avoid starvation
    // Start from the last processed client + 1
    size_t startIdx = 0;
    for (size_t i = 0; i < clientIds.size(); i++) {
        if (clientIds[i] == mLastProcessedClientId) {
            startIdx = (i + 1) % clientIds.size();
            break;
        }
    }

    // Try each client starting from startIdx
    for (size_t offset = 0; offset < clientIds.size(); offset++) {
        size_t idx = (startIdx + offset) % clientIds.size();
        u32 clientId = clientIds[idx];

        ClientState* state = getOrCreateClientState(clientId);
        if (!state || !state->httpHeaderReceived || !state->httpHeaderSent) {
            continue;  // Skip clients that haven't completed HTTP handshake
        }

        // Try to receive data from this client
        int received = mNativeServer->recv(clientId, buffer);
        if (received > 0) {
            mLastProcessedClientId = clientId;
            return received;
        }
    }

    return 0;  // No data available from any client
}

void HttpStreamServer::triggerReconnect() {
    // For server: disconnect all clients and restart