iolog.h

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