Method HandleClient

engine/Poseidon/Dev/Harness/HarnessServer.cpp:303–456

}

void HarnessServer::HandleClient(SOCKET_T clientSock)
{
    std::string buffer;
    char recvBuf[4096];

    while (!_stopRequested.load())
    {
        // First, drain any pending events and send to client
        auto events = _queue.DrainEvents();
        for (const auto& evt : events)
        {
            int sent = send(clientSock, evt.json.c_str(), static_cast<int>(evt.json.size()), 0);
            if (sent == HARNESS_SOCKET_ERROR)
            {
                LOG_DEBUG(Core, "[Harness] Send event failed, client gone");
                return;
            }
        }

        // Use select() to check for data with timeout
        fd_set readSet;
        FD_ZERO(&readSet);
        FD_SET(clientSock, &readSet);

        timeval tv = {};
        tv.tv_sec = 0;
        tv.tv_usec = 50000; // 50ms — check events frequently

        int sel = select(static_cast<int>(clientSock) + 1, &readSet, nullptr, nullptr, &tv);
        if (sel < 0)
        {
            LOG_DEBUG(Core, "[Harness] select() error on client socket");
            return;
        }
        if (sel == 0)
            continue; // timeout — loop back to drain events

        int bytes = recv(clientSock, recvBuf, sizeof(recvBuf) - 1, 0);
        if (bytes <= 0)
        {
            LOG_DEBUG(Core, "[Harness] Client connection closed (recv={})", bytes);
            return;
        }
        recvBuf[bytes] = '\0';
        buffer += recvBuf;

        // Process complete lines
        size_t pos;
        while ((pos = buffer.find('\n')) != std::string::npos)
        {
            std::string line = buffer.substr(0, pos);
            buffer.erase(0, pos + 1);

            while (!line.empty() && (line.back() == '\r' || line.back() == ' '))
                line.pop_back();
            if (line.empty())
                continue;