/*
 * @licence app begin@
 * SPDX license identifier: MPL-2.0
 *
 * Copyright (C) 2011-2015, BMW AG
 *
 * This file is part of GENIVI Project DLT - Diagnostic Log and Trace.
 *
 * This Source Code Form is subject to the terms of the
 * Mozilla Public License (MPL), v. 2.0.
 * If a copy of the MPL was not distributed with this file,
 * You can obtain one at http://mozilla.org/MPL/2.0/.
 *
 * For further information see http://www.genivi.org/.
 * @licence end@
 */

/*!
 * \author Sven Hassler <sven_hassler@mentor.com>
 *
 * \copyright Copyright © 2011-2015 BMW AG. \n
 * License MPL-2.0: Mozilla Public License version 2.0 http://mozilla.org/MPL/2.0/.
 *
 * \file dlt-kpi-interrupt.c
 */

#include "dlt-kpi-interrupt.h"

DltReturnValue dlt_kpi_log_interrupts(DltContext *ctx, DltLogLevelType log_level)
{
    if (ctx == NULL) {
        fprintf(stderr, "%s: Nullpointer parameter (NULL) !\n", __func__);
        return DLT_RETURN_WRONG_PARAMETER;
    }

    char buffer[BUFFER_SIZE];
    *buffer = '\0';

    char file_buffer[BUFFER_SIZE];
    char *token, *delim = " \t", *delim2 = " \t\n", *check;
    int head_line = 1, first_row = 1, cpu_count = 0, column = 0, buffer_offset = 0;
    DltReturnValue ret;

    if ((ret = dlt_kpi_read_file("/proc/interrupts", file_buffer, BUFFER_SIZE)) < DLT_RETURN_OK) return ret;

    token = strtok(file_buffer, delim);

    while (token != NULL) {
        if (head_line) {
            if ((strlen(token) > 3) && (token[0] == 'C') && (token[1] == 'P') && (token[2] == 'U')) {
                cpu_count++;
            }
            else if (cpu_count <= 0)
            {
                fprintf(stderr, "%s: Could not parse CPU count !\n", __func__);
                return DLT_RETURN_ERROR;
            }
            else if (strcmp(token, "\n") == 0)
            {
                head_line = 0;
            }

            token = strtok(NULL, delim);
        }
        else {
            int tokenlen = strlen(token);

            if (token[tokenlen - 1] == ':') {
                column = 0;

                if (first_row)
                    first_row = 0;
                else
                    buffer_offset += snprintf(buffer + buffer_offset, BUFFER_SIZE - buffer_offset, "\n");
            }

            if (column == 0) { /* IRQ number */
                buffer_offset += snprintf(buffer + buffer_offset,
                                          BUFFER_SIZE - buffer_offset,
                                          "%.*s;",
                                          tokenlen - 1,
                                          token);
            }
            else if (column <= cpu_count)
            {
                long int interrupt_count = strtol(token, &check, 10);

                if (*check != '\0') {
                    fprintf(stderr, "%s: Could not parse interrupt count for CPU !\n", __func__);
                    return DLT_RETURN_ERROR;
                }

                buffer_offset += snprintf(buffer + buffer_offset,
                                          BUFFER_SIZE - buffer_offset,
                                          "cpu%d:%ld;",
                                          column - 1,
                                          interrupt_count);
            }

            column++;

            token = strtok(NULL, delim2);
        }
    }

    /* synchronization message */
    DLT_LOG(*ctx, log_level, DLT_STRING("IRQ"), DLT_STRING("BEG"));

    DltContextData ctx_data;

    if ((ret = dlt_user_log_write_start(ctx, &ctx_data, log_level)) < DLT_RETURN_OK) {
        fprintf(stderr, "%s: dlt_user_log_write_start() returned error\n", __func__);
        return ret;
    }

    if ((ret = dlt_user_log_write_string(&ctx_data, "IRQ")) < DLT_RETURN_OK) {
        fprintf(stderr, "%s: dlt_user_log_write_string() returned error\n", __func__);
        return ret;
    }

    token = strtok(buffer, "\n");

    while (token != NULL) {
        if (dlt_user_log_write_string(&ctx_data, token) < DLT_RETURN_OK) {
            /* message buffer full, start new one */
            if ((ret = dlt_user_log_write_finish(&ctx_data)) < DLT_RETURN_OK) {
                fprintf(stderr, "%s: dlt_user_log_write_finish() returned error\n", __func__);
                return ret;
            }

            if ((ret = dlt_user_log_write_start(ctx, &ctx_data, log_level)) < DLT_RETURN_OK) {
                fprintf(stderr, "%s: dlt_user_log_write_start() returned error\n", __func__);
                return ret;
            }

            if ((ret = dlt_user_log_write_string(&ctx_data, "IRQ")) < DLT_RETURN_OK) {
                fprintf(stderr, "%s: dlt_user_log_write_string() returned error\n", __func__);
                return ret;
            }
        }
        else {
            token = strtok(NULL, "\n");
        }
    }

    if ((ret = dlt_user_log_write_finish(&ctx_data)) < DLT_RETURN_OK) {
        fprintf(stderr, "%s: dlt_user_log_write_finish() returned error\n", __func__);
        return ret;
    }

    /* synchronization message */
    DLT_LOG(*ctx, log_level, DLT_STRING("IRQ"), DLT_STRING("END"));

    return DLT_RETURN_OK;
}