source: mainline/uspace/app/top/screen.c@ c47e1a8

/*
 * Copyright (c) 2010 Stanislav Kozina
 * Copyright (c) 2010 Martin Decky
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * - Redistributions of source code must retain the above copyright
 *   notice, this list of conditions and the following disclaimer.
 * - Redistributions in binary form must reproduce the above copyright
 *   notice, this list of conditions and the following disclaimer in the
 *   documentation and/or other materials provided with the distribution.
 * - The name of the author may not be used to endorse or promote products
 *   derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

/** @addtogroup top
 * @brief Top utility.
 * @{
 */
/**
 * @file
 */

#include <stdio.h>
#include <ipc/ipc.h>
#include <io/console.h>
#include <io/style.h>
#include <vfs/vfs.h>
#include <stdarg.h>
#include <stats.h>
#include <inttypes.h>
#include "screen.h"
#include "top.h"

static ipcarg_t warn_col = 0;
static ipcarg_t warn_row = 0;

static void screen_style_normal(void)
{
        fflush(stdout);
        console_set_style(fphone(stdout), STYLE_NORMAL);
}

static void screen_style_inverted(void)
{
        fflush(stdout);
        console_set_style(fphone(stdout), STYLE_INVERTED);
}

static void screen_moveto(ipcarg_t col, ipcarg_t row)
{
        fflush(stdout);
        console_set_pos(fphone(stdout), col, row);
}

static void screen_get_pos(ipcarg_t *col, ipcarg_t *row)
{
        fflush(stdout);
        console_get_pos(fphone(stdout), col, row);
}

static void screen_get_size(ipcarg_t *col, ipcarg_t *row)
{
        fflush(stdout);
        console_get_size(fphone(stdout), col, row);
}

static void screen_restart(bool clear)
{
        screen_style_normal();
        
        if (clear) {
                fflush(stdout);
                console_clear(fphone(stdout));
        }
        
        screen_moveto(0, 0);
}

static void screen_newline(void)
{
        ipcarg_t cols;
        ipcarg_t rows;
        screen_get_size(&cols, &rows);
        
        ipcarg_t c;
        ipcarg_t r;
        screen_get_pos(&c, &r);
        
        ipcarg_t i;
        for (i = c + 1; i < cols; i++)
                puts(" ");
        
        if (r + 1 < rows)
                puts("\n");
}

void screen_init(void)
{
        fflush(stdout);
        console_cursor_visibility(fphone(stdout), false);
        
        screen_restart(true);
}

void screen_done(void)
{
        screen_restart(true);
        
        fflush(stdout);
        console_cursor_visibility(fphone(stdout), true);
}

static void print_float(fixed_float ffloat, unsigned int precision)
{
        printf("%2" PRIu64 ".", ffloat.upper / ffloat.lower);
        
        unsigned int i;
        uint64_t rest = (ffloat.upper % ffloat.lower) * 10;
        for (i = 0; i < precision; i++) {
                printf("%" PRIu64, rest / ffloat.lower);
                rest = (rest % ffloat.lower) * 10;
        }
}

static inline void print_global_head(data_t *data)
{
        printf("top - %02lu:%02lu:%02lu up %u days, %02u:%02u:%02u, load average:",
            data->hours, data->minutes, data->seconds,
            data->udays, data->uhours, data->uminutes, data->useconds);
        
        size_t i;
        for (i = 0; i < data->load_count; i++) {
                puts(" ");
                stats_print_load_fragment(data->load[i], 2);
        }
        
        screen_newline();
}

static inline void print_task_summary(data_t *data)
{
        printf("tasks: %u total", data->tasks_count);
        screen_newline();
}

static inline void print_thread_summary(data_t *data)
{
        size_t total = 0;
        size_t running = 0;
        size_t ready = 0;
        size_t sleeping = 0;
        size_t lingering = 0;
        size_t other = 0;
        size_t invalid = 0;
        
        size_t i;
        for (i = 0; i < data->threads_count; i++) {
                total++;
                
                switch (data->threads[i].state) {
                case Running:
                        running++;
                        break;
                case Ready:
                        ready++;
                        break;
                case Sleeping:
                        sleeping++;
                        break;
                case Lingering:
                        lingering++;
                        break;
                case Entering:
                case Exiting:
                        other++;
                        break;
                default:
                        invalid++;
                }
        }
        
        printf("threads: %u total, %u running, %u ready, %u sleeping, %u lingering, "
            "%u other, %u invalid",
            total, running, ready, sleeping, lingering, other, invalid);
        screen_newline();
}

