X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=iolog.h;h=de641d54e191979595a9dbfaf142168e2c5dce69;hp=ade4f1b80b379fe163ab085c3795b0fe1e30416a;hb=90eff1c9f01d2f8b4ff8bc75a2bf120a1789b37c;hpb=65a4d15c132de669223445791b141eb90267f761 diff --git a/iolog.h b/iolog.h index ade4f1b8..de641d54 100644 --- a/iolog.h +++ b/iolog.h @@ -18,14 +18,10 @@ struct io_stat { fio_fp64_t S; }; -struct io_u_plat_list { - struct flist_head list; -}; - struct io_hist { uint64_t samples; unsigned long hist_last; - struct io_u_plat_list list; + struct flist_head list; }; /* @@ -33,7 +29,10 @@ struct io_hist { */ struct io_sample { uint64_t time; - uint64_t val; + union { + uint64_t val; + struct io_u_plat_entry *plat_entry; + }; uint32_t __ddir; uint32_t bs; }; @@ -114,13 +113,14 @@ struct io_log { unsigned long avg_msec; unsigned long avg_last; - /* - * Windowed latency histograms, for keeping track of when we need to - * save a copy of the histogram every approximately hist_msec milliseconds. - */ + /* + * Windowed latency histograms, for keeping track of when we need to + * save a copy of the histogram every approximately hist_msec + * milliseconds. + */ struct io_hist hist_window[DDIR_RWDIR_CNT]; unsigned long hist_msec; - int hist_coarseness; + unsigned int hist_coarseness; pthread_mutex_t chunk_lock; unsigned int chunk_seq; @@ -153,6 +153,11 @@ static inline size_t log_entry_sz(struct io_log *log) return __log_entry_sz(log->log_offset); } +static inline size_t log_sample_sz(struct io_log *log, struct io_logs *cur_log) +{ + return cur_log->nr_samples * log_entry_sz(log); +} + static inline struct io_sample *__get_sample(void *samples, int log_offset, uint64_t sample) { @@ -262,6 +267,7 @@ extern void finalize_logs(struct thread_data *td, bool); extern void setup_log(struct io_log **, struct log_params *, const char *); extern void flush_log(struct io_log *, bool); extern void flush_samples(FILE *, void *, uint64_t); +extern unsigned long hist_sum(int, int, unsigned int *, unsigned int *); extern void free_log(struct io_log *); extern void fio_writeout_logs(bool); extern void td_writeout_logs(struct thread_data *, bool);