rate = (td->this_io_bytes[ddir] - td->rate_bytes) / spent;
if (rate < td->ratemin) {
- fprintf(f_out, "%s: min rate %d not met, got %ldKiB/sec\n", td->name, td->ratemin, rate);
+ fprintf(f_out, "%s: min rate %u not met, got %luKiB/sec\n", td->name, td->ratemin, rate);
return 1;
}
}
* The main verify engine. Runs over the writes we previusly submitted,
* reads the blocks back in, and checks the crc/md5 of the data.
*/
-void do_verify(struct thread_data *td)
+static void do_verify(struct thread_data *td)
{
struct io_u *io_u, *v_io_u = NULL;
struct io_completion_data icd;
max_units = td->iodepth;
max_bs = max(td->max_bs[DDIR_READ], td->max_bs[DDIR_WRITE]);
- td->orig_buffer_size = max_bs * max_units + MASK;
+ td->orig_buffer_size = max_bs * max_units;
+
+ if (td->mem_type == MEM_SHMHUGE)
+ td->orig_buffer_size = (td->orig_buffer_size + FIO_HUGE_PAGE - 1) & ~FIO_HUGE_PAGE;
+ else
+ td->orig_buffer_size += MASK;
if (allocate_io_mem(td))
return 1;
system(td->exec_prerun);
fio_gettime(&td->epoch, NULL);
+ getrusage(RUSAGE_SELF, &td->ru_start);
runtime[0] = runtime[1] = 0;
while (td->loops--) {
- getrusage(RUSAGE_SELF, &td->ru_start);
fio_gettime(&td->start, NULL);
memcpy(&td->stat_sample_time, &td->start, sizeof(td->start));
if (td_rw(td) && td->io_bytes[td->ddir ^ 1])
runtime[td->ddir ^ 1] = runtime[td->ddir];
- update_rusage_stat(td);
-
if (td->error || td->terminate)
break;
break;
}
+ update_rusage_stat(td);
fio_gettime(&td->end_time, NULL);
td->runtime[0] = runtime[0] / 1000;
td->runtime[1] = runtime[1] / 1000;