Function dictCompleteRehashAsync

src/dict.cpp:492–554

}

void dictCompleteRehashAsync(dictAsyncRehashCtl *ctl, bool fFree) {
    dict *d = ctl->dict;
    assert(ctl->done);
    
    // Unlink ourselves
    bool fUnlinked = false;
    dictAsyncRehashCtl **pprev = &d->asyncdata;

    while (*pprev != nullptr) {
        if (*pprev == ctl) {
            *pprev = ctl->next;
            fUnlinked = true;
            break;
        }
        pprev = &((*pprev)->next);
    }

    if (fUnlinked) {
        if (ctl->next != nullptr && ctl->deGCList != nullptr) {
            // An older work item may depend on our free list, so pass our free list to them
            dictEntry **deGC = &ctl->next->deGCList;
            while (*deGC != nullptr) deGC = &((*deGC)->next);
            *deGC = ctl->deGCList;
            ctl->deGCList = nullptr;
        }
    }

    if (fUnlinked && !ctl->abondon) {
        if (d->ht[0].table != nullptr) {    // can be null if we're cleared during the rehash
            for (auto &wi : ctl->queue) {
                // We need to remove it from the source hash table, and store it in the dest.
                //  Note that it may have been deleted in the meantime and therefore not exist.
                //  In this case it will be in the garbage collection list
                
                dictEntry **pdePrev = &d->ht[0].table[wi.hash & d->ht[0].sizemask];
                while (*pdePrev != nullptr && *pdePrev != wi.de) {
                    pdePrev = &((*pdePrev)->next);
                }
                if (*pdePrev != nullptr) {  // The element may be NULL if its in the GC list
                    assert(*pdePrev == wi.de);
                    *pdePrev = wi.de->next;
                    // Now link it to the dest hash table
                    wi.de->next = d->ht[1].table[wi.hash & d->ht[1].sizemask];
                    d->ht[1].table[wi.hash & d->ht[1].sizemask] = wi.de;
                    d->ht[0].used--;
                    d->ht[1].used++;
                }
            }
        }

        /* Check if we already rehashed the whole table... */
        if (d->ht[0].used == 0 && d->asyncdata == nullptr) {
            asyncFreeDictTable(d->ht[0].table);
            d->ht[0] = d->ht[1];
            _dictReset(&d->ht[1]);
            d->rehashidx = -1;
        }
    }