Function task_manager_collect_stats_summary_command

cpworker/src/task.c:818–865

}

int task_manager_collect_stats_summary_command(cJSON *cmd_msg, cJSON *server_msg, void *data)
{
    task_manager_t *this = &task_mgr;

    pthread_mutex_lock(&this->stats_lock);
    task_stats_summary_snapshot_t stats = this->stats_summary_snapshot;
    pthread_mutex_unlock(&this->stats_lock);

    cJSON *time = cJSON_CreateObject();
    if (!time)
        goto error;
    cJSON_AddItemToObject(server_msg, "time", time);

    cJSON *tv_sec = cJSON_CreateNumber(stats.tm.tv_sec);
    if (!tv_sec)
        goto error;
    cJSON_AddItemToObject(time, "sec", tv_sec);

    cJSON *tv_nsec = cJSON_CreateNumber(stats.tm.tv_nsec);
    if (!tv_nsec)
        goto error;
    cJSON_AddItemToObject(time, "nsec", tv_nsec);

    cJSON *capture = cJSON_CreateObject();
    if (!capture)
        goto error;
    cJSON_AddItemToObject(server_msg, "capture", capture);
    if (capture_stats_json_dump(&stats.capture, capture) != 0)
        goto error;

    cJSON *output = cJSON_CreateObject();
    if (!output)
        goto error;
    cJSON_AddItemToObject(server_msg, "output", output);
    if (output_stats_json_dump(&stats.output, output) != 0)
        goto error;

    cJSON *pipeline_buffer = cJSON_CreateObject();
    if (!pipeline_buffer)
        goto error;
    cJSON_AddItemToObject(server_msg, "pipeline_buffer", pipeline_buffer);
    if (pipeline_buffer_stats_json_dump(&stats.pipeline_buffer, pipeline_buffer) != 0)
        goto error;

    return 0;
error:
    return -1;
}

/*
 * 硬约束：