Function build_full_task_set

cpworker/src/task.c:1184–1262

}

static int build_full_task_set(Config *config, struct TaskList *current_tasks,
                               task_stats_summary_t *current_stats_summary, build_task_set_result_t *result)
{
    struct TaskList *tasks = malloc(sizeof(struct TaskList));
    if (!tasks)
    {
        log_error("malloc failed");
        return -1;
    }
    struct TaskErrorList *errors = malloc(sizeof(struct TaskErrorList));
    if (errors == NULL)
    {
        log_error("malloc failed");
        free(tasks);
        return -1;
    }
    TAILQ_INIT(tasks);
    TAILQ_INIT(errors);

    task_t *item;
    task_t *titem;

    char errbuf[ERROR_BUFFER_SIZE];
    TaskConfig *task_config;
    for (int i = 0; i < config->tasks_cfg->num_tasks; ++i)
    {
        task_config = config->tasks_cfg->tasks[i];
        task_t *existing_task = find_task_by_fingerprint(task_config->fingerprint, current_tasks);
        if (existing_task)
        {
            // reuse existing task
            task_t *task = task_wrapper_new(i, task_config->fingerprint, existing_task->task);
            if (!task)
                goto error;
            TAILQ_INSERT_TAIL(tasks, task, next);
            log_info("existing task-%d, fingerprint=%s", i, task_config->fingerprint);
            continue;
        }

        // create new task
        capture_task_t *cap_task = capture_task_new(config->tasks_cfg, task_config, current_stats_summary, errbuf);
        if (!cap_task)
        {
            log_error("new task-%d error: %s", i, errbuf);
            task_error_t *error = task_error_new(i, task_config->fingerprint, errbuf);
            if (!error)
                goto error;
            TAILQ_INSERT_TAIL(errors, error, next);
            continue;
        }

        task_t *task = task_wrapper_new(i, task_config->fingerprint, cap_task);
        if (!task)
        {
            capture_task_destroy(cap_task);
            goto error;
        }
        log_info("create task-%d success", i);