Method WaitForPacket

profiling/server/src/basePipeServer/BasePipeServer.cpp:111–172

}

arm::pipe::Packet BasePipeServer::WaitForPacket(uint32_t timeoutMs)
{
    // Is there currently more than a headers worth of data waiting to be read?
    int bytes_available;
    arm::pipe::Ioctl(m_ClientConnection, FIONREAD, &bytes_available);
    if (bytes_available > 8)
    {
        // Yes there is. Read it:
        return ReceivePacket();
    }
    else
    {
        // No there's not. Poll for more data.
        struct pollfd pollingFd[1]{};
        pollingFd[0].fd = m_ClientConnection;
        int pollResult  = arm::pipe::Poll(pollingFd, 1, static_cast<int>(timeoutMs));

        switch (pollResult)
        {
            // Error
            case -1:
                throw ProfilingException(std::string("File descriptor reported an error during polling: ") +
                                         strerror(errno));

                // Timeout
            case 0:
                throw arm::pipe::TimeoutException("Timeout while waiting to receive packet.");

                // Normal poll return. It could still contain an error signal
            default:
                // Check if the socket reported an error
                if (pollingFd[0].revents & (POLLNVAL | POLLERR | POLLHUP))
                {
                    if (pollingFd[0].revents == POLLNVAL)
                    {
                        throw arm::pipe::ProfilingException(
                            std::string("Error while polling receiving socket: POLLNVAL"));
                    }
                    if (pollingFd[0].revents == POLLERR)
                    {
                        throw arm::pipe::ProfilingException(
                            std::string("Error while polling receiving socket: POLLERR: ") + strerror(errno));
                    }
                    if (pollingFd[0].revents == POLLHUP)
                    {
                        throw arm::pipe::ProfilingException(
                            std::string("Connection closed by remote client: POLLHUP"));
                    }
                }

                // Check if there is data to read
                if (!(pollingFd[0].revents & (POLLIN)))
                {
                    // This is a corner case. The socket as been woken up but not with any data.
                    // We'll throw a timeout exception to loop around again.
                    throw arm::pipe::TimeoutException(
                        "File descriptor was polled but no data was available to receive.");
                }