X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=time.c;h=5c4d6de0399c5cc681e9ca362c019870baf9db98;hb=afb34fb175d1a2de35120807feb6f5af403c581a;hp=c8876829a367ede755453f6b255b2f4139ee8a74;hpb=358ffaa6c37acb26e0f507934ba8a6f98f34ffee;p=fio.git diff --git a/time.c b/time.c index c8876829..5c4d6de0 100644 --- a/time.c +++ b/time.c @@ -57,6 +57,13 @@ uint64_t usec_sleep(struct thread_data *td, unsigned long usec) if (ts >= 1000000) { req.tv_sec = ts / 1000000; ts -= 1000000 * req.tv_sec; + /* + * Limit sleep to ~1 second at most, otherwise we + * don't notice then someone signaled the job to + * exit manually. + */ + if (req.tv_sec > 1) + req.tv_sec = 1; } else req.tv_sec = 0; @@ -118,6 +125,7 @@ bool ramp_time_over(struct thread_data *td) if (utime_since_now(&td->epoch) >= td->o.ramp_time) { td->ramp_time_over = true; reset_all_stats(td); + reset_io_stats(td); td_set_runstate(td, TD_RAMP); /* @@ -164,14 +172,14 @@ void set_genesis_time(void) fio_gettime(&genesis, NULL); } -void set_epoch_time(struct thread_data *td, int log_unix_epoch) +void set_epoch_time(struct thread_data *td, int log_alternate_epoch, clockid_t clock_id) { fio_gettime(&td->epoch, NULL); - if (log_unix_epoch) { - struct timeval tv; - gettimeofday(&tv, NULL); - td->unix_epoch = (unsigned long long)(tv.tv_sec) * 1000 + - (unsigned long long)(tv.tv_usec) / 1000; + if (log_alternate_epoch) { + struct timespec ts; + clock_gettime(clock_id, &ts); + td->alternate_epoch = (unsigned long long)(ts.tv_sec) * 1000 + + (unsigned long long)(ts.tv_nsec) / 1000000; } }