Function RequeueFromWorker

src/common/cloud_work_queue.cpp:525–558

}

static bool RequeueFromWorker(WorkItem item) {
    std::lock_guard<std::mutex> lock(g_queueMutex);
    if (item.type == WorkItem::Upload) {
        // A present index entry means a newer upload is already queued for this
        // path, so drop the retry instead of walking the list under the lock.
        if (g_uploadIndex.find(item.cloudPath) != g_uploadIndex.end()) {
            LOG("[CloudStorage] Retry dropped: newer upload already queued for %s",
                item.cloudPath.c_str());
            g_failedPaths.erase(item.cloudPath);
            g_failedWorkItems.erase(item.cloudPath);
            return false;
        }
    }
    if (item.type == WorkItem::Delete) {
        ClearRecentUploadForDeleteLocked(item.cloudPath);
        auto indexIt = g_uploadIndex.find(item.cloudPath);
        if (indexIt != g_uploadIndex.end()) {
            LOG("[CloudStorage] Retry dropped: upload supersedes stale delete for %s",
                item.cloudPath.c_str());
            g_failedPaths.erase(item.cloudPath);
            g_failedWorkItems.erase(item.cloudPath);
            return false;
        }
    }
    g_failedPaths.erase(item.cloudPath);
    g_failedWorkItems.erase(item.cloudPath);
    g_workQueue.push_back(std::move(item));
    auto qit = std::prev(g_workQueue.end());
    if (qit->type == WorkItem::Upload) {
        g_uploadIndex[qit->cloudPath] = qit;
    }
    g_queueCV.notify_one();
    return true;
}

void DrainQueue() {
    if (!g_provider) return;