Lines Matching refs:iolog
1564 static void __add_log_sample(struct io_log *iolog, unsigned long val,
1568 const int nr_samples = iolog->nr_samples;
1570 if (iolog->disabled)
1573 if (!iolog->nr_samples)
1574 iolog->avg_last = t;
1576 if (iolog->nr_samples == iolog->max_samples) {
1577 int new_size = sizeof(struct io_sample) * iolog->max_samples*2;
1580 new_log = realloc(iolog->log, new_size);
1582 log_err("fio: failed extending iolog! Will stop logging.\n");
1583 iolog->disabled = 1;
1586 iolog->log = new_log;
1587 iolog->max_samples <<= 1;
1590 iolog->log[nr_samples].val = val;
1591 iolog->log[nr_samples].time = t;
1592 iolog->log[nr_samples].ddir = ddir;
1593 iolog->log[nr_samples].bs = bs;
1594 iolog->nr_samples++;
1638 static void _add_stat_to_log(struct io_log *iolog, unsigned long elapsed)
1645 if (iolog->avg_window[DDIR_READ].samples) {
1648 mr = iolog->avg_window[DDIR_READ].mean.u.f + 0.50;
1649 __add_log_sample(iolog, mr, DDIR_READ, 0, elapsed);
1651 if (iolog->avg_window[DDIR_WRITE].samples) {
1654 mw = iolog->avg_window[DDIR_WRITE].mean.u.f + 0.50;
1655 __add_log_sample(iolog, mw, DDIR_WRITE, 0, elapsed);
1657 if (iolog->avg_window[DDIR_TRIM].samples) {
1660 mw = iolog->avg_window[DDIR_TRIM].mean.u.f + 0.50;
1661 __add_log_sample(iolog, mw, DDIR_TRIM, 0, elapsed);
1664 reset_io_stat(&iolog->avg_window[DDIR_READ]);
1665 reset_io_stat(&iolog->avg_window[DDIR_WRITE]);
1666 reset_io_stat(&iolog->avg_window[DDIR_TRIM]);
1669 static void add_log_sample(struct thread_data *td, struct io_log *iolog,
1683 if (!iolog->avg_msec) {
1684 __add_log_sample(iolog, val, ddir, bs, elapsed);
1692 add_stat_sample(&iolog->avg_window[ddir], val);
1698 this_window = elapsed - iolog->avg_last;
1699 if (this_window < iolog->avg_msec)
1702 _add_stat_to_log(iolog, elapsed);
1704 iolog->avg_last = elapsed;
1727 struct io_log *iolog;
1732 iolog = agg_io_log[ddir];
1733 __add_log_sample(iolog, val, ddir, bs, mtime_since_genesis());
