static int get_next_rand_offset(struct thread_data *td, struct fio_file *f,
enum fio_ddir ddir, unsigned long long *b)
{
- unsigned long long r, lastb;
+ unsigned long long rmax, r, lastb;
int loops = 5;
lastb = last_block(td, f, ddir);
if (f->failed_rands >= 200)
goto ffz;
+ rmax = td->o.use_os_rand ? OS_RAND_MAX : FRAND_MAX;
do {
- if (td->o.use_os_rand) {
+ if (td->o.use_os_rand)
r = os_random_long(&td->random_state);
- *b = (lastb - 1) * (r / ((unsigned long long) OS_RAND_MAX + 1.0));
- } else {
+ else
r = __rand(&td->__random_state);
- *b = (lastb - 1) * (r / ((unsigned long long) FRAND_MAX + 1.0));
- }
+
+ *b = (lastb - 1) * (r / ((unsigned long long) rmax + 1.0));
dprint(FD_RANDOM, "off rand %llu\n", r);
loops = 10;
do {
f->last_free_lookup = (f->num_maps - 1) *
- (r / (OS_RAND_MAX + 1.0));
+ (r / ((unsigned long long) rmax + 1.0));
if (!get_next_free_block(td, f, ddir, b))
goto ret;
if (!td->o.disable_bw)
add_bw_sample(td, idx, bytes, &icd->time);
+
+ add_iops_sample(td, idx, &icd->time);
}
static void io_completed(struct thread_data *td, struct io_u *io_u,
int ret;
td->io_blocks[idx]++;
+ td->this_io_blocks[idx]++;
td->io_bytes[idx] += bytes;
td->this_io_bytes[idx] += bytes;
}
}
- if (ramp_time_over(td)) {
+ if (ramp_time_over(td) && td->runstate == TD_RUNNING) {
account_io_completion(td, io_u, icd, idx, bytes);
if (__should_check_rate(td, idx)) {