Method removeClientAsyncWrites

src/AsyncWorkQueue.cpp:64–86

}

bool AsyncWorkQueue::removeClientAsyncWrites(client *c)
{
    bool fFound = false;
    aeAcquireLock();
    m_mutex.lock();
    for (auto pvars : m_vecpthreadVars)
    {
        listIter li;
        listNode *ln;
        listRewind(pvars->clients_pending_asyncwrite, &li);
        while ((ln = listNext(&li)) != nullptr)
        {
            if (c == listNodeValue(ln))
            {
                listDelNode(pvars->clients_pending_asyncwrite, ln);
                fFound = true;
            }
        }
    }
    m_mutex.unlock();
    aeReleaseLock();
    return fFound;
}

void AsyncWorkQueue::shutdown()
{