- pthread_attr_init(&attr);
- pthread_attr_setstacksize(&attr, PTHREAD_STACK_MIN);
- ret = pthread_create(>od_thread, &attr, gtod_thread_main, NULL);
- pthread_attr_destroy(&attr);
- if (ret) {
- log_err("Can't create gtod thread: %s\n", strerror(ret));
- goto err;
+ return c1->seq - c2->seq;
+}
+
+int fio_monotonic_clocktest(int debug)
+{
+ struct clock_thread *cthreads;
+ unsigned int nr_cpus = cpus_online();
+ struct clock_entry *entries;
+ unsigned long nr_entries, tentries, failed = 0;
+ struct clock_entry *prev, *this;
+ uint32_t seq = 0;
+ unsigned int i;
+
+ if (debug) {
+ log_info("cs: reliable_tsc: %s\n", tsc_reliable ? "yes" : "no");
+
+#ifdef FIO_INC_DEBUG
+ fio_debug |= 1U << FD_TIME;
+#endif
+ nr_entries = CLOCK_ENTRIES_DEBUG;
+ } else
+ nr_entries = CLOCK_ENTRIES_TEST;
+
+ calibrate_cpu_clock();
+
+ if (debug) {
+#ifdef FIO_INC_DEBUG
+ fio_debug &= ~(1U << FD_TIME);
+#endif
+ }
+
+ cthreads = malloc(nr_cpus * sizeof(struct clock_thread));
+ tentries = nr_entries * nr_cpus;
+ entries = malloc(tentries * sizeof(struct clock_entry));
+
+ if (debug)
+ log_info("cs: Testing %u CPUs\n", nr_cpus);
+
+ for (i = 0; i < nr_cpus; i++) {
+ struct clock_thread *t = &cthreads[i];
+
+ t->cpu = i;
+ t->debug = debug;
+ t->seq = &seq;
+ t->nr_entries = nr_entries;
+ t->entries = &entries[i * nr_entries];
+ pthread_mutex_init(&t->lock, NULL);
+ pthread_mutex_init(&t->started, NULL);
+ pthread_mutex_lock(&t->lock);
+ if (pthread_create(&t->thread, NULL, clock_thread_fn, t)) {
+ failed++;
+ nr_cpus = i;
+ break;
+ }
+ }
+
+ for (i = 0; i < nr_cpus; i++) {
+ struct clock_thread *t = &cthreads[i];
+
+ pthread_mutex_lock(&t->started);
+ }
+
+ for (i = 0; i < nr_cpus; i++) {
+ struct clock_thread *t = &cthreads[i];
+
+ pthread_mutex_unlock(&t->lock);