Function worker_unique_file

src/mcp/index_supervisor.c:567–598

}

static bool worker_unique_file(char *out, size_t out_size, const char *kind) {
    if (!out || out_size == 0 || !kind || !kind[0]) {
        return false;
    }
    char cache_copy[INDEX_WORKER_PATH_CAP] = {0};
    bool have_cache = worker_cache_dir(cache_copy);
    int written;
    if (have_cache) {
        char directory[INDEX_WORKER_PATH_CAP];
        written = snprintf(directory, sizeof(directory), "%s/logs", cache_copy);
        if (written <= 0 || written >= (int)sizeof(directory) ||
            !cbm_mkdir_p_ex(directory, 0700, CBM_MKDIR_FOLLOW_OWNED)) {
            return false;
        }
        written = snprintf(out, out_size, "%s/.worker-%s-XXXXXX", directory, kind);
    } else {
        written = snprintf(out, out_size, ".worker-%s-XXXXXX", kind);
    }
    if (written <= 0 || written >= (int)out_size) {
        out[0] = '\0';
        return false;
    }
    worker_tmp_lock();
    int descriptor = cbm_mkstemp(out);
    worker_tmp_unlock();
    if (descriptor < 0) {
        out[0] = '\0';
        return false;
    }
    (void)worker_close(descriptor);
    return true;
}

static bool worker_result_succeeded(const cbm_index_worker_result_t *result) {
    return result && result->outcome == CBM_PROC_CLEAN && !result->cancellation_requested &&