X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=stat.h;h=3f68305adb2841c3aac8f98de942be94b8e23d5b;hb=a48fddbcb33991f9b2d1be1fa0a5e5cfb9ea9fae;hp=0125f5762329f6887ad527382139e68e40c800ee;hpb=714e85f340194409d0abcf643cd2f154a7380a74;p=fio.git diff --git a/stat.h b/stat.h index 0125f576..3f68305a 100644 --- a/stat.h +++ b/stat.h @@ -114,6 +114,7 @@ struct group_run_stats { #define MAX_PATTERN_SIZE 512 #define FIO_JOBNAME_SIZE 128 +#define FIO_JOBDESC_SIZE 256 #define FIO_VERROR_SIZE 128 struct thread_stat { @@ -123,7 +124,7 @@ struct thread_stat { uint32_t thread_number; uint32_t groupid; uint32_t pid; - char description[FIO_JOBNAME_SIZE]; + char description[FIO_JOBDESC_SIZE]; uint32_t members; uint32_t unified_rw_rep; @@ -175,6 +176,11 @@ struct thread_stat { uint32_t kb_base; uint32_t unit_base; + + uint32_t latency_depth; + uint64_t latency_target; + fio_fp64_t latency_percentile; + uint64_t latency_window; }; struct jobs_eta { @@ -199,12 +205,16 @@ struct jobs_eta { uint8_t run_str[]; }; -extern void show_thread_status(struct thread_stat *ts, struct group_run_stats *rs); +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 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); extern void show_running_run_stats(void); +extern void check_for_running_stats(void); extern void sum_thread_stats(struct thread_stat *dst, struct thread_stat *src, int nr); extern void sum_group_stats(struct group_run_stats *dst, struct group_run_stats *src); extern void init_thread_stat(struct thread_stat *ts); @@ -215,6 +225,7 @@ extern unsigned int calc_clat_percentiles(unsigned int *io_u_plat, unsigned long 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 *); static inline int usec_to_msec(unsigned long *min, unsigned long *max, double *mean, double *dev)