1 files changed, 62 insertions, 0 deletions
diff --git a/executor/executor_fuchsia.h b/executor/executor_fuchsia.h
new file mode 100644
index 000000000..e49f75b67
--- /dev/null
+++ b/executor/executor_fuchsia.h
@@ -0,0 +1,62 @@
+// Copyright 2018 syzkaller project authors. All rights reserved.
+// Use of this source code is governed by Apache 2 LICENSE that can be found in the LICENSE file.
+
+// Fuchsia's pthread_cond_timedwait just returns immidiately, so we use simple spin wait.
+
+#include <pthread.h>
+
+typedef pthread_t osthread_t;
+
+void thread_start(osthread_t* t, void* (*fn)(void*), void* arg)
+{
+	pthread_attr_t attr;
+	pthread_attr_init(&attr);
+	pthread_attr_setstacksize(&attr, 128 << 10);
+	if (pthread_create(t, &attr, fn, arg))
+		exitf("pthread_create failed");
+	pthread_attr_destroy(&attr);
+}
+
+struct event_t {
+	int state;
+};
+
+void event_init(event_t* ev)
+{
+	ev->state = 0;
+}
+
+void event_reset(event_t* ev)
+{
+	ev->state = 0;
+}
+
+void event_set(event_t* ev)
+{
+	if (ev->state)
+		fail("event already set");
+	__atomic_store_n(&ev->state, 1, __ATOMIC_RELEASE);
+}
+
+void event_wait(event_t* ev)
+{
+	while (!__atomic_load_n(&ev->state, __ATOMIC_ACQUIRE))
+		usleep(200);
+}
+
+bool event_isset(event_t* ev)
+{
+	return __atomic_load_n(&ev->state, __ATOMIC_ACQUIRE);
+}
+
+bool event_timedwait(event_t* ev, uint64 timeout_ms)
+{
+	uint64 start = current_time_ms();
+	for (;;) {
+		if (__atomic_load_n(&ev->state, __ATOMIC_RELAXED))
+			return true;
+		if (current_time_ms() - start > timeout_ms)
+			return false;
+		usleep(200);
+	}
+}