X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=gettime-thread.c;h=cbb81dc83e9ff3c7f427e071161b92f016c1b9d1;hp=73632d0b35675510a9edd2a8c52cf0f15bec71e2;hb=69746cd8631060aa869799a63122defbac8a51cc;hpb=79c896a122a7a39b840257215e622bdeff8272f1 diff --git a/gettime-thread.c b/gettime-thread.c index 73632d0b..cbb81dc8 100644 --- a/gettime-thread.c +++ b/gettime-thread.c @@ -6,30 +6,30 @@ #include "fio.h" #include "smalloc.h" -struct timeval *fio_tv = NULL; +struct timespec *fio_ts = NULL; int fio_gtod_offload = 0; -static os_cpu_mask_t fio_gtod_cpumask; static pthread_t gtod_thread; +static os_cpu_mask_t fio_gtod_cpumask; void fio_gtod_init(void) { - if (fio_tv) + if (fio_ts) return; - fio_tv = smalloc(sizeof(struct timeval)); - if (!fio_tv) + fio_ts = smalloc(sizeof(*fio_ts)); + if (!fio_ts) log_err("fio: smalloc pool exhausted\n"); } static void fio_gtod_update(void) { - if (fio_tv) { + if (fio_ts) { struct timeval __tv; gettimeofday(&__tv, NULL); - fio_tv->tv_sec = __tv.tv_sec; + fio_ts->tv_sec = __tv.tv_sec; write_barrier(); - fio_tv->tv_usec = __tv.tv_usec; + fio_ts->tv_nsec = __tv.tv_usec * 1000; write_barrier(); } } @@ -71,7 +71,7 @@ int fio_start_gtod_thread(void) return 1; pthread_attr_init(&attr); - pthread_attr_setstacksize(&attr, PTHREAD_STACK_MIN); + pthread_attr_setstacksize(&attr, 2 * PTHREAD_STACK_MIN); ret = pthread_create(>od_thread, &attr, gtod_thread_main, mutex); pthread_attr_destroy(&attr); if (ret) { @@ -81,7 +81,7 @@ int fio_start_gtod_thread(void) ret = pthread_detach(gtod_thread); if (ret) { - log_err("Can't detatch gtod thread: %s\n", strerror(ret)); + log_err("Can't detach gtod thread: %s\n", strerror(ret)); goto err; } @@ -95,5 +95,7 @@ err: void fio_gtod_set_cpu(unsigned int cpu) { +#ifdef FIO_HAVE_CPU_AFFINITY fio_cpu_set(&fio_gtod_cpumask, cpu); +#endif }