task_monitor.h

// ---------------------------------------------
//           This file is part of
//      _  _   __    _   _    __    __
//     ( \/ ) /__\  ( )_( )  /__\  (  )
//      \  / /(__)\  ) _ (  /(__)\  )(__
//      (__)(__)(__)(_) (_)(__)(__)(____)
//
//     Yet Another HW Abstraction Library
//      Copyright (C) Andreas Terstegge
//      BSD Licensed (see file LICENSE)
//
// ---------------------------------------------
//
// A task monitor which prints a task table to
// stdout.
//
#ifndef _TASK_MONITOR_H
#define _TASK_MONITOR_H
 
#include <cstdio>
#include "yahal_config.h"
#include "task.h"
#include "task_timer.h"
#include "malloc.h"
 
#define MONITOR_WAIT 5  // in seconds !!
 
#define CLEAR_SCREEN "%c[H%c[J",27,27
#define VT100_COLOR  "%c[%dm",27
#define BLACK 30
#define RED 31
#define GREEN 32
#define YELLOW 33
#define BLUE 34
#define MAGENTA 35
#define CYAN 36
#define WHITE 37
 
extern uint32_t __data_start__;
extern uint32_t __data_end__;
extern uint32_t __bss_start__;
extern uint32_t __bss_end__;
 
class task_monitor : public task_timer
{
public:
    task_monitor() : task_timer("Monitor", DEFAULT_STACK_SIZE) {
        setPeriod(MONITOR_WAIT * 1000000, TIMER::PERIODIC);
        setCallback([this]() {
            task * p = _list[_core].getHead();
            uint32_t millis  = task::millis();
            printf(CLEAR_SCREEN);
            printf(VT100_COLOR, BLUE);
            printf("\n    ---< YAHAL Task Monitor (core:%d uptime: %ldh %ldm %ld.%03lds) >--- \n\n",
                   _core,
                    millis/3600000,
                   (millis/60000) % 60,
                   (millis/1000)  % 60,
                    millis%1000);
            printf(VT100_COLOR, BLACK);
 
            auto data_size = (uint32_t)(&__data_end__) - (uint32_t)(&__data_start__);
            auto bss_size  = (uint32_t)(&__bss_end__)  - (uint32_t)(&__bss_start__);
            uint32_t heap_used  = mallinfo().uordblks;
            printf("   RAM usage: data:%ld, bss:%ld, heap:%ld, total:%ld bytes\n",
                   data_size, bss_size, heap_used, data_size + bss_size + heap_used);
 
            puts("+------------------+-----+------+-----------+-------------+--------+");
            puts("| Task Name        | Flg | Prio | State     | Stack usage |  CPU % |");
            puts("+------------------+-----+------+-----------+-------------+--------+");
            do {
                uint32_t t = p->getDeltaTicks();
                printf("| %-16s | %c/%c | %4d | %-9s | %4d / %4d |%3ld.%1ld %% |\n",
                       p->getName(),
                       p->isPrivileged() ? 'P' : 'U', p->isUsingFloat() ? 'F' : 'I',
                       p->getPriority(),
                       state_to_str(p->getState()),
                       p->getUsedStack(), p->getStackSize(),
                        t * 100  / MONITOR_WAIT / TICK_FREQUENCY,
                       (t * 1000 / MONITOR_WAIT / TICK_FREQUENCY) % 10
                );
                p = p->_next;
            } while(p != _list[_core].getHead());
            puts("+------------------+-----+------+-----------+-------------+--------+");
        });
        start();
    }
 
    ~task_monitor() override = default;
 
    // No copy, no assignment
    task_monitor             (const task_monitor &) = delete;
    task_monitor & operator= (const task_monitor &) = delete;
};
 
#endif // _TASK_MONITOR_H