dst = get_sample(iolog, cur_log, i);
memcpy(dst, src, log_entry_sz(iolog));
}
dst = get_sample(iolog, cur_log, i);
memcpy(dst, src, log_entry_sz(iolog));
}
__add_stat_to_log(iolog, ddir, elapsed, log_max);
}
__add_stat_to_log(iolog, ddir, elapsed, log_max);
}
unsigned long val, enum fio_ddir ddir,
unsigned int bs, uint64_t offset)
{
unsigned long elapsed, this_window;
if (!ddir_rw(ddir))
unsigned long val, enum fio_ddir ddir,
unsigned int bs, uint64_t offset)
{
unsigned long elapsed, this_window;
if (!ddir_rw(ddir))
*/
if (!iolog->avg_msec) {
__add_log_sample(iolog, val, ddir, bs, elapsed, offset);
*/
if (!iolog->avg_msec) {
__add_log_sample(iolog, val, ddir, bs, elapsed, offset);
struct thread_stat *ts = &td->ts;
unsigned long spent, rate;
enum fio_ddir ddir;
struct thread_stat *ts = &td->ts;
unsigned long spent, rate;
enum fio_ddir ddir;
spent = mtime_since(&td->bw_sample_time, t);
if (spent < td->o.bw_avg_time &&
spent = mtime_since(&td->bw_sample_time, t);
if (spent < td->o.bw_avg_time &&
- add_log_sample(td, td->bw_log, rate, ddir, bs, 0);
+ next = add_log_sample(td, td->bw_log, rate, ddir, bs, 0);
+ next_log = min(next_log, next);
struct thread_stat *ts = &td->ts;
unsigned long spent, iops;
enum fio_ddir ddir;
struct thread_stat *ts = &td->ts;
unsigned long spent, iops;
enum fio_ddir ddir;
spent = mtime_since(&td->iops_sample_time, t);
if (spent < td->o.iops_avg_time &&
spent = mtime_since(&td->iops_sample_time, t);
if (spent < td->o.iops_avg_time &&
- add_log_sample(td, td->iops_log, iops, ddir, bs, 0);
+ next = add_log_sample(td, td->iops_log, iops, ddir, bs, 0);
+ next_log = min(next_log, next);