X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=iolog.h;h=4ad4e79ebf2c66ee79597e42fc1d0411ccaf3332;hp=a523d4d22767ec8cd80cd022d9ba96dad3e4c012;hb=b999b3c74daa2dedd398544e898b54d8b221314c;hpb=fddc6604f91ebf76d9090741f9d4f5a4d33be0c6 diff --git a/iolog.h b/iolog.h index a523d4d2..4ad4e79e 100644 --- a/iolog.h +++ b/iolog.h @@ -1,7 +1,9 @@ #ifndef FIO_IOLOG_H #define FIO_IOLOG_H -#include "ieee754.h" +#include "lib/rbtree.h" +#include "lib/ieee754.h" +#include "ioengine.h" /* * Use for maintaining statistics @@ -19,19 +21,40 @@ struct io_stat { * A single data sample */ struct io_sample { - unsigned long time; - unsigned long val; - enum fio_ddir ddir; - unsigned int bs; + uint64_t time; + uint64_t val; + uint32_t ddir; + uint32_t bs; +}; + +enum { + IO_LOG_TYPE_LAT = 1, + IO_LOG_TYPE_CLAT, + IO_LOG_TYPE_SLAT, + IO_LOG_TYPE_BW, + IO_LOG_TYPE_IOPS, }; /* * Dynamically growing data sample log */ struct io_log { + /* + * Entries already logged + */ unsigned long nr_samples; unsigned long max_samples; struct io_sample *log; + + unsigned int log_type; + + /* + * Windowed average, for logging single entries average over some + * period of time. + */ + struct io_stat avg_window[DDIR_RWDIR_CNT]; + unsigned long avg_msec; + unsigned long avg_last; }; enum { @@ -96,12 +119,11 @@ extern void add_bw_sample(struct thread_data *, enum fio_ddir, unsigned int, extern void add_iops_sample(struct thread_data *, enum fio_ddir, struct timeval *); extern void init_disk_util(struct thread_data *); extern void update_rusage_stat(struct thread_data *); -extern void update_io_ticks(void); -extern void setup_log(struct io_log **); +extern void setup_log(struct io_log **, unsigned long, int); extern void finish_log(struct thread_data *, struct io_log *, const char *); extern void finish_log_named(struct thread_data *, struct io_log *, const char *, const char *); extern void __finish_log(struct io_log *, const char *); -extern struct io_log *agg_io_log[2]; +extern struct io_log *agg_io_log[DDIR_RWDIR_CNT]; extern int write_bw_log; extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int);