values.c

Go to the documentation of this file.

#include <stdlib.h>

#include "util.h"
#include "values.h"

void perf_read_values_init(struct perf_read_values *values)
{
    values->threads_max = 16;
    values->pid = malloc(values->threads_max * sizeof(*values->pid));
    values->tid = malloc(values->threads_max * sizeof(*values->tid));
    values->value = malloc(values->threads_max * sizeof(*values->value));
    if (!values->pid || !values->tid || !values->value)
        die("failed to allocate read_values threads arrays");
    values->threads = 0;

    values->counters_max = 16;
    values->counterrawid = malloc(values->counters_max
                      * sizeof(*values->counterrawid));
    values->countername = malloc(values->counters_max
                     * sizeof(*values->countername));
    if (!values->counterrawid || !values->countername)
        die("failed to allocate read_values counters arrays");
    values->counters = 0;
}

void perf_read_values_destroy(struct perf_read_values *values)
{
    int i;

    if (!values->threads_max || !values->counters_max)
        return;

    for (i = 0; i < values->threads; i++)
        free(values->value[i]);
    free(values->value);
    free(values->pid);
    free(values->tid);
    free(values->counterrawid);
    for (i = 0; i < values->counters; i++)
        free(values->countername[i]);
    free(values->countername);
}

static void perf_read_values__enlarge_threads(struct perf_read_values *values)
{
    values->threads_max *= 2;
    values->pid = realloc(values->pid,
                  values->threads_max * sizeof(*values->pid));
    values->tid = realloc(values->tid,
                  values->threads_max * sizeof(*values->tid));
    values->value = realloc(values->value,
                values->threads_max * sizeof(*values->value));
    if (!values->pid || !values->tid || !values->value)
        die("failed to enlarge read_values threads arrays");
}

static int perf_read_values__findnew_thread(struct perf_read_values *values,
                        u32 pid, u32 tid)
{
    int i;

    for (i = 0; i < values->threads; i++)
        if (values->pid[i] == pid && values->tid[i] == tid)
            return i;

    if (values->threads == values->threads_max)
        perf_read_values__enlarge_threads(values);

    i = values->threads++;
    values->pid[i] = pid;
    values->tid[i] = tid;
    values->value[i] = malloc(values->counters_max * sizeof(**values->value));
    if (!values->value[i])
        die("failed to allocate read_values counters array");

    return i;
}

static void perf_read_values__enlarge_counters(struct perf_read_values *values)
{
    int i;

    values->counters_max *= 2;
    values->counterrawid = realloc(values->counterrawid,
                       values->counters_max * sizeof(*values->counterrawid));
    values->countername = realloc(values->countername,
                      values->counters_max * sizeof(*values->countername));
    if (!values->counterrawid || !values->countername)
        die("failed to enlarge read_values counters arrays");

    for (i = 0; i < values->threads; i++) {
        values->value[i] = realloc(values->value[i],
                       values->counters_max * sizeof(**values->value));
        if (!values->value[i])
            die("failed to enlarge read_values counters arrays");
    }
}

static int perf_read_values__findnew_counter(struct perf_read_values *values,
                         u64 rawid, const char *name)
{
    int i;

    for (i = 0; i < values->counters; i++)
        if (values->counterrawid[i] == rawid)
            return i;

    if (values->counters == values->counters_max)
        perf_read_values__enlarge_counters(values);

    i = values->counters++;
    values->counterrawid[i] = rawid;
    values->countername[i] = strdup(name);

    return i;
}

void perf_read_values_add_value(struct perf_read_values *values,
                u32 pid, u32 tid,
                u64 rawid, const char *name, u64 value)
{
    int tindex, cindex;

    tindex = perf_read_values__findnew_thread(values, pid, tid);
    cindex = perf_read_values__findnew_counter(values, rawid, name);

    values->value[tindex][cindex] = value;
}

static void perf_read_values__display_pretty(FILE *fp,
                         struct perf_read_values *values)
{
    int i, j;
    int pidwidth, tidwidth;
    int *counterwidth;

    counterwidth = malloc(values->counters * sizeof(*counterwidth));
    if (!counterwidth)
        die("failed to allocate counterwidth array");
    tidwidth = 3;
    pidwidth = 3;
    for (j = 0; j < values->counters; j++)
        counterwidth[j] = strlen(values->countername[j]);
    for (i = 0; i < values->threads; i++) {
        int width;

        width = snprintf(NULL, 0, "%d", values->pid[i]);
        if (width > pidwidth)
            pidwidth = width;
        width = snprintf(NULL, 0, "%d", values->tid[i]);
        if (width > tidwidth)
            tidwidth = width;
        for (j = 0; j < values->counters; j++) {
            width = snprintf(NULL, 0, "%" PRIu64, values->value[i][j]);
            if (width > counterwidth[j])
                counterwidth[j] = width;
        }
    }

    fprintf(fp, "# %*s  %*s", pidwidth, "PID", tidwidth, "TID");
    for (j = 0; j < values->counters; j++)
        fprintf(fp, "  %*s", counterwidth[j], values->countername[j]);
    fprintf(fp, "\n");

    for (i = 0; i < values->threads; i++) {
        fprintf(fp, "  %*d  %*d", pidwidth, values->pid[i],
            tidwidth, values->tid[i]);
        for (j = 0; j < values->counters; j++)
            fprintf(fp, "  %*" PRIu64,
                counterwidth[j], values->value[i][j]);
        fprintf(fp, "\n");
    }
    free(counterwidth);
}

static void perf_read_values__display_raw(FILE *fp,
                      struct perf_read_values *values)
{
    int width, pidwidth, tidwidth, namewidth, rawwidth, countwidth;
    int i, j;

    tidwidth = 3; /* TID */
    pidwidth = 3; /* PID */
    namewidth = 4; /* "Name" */
    rawwidth = 3; /* "Raw" */
    countwidth = 5; /* "Count" */

    for (i = 0; i < values->threads; i++) {
        width = snprintf(NULL, 0, "%d", values->pid[i]);
        if (width > pidwidth)
            pidwidth = width;
        width = snprintf(NULL, 0, "%d", values->tid[i]);
        if (width > tidwidth)
            tidwidth = width;
    }
    for (j = 0; j < values->counters; j++) {
        width = strlen(values->countername[j]);
        if (width > namewidth)
            namewidth = width;
        width = snprintf(NULL, 0, "%" PRIx64, values->counterrawid[j]);
        if (width > rawwidth)
            rawwidth = width;
    }
    for (i = 0; i < values->threads; i++) {
        for (j = 0; j < values->counters; j++) {
            width = snprintf(NULL, 0, "%" PRIu64, values->value[i][j]);
            if (width > countwidth)
                countwidth = width;
        }
    }

    fprintf(fp, "# %*s  %*s  %*s  %*s  %*s\n",
        pidwidth, "PID", tidwidth, "TID",
        namewidth, "Name", rawwidth, "Raw",
        countwidth, "Count");
    for (i = 0; i < values->threads; i++)
        for (j = 0; j < values->counters; j++)
            fprintf(fp, "  %*d  %*d  %*s  %*" PRIx64 "  %*" PRIu64,
                pidwidth, values->pid[i],
                tidwidth, values->tid[i],
                namewidth, values->countername[j],
                rawwidth, values->counterrawid[j],
                countwidth, values->value[i][j]);
}

void perf_read_values_display(FILE *fp, struct perf_read_values *values, int raw)
{
    if (raw)
        perf_read_values__display_raw(fp, values);
    else
        perf_read_values__display_pretty(fp, values);
}