static volatile int startup_sem;
static volatile int fio_abort;
+static int exit_value;
struct io_log *agg_io_log[2];
td_set_runstate(td, TD_RUNNING);
- while (td->this_io_bytes[td->ddir] < td->io_size) {
+ while ((td->this_io_bytes[0] + td->this_io_bytes[1]) < td->io_size) {
struct timespec *timeout;
int min_evts = 0;
struct io_u *io_u;
continue;
}
+ if (td->error)
+ exit_value++;
+
td_set_runstate(td, TD_REAPED);
if (td->use_thread) {
}
}
- return 0;
+ return exit_value;
}