Function dictRehashSomeAsync

src/dict.cpp:461–473

}

bool dictRehashSomeAsync(dictAsyncRehashCtl *ctl, size_t hashes) {
    if (ctl->abondon.load(std::memory_order_acquire)) {
        ctl->hashIdx = ctl->queue.size();
    }
    size_t max = std::min(ctl->hashIdx + hashes, ctl->queue.size());
    for (; ctl->hashIdx < max; ++ctl->hashIdx) {
        auto &wi = ctl->queue[ctl->hashIdx];
        wi.hash = dictHashKey(ctl->dict, dictGetKey(wi.de));
    }

    if (ctl->hashIdx == ctl->queue.size()) ctl->done = true;
    return ctl->hashIdx < ctl->queue.size();
}


void discontinueAsyncRehash(dict *d) {