statistics.h

Go to the documentation of this file.

#pragma once

#include <scheduler/process.h>

#define DEFAULT_OUTPUT_DIR "outputs"

#define MAX_PATHLEN 512

enum stat_file_unique {
    STAT_FILE_U_NODE = 0,
    STAT_FILE_U_GLOBAL,
    NUM_STAT_FILE_U
};

/* Definition of statistics file names/indices for unique files */
#define STAT_FILE_NAME_NODE     "execution_stats"
#define STAT_FILE_NAME_GLOBAL       "global_execution_stats"

enum stat_file_per_thread {
    STAT_FILE_T_THREAD = 0,
    STAT_FILE_T_GVT,
    STAT_FILE_T_LP,
    NUM_STAT_FILE_T
};

/* Definition of statistics file names/indices for per-thread files */
#define STAT_FILE_NAME_THREAD   "local_stats"
#define STAT_FILE_NAME_GVT      "gvt"
#define STAT_FILE_NAME_LP       "lps"

/* Definition of LP Statistics Post Messages */
enum stat_msg_t {
    STAT_ANTIMESSAGE = 1001,
    STAT_EVENT,
    STAT_COMMITTED,
    STAT_ROLLBACK,
    STAT_CKPT,
    STAT_CKPT_TIME,
    STAT_CKPT_MEM,
    STAT_RECOVERY,
    STAT_RECOVERY_TIME,
    STAT_EVENT_TIME,
    STAT_IDLE_CYCLES,
    STAT_SILENT,
    STAT_GVT_ROUND_TIME,
    STAT_GET_SIMTIME_ADVANCEMENT,   //xxx totally unused
    STAT_GET_EVENT_TIME_LP
};

enum stats_levels {
    STATS_INVALID = 0,  
    STATS_GLOBAL,       
    STATS_PERF,     
    STATS_LP,       
    STATS_ALL       
};

// this is used in order to have more efficient stats additions during gvt reductions
typedef double vec_double __attribute__((vector_size(16 * sizeof(double))));

// Structure to keep track of (incremental) statistics
struct stat_t {
    union {
        struct {
            double tot_antimessages,
                tot_events,
                committed_events,
                reprocessed_events,
                tot_rollbacks,
                tot_ckpts,
                ckpt_time,
                ckpt_mem,
                tot_recoveries,
                recovery_time,
                event_time,
                idle_cycles,
                memory_usage,
                simtime_advancement,
                gvt_computations, exponential_event_time;
        };
        vec_double vec;
    };
    double gvt_time,
        gvt_round_time,
        gvt_round_time_min, gvt_round_time_max, max_resident_set;
};

extern void _mkdir(const char *path);

extern void print_config(void);

extern void statistics_init(void);
extern void statistics_fini(void);

extern void statistics_start(void);
extern void statistics_stop(int exit_code);

extern inline void statistics_on_gvt(double gvt);
extern inline void statistics_on_gvt_serial(double gvt);

extern inline void statistics_post_data(struct lp_struct *, enum stat_msg_t type, double data);
extern inline void statistics_post_data_serial(enum stat_msg_t type, double data);

extern double statistics_get_lp_data(struct lp_struct *, unsigned int type);