Calloc() cleanup
[fio.git] / gettime-thread.c
1 #include <unistd.h>
2 #include <math.h>
3 #include <sys/time.h>
4 #include <time.h>
5
6 #include "fio.h"
7 #include "smalloc.h"
8
9 struct timeval *fio_tv = NULL;
10 int fio_gtod_offload = 0;
11 int fio_gtod_cpu = -1;
12 static pthread_t gtod_thread;
13
14 void fio_gtod_init(void)
15 {
16         fio_tv = smalloc(sizeof(struct timeval));
17         if (!fio_tv)
18                 log_err("fio: smalloc pool exhausted\n");
19 }
20
21 static void fio_gtod_update(void)
22 {
23         if (fio_tv)
24                 gettimeofday(fio_tv, NULL);
25 }
26
27 static void *gtod_thread_main(void *data)
28 {
29         struct fio_mutex *mutex = data;
30
31         fio_mutex_up(mutex);
32
33         /*
34          * As long as we have jobs around, update the clock. It would be nice
35          * to have some way of NOT hammering that CPU with gettimeofday(),
36          * but I'm not sure what to use outside of a simple CPU nop to relax
37          * it - we don't want to lose precision.
38          */
39         while (threads) {
40                 fio_gtod_update();
41                 nop;
42         }
43
44         return NULL;
45 }
46
47 int fio_start_gtod_thread(void)
48 {
49         struct fio_mutex *mutex;
50         pthread_attr_t attr;
51         int ret;
52
53         mutex = fio_mutex_init(FIO_MUTEX_LOCKED);
54         if (!mutex)
55                 return 1;
56
57         pthread_attr_init(&attr);
58         pthread_attr_setstacksize(&attr, PTHREAD_STACK_MIN);
59         ret = pthread_create(&gtod_thread, &attr, gtod_thread_main, NULL);
60         pthread_attr_destroy(&attr);
61         if (ret) {
62                 log_err("Can't create gtod thread: %s\n", strerror(ret));
63                 goto err;
64         }
65
66         ret = pthread_detach(gtod_thread);
67         if (ret) {
68                 log_err("Can't detatch gtod thread: %s\n", strerror(ret));
69                 goto err;
70         }
71
72         dprint(FD_MUTEX, "wait on startup_mutex\n");
73         fio_mutex_down(mutex);
74         dprint(FD_MUTEX, "done waiting on startup_mutex\n");
75 err:
76         fio_mutex_remove(mutex);
77         return ret;
78 }
79
80