X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=iolog.h;h=0d6b5062999c40480cc1b50de805930b8a14461e;hp=d8140f28c2f8a59de00bc32731edefc7d720cf97;hb=d0db819d9c5abe904f85a3b21a95023fef007f20;hpb=c8eeb9df1f52f28567a5937e141decc6a26ec30b diff --git a/iolog.h b/iolog.h index d8140f28..0d6b5062 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[2]; + unsigned long avg_msec; + unsigned long avg_last; }; enum { @@ -94,11 +117,10 @@ extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long, extern void add_bw_sample(struct thread_data *, enum fio_ddir, unsigned int, struct timeval *); extern void add_iops_sample(struct thread_data *, enum fio_ddir, struct timeval *); -extern void show_run_stats(void); 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 *);