X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=stat.h;h=0fc5533fd20529efbd65b3cc47e1bf5b8e84c094;hp=e87dae08fe1ee2f4ea3e0a215356ee5ef5c05fc7;hb=b9c8a72a5795a58bd6bf060a79393e835db57a95;hpb=36870c47801ca85d1a98c7ec47950b0aa360f865 diff --git a/stat.h b/stat.h index e87dae08..0fc5533f 100644 --- a/stat.h +++ b/stat.h @@ -2,6 +2,7 @@ #define FIO_STAT_H #include "iolog.h" +#include "lib/output_buffer.h" struct group_run_stats { uint64_t max_run[DDIR_RWDIR_CNT], min_run[DDIR_RWDIR_CNT]; @@ -182,9 +183,9 @@ struct thread_stat { uint32_t io_u_plat[DDIR_RWDIR_CNT][FIO_IO_U_PLAT_NR]; uint32_t pad; - uint64_t total_io_u[3]; - uint64_t short_io_u[3]; - uint64_t drop_io_u[3]; + uint64_t total_io_u[DDIR_RWDIR_CNT]; + uint64_t short_io_u[DDIR_RWDIR_CNT]; + uint64_t drop_io_u[DDIR_RWDIR_CNT]; uint64_t total_submit; uint64_t total_complete; @@ -246,8 +247,8 @@ extern struct jobs_eta *get_jobs_eta(int force, size_t *size); extern void stat_init(void); extern void stat_exit(void); -extern struct json_object * show_thread_status(struct thread_stat *ts, struct group_run_stats *rs); -extern void show_group_stats(struct group_run_stats *rs); +extern struct json_object * show_thread_status(struct thread_stat *ts, struct group_run_stats *rs, struct buf_output *); +extern void show_group_stats(struct group_run_stats *rs, struct buf_output *); extern int calc_thread_status(struct jobs_eta *je, int force); extern void display_thread_status(struct jobs_eta *je); extern void show_run_stats(void); @@ -266,6 +267,23 @@ extern void stat_calc_lat_m(struct thread_stat *ts, double *io_u_lat); extern void stat_calc_lat_u(struct thread_stat *ts, double *io_u_lat); extern void stat_calc_dist(unsigned int *map, unsigned long total, double *io_u_dist); extern void reset_io_stats(struct thread_data *); +extern void update_rusage_stat(struct thread_data *); +extern void clear_rusage_stat(struct thread_data *); + +extern void add_lat_sample(struct thread_data *, enum fio_ddir, unsigned long, + unsigned int, uint64_t); +extern void add_clat_sample(struct thread_data *, enum fio_ddir, unsigned long, + unsigned int, uint64_t); +extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long, + unsigned int, uint64_t); +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, unsigned int, + struct timeval *); +extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int); + +extern struct io_log *agg_io_log[DDIR_RWDIR_CNT]; +extern int write_bw_log; static inline int usec_to_msec(unsigned long *min, unsigned long *max, double *mean, double *dev)