static inline void print_cpu_info(data_t *data)
{
        size_t i;
        for (i = 0; i < data->cpus_count; i++) {
                if (data->cpus[i].active) {
                        printf("cpu%u (%4" PRIu16 " MHz): busy ticks: "
                            "%" PRIu64 ", idle ticks: %" PRIu64,
                            data->cpus[i].id, data->cpus[i].frequency_mhz,
                            data->cpus[i].busy_ticks, data->cpus[i].idle_ticks);
                        puts(", idle: ");
                        print_float(data->cpus_perc[i].idle, 2);
                        puts("%, busy: ");
                        print_float(data->cpus_perc[i].busy, 2);
                        puts("%");
                } else
                        printf("cpu%u inactive", data->cpus[i].id);
                
                screen_newline();
        }
}

static inline void print_physmem_info(data_t *data)
{
        uint64_t total;
        uint64_t unavail;
        uint64_t used;
        uint64_t free;
        char total_suffix;
        char unavail_suffix;
        char used_suffix;
        char free_suffix;
        
        order_suffix(data->physmem->total, &total, &total_suffix);
        order_suffix(data->physmem->unavail, &unavail, &unavail_suffix);
        order_suffix(data->physmem->used, &used, &used_suffix);
        order_suffix(data->physmem->free, &free, &free_suffix);
        
        printf("memory: %" PRIu64 "%c total, %" PRIu64 "%c unavail, %"
            PRIu64 "%c used, %" PRIu64 "%c free", total, total_suffix,
            unavail, unavail_suffix, used, used_suffix, free, free_suffix);
        screen_newline();
}

static inline void print_task_head(void)
{
        screen_style_inverted();
        printf("      ID  Threads      Mem      %%Mem %%uCycles %%kCycles  Name");
        screen_newline();
        screen_style_normal();
}

static inline void print_tasks(data_t *data)
{
        ipcarg_t cols;
        ipcarg_t rows;
        screen_get_size(&cols, &rows);
        
        ipcarg_t col;
        ipcarg_t row;
        screen_get_pos(&col, &row);
        
        size_t i;
        for (i = 0; (i < data->tasks_count) && (row < rows); i++, row++) {
                uint64_t virtmem;
                char virtmem_suffix;
                order_suffix(data->tasks[i].virtmem, &virtmem, &virtmem_suffix);
                
                printf("%8" PRIu64 " %8u %8" PRIu64 "%c ", data->tasks[i].task_id,
                    data->tasks[i].threads, virtmem, virtmem_suffix);
                puts("   ");
                print_float(data->tasks_perc[i].virtmem, 2);
                puts("%   ");
                print_float(data->tasks_perc[i].ucycles, 2);
                puts("%   ");
                print_float(data->tasks_perc[i].kcycles, 2);
                printf("%% %s", data->tasks[i].name);
                
                screen_newline();
        }
        
        while (row < rows) {
                screen_newline();
                row++;
        }
}

static inline void print_ipc_head(void)
{
        screen_style_inverted();
        printf("      ID Calls sent Calls recv Answs sent Answs recv  IRQn recv       Forw Name");
        screen_newline();
        screen_style_normal();
}

static inline void print_ipc(data_t *data)
{
        ipcarg_t cols;
        ipcarg_t rows;
        screen_get_size(&cols, &rows);
        
        ipcarg_t col;
        ipcarg_t row;
        screen_get_pos(&col, &row);
        
        size_t i;
        for (i = 0; (i < data->tasks_count) && (row < rows); i++, row++) {
                printf("%8" PRIu64 " %10" PRIu64 " %10" PRIu64 " %10" PRIu64
                     " %10" PRIu64 " %10" PRIu64 " %10" PRIu64 " %s",
                     data->tasks[i].task_id, data->tasks[i].ipc_info.call_sent,
                     data->tasks[i].ipc_info.call_recieved,
                     data->tasks[i].ipc_info.answer_sent,
                     data->tasks[i].ipc_info.answer_recieved,
                     data->tasks[i].ipc_info.irq_notif_recieved,
                     data->tasks[i].ipc_info.forwarded, data->tasks[i].name);
                
                screen_newline();
        }
        
        while (row < rows) {
                screen_newline();
                row++;
        }
}

void print_data(data_t *data)
{
        screen_restart(false);
        print_global_head(data);
        print_task_summary(data);
        print_thread_summary(data);
        print_cpu_info(data);
        print_physmem_info(data);
        
        /* Empty row for warnings */
        screen_get_pos(&warn_col, &warn_row);
        screen_newline();
        
        if (operation_type == OP_IPC) {
                print_ipc_head();
                print_ipc(data);
        } else {
                print_task_head();
                print_tasks(data);
        }
        
        fflush(stdout);
}

void print_warning(const char *fmt, ...)
{
        screen_moveto(warn_col, warn_row);
        
        va_list args;
        va_start(args, fmt);
        vprintf(fmt, args);
        va_end(args);
        
        screen_newline();
        fflush(stdout);
}

/** @}
 */