Function freeClientsInAsyncFreeQueue

src/networking.cpp:1774–1800

}

int freeClientsInAsyncFreeQueue(int iel) {
    serverAssert(GlobalLocksAcquired());
    std::unique_lock<fastlock> ul(g_lockasyncfree);
    listIter li;
    listNode *ln;
    listRewind(g_pserver->clients_to_close,&li);

    // Store the clients in a temp vector since freeClient will modify this list
    std::vector<client*> vecclientsFree;
    while((ln = listNext(&li))) 
    {
        client *c = (client*)listNodeValue(ln);
        if (c->iel == iel && !(c->flags & CLIENT_PROTECTED) && !c->casyncOpsPending)
        {
            vecclientsFree.push_back(c);
            listDelNode(g_pserver->clients_to_close, ln);
        }
    }
    ul.unlock();

    for (client *c : vecclientsFree)
    {
        c->flags &= ~CLIENT_CLOSE_ASAP;
        freeClient(c);
    }
    return (int)vecclientsFree.size();
}

/* Return a client by ID, or NULL if the client ID is not in the set
 * of registered clients. Note that "fake clients", created with -1 as FD,