stats.h

Go to the documentation of this file.

/*
START OF LICENSE STUB
    DeDOS: Declarative Dispersion-Oriented Software
    Copyright (C) 2017 University of Pennsylvania, Georgetown University

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
END OF LICENSE STUB
*/
#ifndef STATS_H_
#define STATS_H_
#include "unused_def.h"
#include "stat_ids.h"

#include <time.h>
#include <stdlib.h>

struct timed_stat {
    struct timespec time;
    long double value;
};

struct stat_sample_hdr {
    enum stat_id stat_id;
    unsigned int item_id;
    int n_stats;
};

struct stat_sample {
    struct stat_sample_hdr hdr;
    int max_stats;
    struct timed_stat *stats;
};

struct stat_type_label {
    enum stat_id id;
    char *name;
};

#ifndef REPORTED_MSU_STAT_TYPES
#define REPORTED_MSU_STAT_TYPES \
    {MSU_QUEUE_LEN, "QUEUE_LEN"}, \
    {MSU_ITEMS_PROCESSED, "ITEMS_PROCESSED"}, \
    {MSU_MEM_ALLOC, "MEMORY_ALLOCATED"}, \
    {MSU_NUM_STATES, "NUM_STATES"}, \
    {MSU_EXEC_TIME, "EXEC_TIME"}, \
    {MSU_IDLE_TIME, "IDLE_TIME"}, \
    {MSU_ERROR_CNT, "ERROR_COUNT"}, \
    {MSU_UCPUTIME, "MSU_USER_TIME"}, \
    {MSU_SCPUTIME, "MSU_KERNEL_TIME"}, \
    {MSU_MINFLT, "MSU_MINOR_FAULTS"}, \
    {MSU_MAJFLT, "MSU_MAJOR_FAULTS"}, \
    {MSU_VCSW, "MSU_VOL_CTX_SW"}, \
    {MSU_IVCSW, "MSU_INVOL_CTX_SW"}
#endif

#ifndef REPORTED_THREAD_STAT_TYPES
#define REPORTED_THREAD_STAT_TYPES \
    {THREAD_UCPUTIME, "USER_TIME"}, \
    {THREAD_SCPUTIME, "KERNAL_TIME"}, \
    {THREAD_MAXRSS, "MAX_RSS"}, \
    {THREAD_MINFLT, "MINOR_FAULTS"}, \
    {THREAD_MAJFLT, "MAJOR_FAULTS"}, \
    {THREAD_VCSW, "VOL_CTX_SW"}, \
    {THREAD_IVCSW, "INVOL_CTX_SW"}
#endif

#ifndef REPORTED_STAT_TYPES
#define REPORTED_STAT_TYPES \
    REPORTED_MSU_STAT_TYPES, \
    REPORTED_THREAD_STAT_TYPES
#endif

int is_thread_stat(enum stat_id id);
int is_msu_stat(enum stat_id id);

static struct stat_type_label UNUSED reported_stat_types[] = {
    REPORTED_STAT_TYPES
};
#define N_REPORTED_STAT_TYPES sizeof(reported_stat_types) / sizeof(*reported_stat_types)

static struct stat_type_label UNUSED reported_msu_stat_types[] = {
    REPORTED_MSU_STAT_TYPES
};
#define N_REPORTED_MSU_STAT_TYPES \
    sizeof(reported_msu_stat_types) / sizeof(*reported_msu_stat_types)

static struct stat_type_label UNUSED reported_thread_stat_types[] = {
    REPORTED_THREAD_STAT_TYPES
};
#define N_REPORTED_THREAD_STAT_TYPES \
    sizeof(reported_thread_stat_types) / sizeof(*reported_thread_stat_types)



#define MAX_STAT_ITEM_ID 4192

#define STAT_SAMPLE_SIZE 5

#define STAT_SAMPLE_PERIOD_MS 500

void free_stat_samples(struct stat_sample *samples, int n_samples);

struct stat_sample *init_stat_samples(int max_stats, int n_samples);

int deserialize_stat_samples(void *buffer, size_t buff_len, struct stat_sample *samples,
                             int n_samples);

ssize_t serialize_stat_samples(struct stat_sample *samples, int n_samples,
                               void *buffer, size_t buff_len);

size_t serialized_stat_sample_size(struct stat_sample *sample, int n_samples);
#endif