X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=fio.c;h=e5d3bbf3c204790e7f98b2b36b749f870acdac22;hb=d09a64a01a6c807596e9286c93f6c6f30fd2ea26;hp=d6802e0aea4c702cf6f591fb768ff96b49123f0d;hpb=c8eeb9df1f52f28567a5937e141decc6a26ec30b;p=fio.git diff --git a/fio.c b/fio.c index d6802e0a..e5d3bbf3 100644 --- a/fio.c +++ b/fio.c @@ -62,6 +62,13 @@ int shm_id = 0; int temp_stall_ts; unsigned long done_secs = 0; +/* + * Just expose an empty list, if the OS does not support disk util stats + */ +#ifndef FIO_HAVE_DISK_UTIL +FLIST_HEAD(disk_list); +#endif + static struct fio_mutex *startup_mutex; static struct fio_mutex *writeout_mutex; static volatile int fio_abort; @@ -77,6 +84,50 @@ struct io_log *agg_io_log[2]; #define JOB_START_TIMEOUT (5 * 1000) +static const char *fio_os_strings[os_nr] = { + "Invalid", + "Linux", + "AIX", + "FreeBSD", + "HP-UX", + "OSX", + "NetBSD", + "Solaris", + "Windows" +}; + +static const char *fio_arch_strings[arch_nr] = { + "Invalid", + "x86-64", + "x86", + "ppc", + "ia64", + "s390", + "alpha", + "sparc", + "sparc64", + "arm", + "sh", + "hppa", + "generic" +}; + +const char *fio_get_os_string(int nr) +{ + if (nr < os_nr) + return fio_os_strings[nr]; + + return NULL; +} + +const char *fio_get_arch_string(int nr) +{ + if (nr < arch_nr) + return fio_arch_strings[nr]; + + return NULL; +} + void td_set_runstate(struct thread_data *td, int runstate) { if (td->runstate == runstate) @@ -121,10 +172,14 @@ void fio_terminate_threads(int group_id) static void sig_int(int sig) { if (threads) { - log_info("\nfio: terminating on signal %d\n", sig); - exit_backend = 1; - fflush(stdout); - exit_value = 128; + if (is_backend) + fio_server_got_signal(sig); + else { + log_info("\nfio: terminating on signal %d\n", sig); + fflush(stdout); + exit_value = 128; + } + fio_terminate_threads(TERMINATE_ALL); } } @@ -139,9 +194,7 @@ static void *disk_thread_main(void *data) break; update_io_ticks(); - if (is_backend) - fio_server_send_status(); - else + if (!is_backend) print_thread_status(); } @@ -1697,8 +1750,12 @@ static void run_threads(void) reap_threads(&nr_running, &t_rate, &m_rate); - if (todo) - usleep(100000); + if (todo) { + if (is_backend) + fio_server_idle_loop(); + else + usleep(100000); + } } while (nr_running) {