Method pollReady

Libraries/HttpClient/HttpClientScheduler.cpp:109–140

    const size_t index = findOperationIndex(operation);
    if (index == InvalidOperationIndex)
    {
        return;
    }

    readyMutex.lock();
    schedulerMemory.readyOperations[index] = 1;
    readyCV.broadcast();
    readyMutex.unlock();
}

SC::Result SC::HttpClientOperationScheduler::pollReady(size_t& numPolled, uint32_t waitMilliseconds)
{
    if (not initialized)
        return Result::Error(HttpClientResultCategory, HttpClientError::SchedulerNotInitialized);

    numPolled = 0;

    readyMutex.lock();
    if (not hasReadyOperationLocked() and waitMilliseconds > 0 and hasRequestsInFlight())
    {
        (void)readyCV.wait(readyMutex, waitMilliseconds);
    }
    readyMutex.unlock();

    for (size_t idx = 0; idx < schedulerMemory.operations.sizeInElements(); ++idx)
    {
        bool shouldPoll = false;
        readyMutex.lock();
        if (schedulerMemory.readyOperations[idx] != 0)
        {
            schedulerMemory.readyOperations[idx] = 0;
            shouldPoll                           = true;
        }
        readyMutex.unlock();