X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=libfio.c;h=3a28f55e2139d8fac9becf617ee23de0ff0fbab8;hb=adaa73f65a8b805dced0b017984d536f215e4353;hp=9245688a029b7771c300df0c923ce680f426e04b;hpb=cba5460c70058e4612f73ded4ac960cbc6ce1a30;p=fio.git diff --git a/libfio.c b/libfio.c index 9245688a..3a28f55e 100644 --- a/libfio.c +++ b/libfio.c @@ -58,6 +58,7 @@ static const char *fio_os_strings[os_nr] = { "Solaris", "Windows", "Android", + "DragonFly", }; static const char *fio_arch_strings[arch_nr] = { @@ -87,6 +88,7 @@ static void reset_io_counters(struct thread_data *td) td->this_io_blocks[ddir] = 0; td->rate_bytes[ddir] = 0; td->rate_blocks[ddir] = 0; + td->bytes_done[ddir] = 0; } td->zone_bytes = 0; @@ -108,8 +110,10 @@ void clear_io_state(struct thread_data *td) reset_io_counters(td); close_files(td); - for_each_file(td, f, i) + for_each_file(td, f, i) { fio_file_clear_done(f); + f->file_offset = get_start_offset(td, f); + } /* * Set the same seed to get repeatable runs @@ -187,6 +191,13 @@ void td_restore_runstate(struct thread_data *td, int old_state) td_set_runstate(td, old_state); } +void fio_mark_td_terminate(struct thread_data *td) +{ + fio_gettime(&td->terminate_time, NULL); + write_barrier(); + td->terminate = 1; +} + void fio_terminate_threads(int group_id) { struct thread_data *td; @@ -203,9 +214,8 @@ void fio_terminate_threads(int group_id) if (td->terminate) continue; - td->terminate = 1; + fio_mark_td_terminate(td); td->o.start_delay = 0; - fio_gettime(&td->terminate_time, NULL); /* * if the thread is running, just let it exit @@ -291,6 +301,20 @@ int initialize_fio(char *envp[]) { long ps; + /* + * We need these to be properly 64-bit aligned, otherwise we + * can run into problems on archs that fault on unaligned fp + * access (ARM). + */ + compiletime_assert((offsetof(struct thread_stat, percentile_list) % 8) == 0, "stat percentile_list"); + compiletime_assert((offsetof(struct thread_stat, total_run_time) % 8) == 0, "total_run_time"); + compiletime_assert((offsetof(struct thread_stat, total_err_count) % 8) == 0, "total_err_count"); + compiletime_assert((offsetof(struct thread_stat, latency_percentile) % 8) == 0, "stat latency_percentile"); + compiletime_assert((offsetof(struct thread_options_pack, zipf_theta) % 8) == 0, "zipf_theta"); + compiletime_assert((offsetof(struct thread_options_pack, pareto_h) % 8) == 0, "pareto_h"); + compiletime_assert((offsetof(struct thread_options_pack, percentile_list) % 8) == 0, "percentile_list"); + compiletime_assert((offsetof(struct thread_options_pack, latency_percentile) % 8) == 0, "latency_percentile"); + if (endian_check()) { log_err("fio: endianness settings appear wrong.\n"); log_err("fio: please report this to fio@vger.kernel.org\n"); @@ -329,3 +353,8 @@ int initialize_fio(char *envp[]) fio_keywords_init(); return 0; } + +void deinitialize_fio(void) +{ + fio_keywords_exit(); +}