iolog.h

   1 #ifndef FIO_IOLOG_H
   2 #define FIO_IOLOG_H
   3
   4 #include "lib/rbtree.h"
   5 #include "lib/ieee754.h"
   6
   7 /*
   8  * Use for maintaining statistics
   9  */
  10 struct io_stat {
  11         uint64_t max_val;
  12         uint64_t min_val;
  13         uint64_t samples;
  14
  15         fio_fp64_t mean;
  16         fio_fp64_t S;
  17 };
  18
  19 /*
  20  * A single data sample
  21  */
  22 struct io_sample {
  23         uint64_t time;
  24         uint64_t val;
  25         uint32_t ddir;
  26         uint32_t bs;
  27 };
  28
  29 enum {
  30         IO_LOG_TYPE_LAT = 1,
  31         IO_LOG_TYPE_CLAT,
  32         IO_LOG_TYPE_SLAT,
  33         IO_LOG_TYPE_BW,
  34         IO_LOG_TYPE_IOPS,
  35 };
  36
  37 /*
  38  * Dynamically growing data sample log
  39  */
  40 struct io_log {
  41         /*
  42          * Entries already logged
  43          */
  44         unsigned long nr_samples;
  45         unsigned long max_samples;
  46         struct io_sample *log;
  47
  48         unsigned int log_type;
  49
  50         /*
  51          * Windowed average, for logging single entries average over some
  52          * period of time.
  53          */
  54         struct io_stat avg_window[DDIR_RWDIR_CNT];
  55         unsigned long avg_msec;
  56         unsigned long avg_last;
  57 };
  58
  59 enum {
  60         IP_F_ONRB       = 1,
  61         IP_F_ONLIST     = 2,
  62         IP_F_TRIMMED    = 4,
  63 };
  64
  65 /*
  66  * When logging io actions, this matches a single sent io_u
  67  */
  68 struct io_piece {
  69         union {
  70                 struct rb_node rb_node;
  71                 struct flist_head list;
  72         };
  73         struct flist_head trim_list;
  74         union {
  75                 int fileno;
  76                 struct fio_file *file;
  77         };
  78         unsigned long long offset;
  79         unsigned long len;
  80         unsigned int flags;
  81         enum fio_ddir ddir;
  82         union {
  83                 unsigned long delay;
  84                 unsigned int file_action;
  85         };
  86 };
  87
  88 /*
  89  * Log exports
  90  */
  91 enum file_log_act {
  92         FIO_LOG_ADD_FILE,
  93         FIO_LOG_OPEN_FILE,
  94         FIO_LOG_CLOSE_FILE,
  95         FIO_LOG_UNLINK_FILE,
  96 };
  97
  98 struct io_u;
  99 extern int __must_check read_iolog_get(struct thread_data *, struct io_u *);
 100 extern void log_io_u(struct thread_data *, struct io_u *);
 101 extern void log_file(struct thread_data *, struct fio_file *, enum file_log_act);
 102 extern int __must_check init_iolog(struct thread_data *td);
 103 extern void log_io_piece(struct thread_data *, struct io_u *);
 104 extern void queue_io_piece(struct thread_data *, struct io_piece *);
 105 extern void prune_io_piece_log(struct thread_data *);
 106 extern void write_iolog_close(struct thread_data *);
 107
 108 /*
 109  * Logging
 110  */
 111 extern void add_lat_sample(struct thread_data *, enum fio_ddir, unsigned long,
 112                                 unsigned int);
 113 extern void add_clat_sample(struct thread_data *, enum fio_ddir, unsigned long,
 114                                 unsigned int);
 115 extern void add_slat_sample(struct thread_data *, enum fio_ddir, unsigned long,
 116                                 unsigned int);
 117 extern void add_bw_sample(struct thread_data *, enum fio_ddir, unsigned int,
 118                                 struct timeval *);
 119 extern void add_iops_sample(struct thread_data *, enum fio_ddir, struct timeval *);
 120 extern void init_disk_util(struct thread_data *);
 121 extern void update_rusage_stat(struct thread_data *);
 122 extern void setup_log(struct io_log **, unsigned long, int);
 123 extern void finish_log(struct thread_data *, struct io_log *, const char *);
 124 extern void finish_log_named(struct thread_data *, struct io_log *, const char *, const char *);
 125 extern void __finish_log(struct io_log *, const char *);
 126 extern struct io_log *agg_io_log[DDIR_RWDIR_CNT];
 127 extern int write_bw_log;
 128 extern void add_agg_sample(unsigned long, enum fio_ddir, unsigned int);
 129
 130 static inline void init_ipo(struct io_piece *ipo)
 131 {
 132         memset(ipo, 0, sizeof(*ipo));
 133         INIT_FLIST_HEAD(&ipo->trim_list);
 134 }
 135
 136 #endif