Method processTask

lib/AsyncHttpClient/src/AsyncHttpClient.cpp:574–603

}

void AsyncHttpClient::processTask(void* parameters)
{
    AsyncHttpClient* tthis = static_cast<AsyncHttpClient*>(parameters);

    if ((nullptr != tthis) &&
        (nullptr != tthis->m_processTaskSemaphore))
    {
        (void)xSemaphoreTake(tthis->m_processTaskSemaphore, portMAX_DELAY);

        while (false == tthis->m_processTaskExit)
        {
            tthis->processCmdQueue();
            tthis->processEvtQueue();

            delay(PROCESS_TASK_PERIOD);
        }

        /* Ensure that any pending request/connection is aborted. */
        tthis->abort();

        /* The global mutex must be released from the same task it
         * was taken, otherwise it will lead to a assertion in FreeRTOS.
         */
        tthis->giveGlobalMutex();

        (void)xSemaphoreGive(tthis->m_processTaskSemaphore);
    }

    vTaskDelete(nullptr);
}

void AsyncHttpClient::processCmdQueue()
{