From b5ff856f47d8e54d12c568462a06351633c29610 Mon Sep 17 00:00:00 2001
From: Adam <Adam@anope.org>
Date: Tue, 8 Nov 2011 17:29:16 -0500
Subject: Windows

---
 src/win32/pthread/pthread.cpp | 117 ++++++++++++++++++++++++++++++++++++++++++
 src/win32/pthread/pthread.h   |  34 ++++++++++++
 2 files changed, 151 insertions(+)
 create mode 100644 src/win32/pthread/pthread.cpp
 create mode 100644 src/win32/pthread/pthread.h

(limited to 'src/win32/pthread')

diff --git a/src/win32/pthread/pthread.cpp b/src/win32/pthread/pthread.cpp
new file mode 100644
index 000000000..8c1da7555
--- /dev/null
+++ b/src/win32/pthread/pthread.cpp
@@ -0,0 +1,117 @@
+ /* POSIX emulation layer for Windows.
+ *
+ * Copyright (C) 2008-2011 Anope Team <team@anope.org>
+ *
+ * Please read COPYING and README for further details.
+ */
+
+#include "pthread.h"
+
+struct ThreadInfo
+{
+	void *(*entry)(void *);
+	void *param;
+};
+
+static DWORD WINAPI entry_point(void *parameter)
+{
+	ThreadInfo *ti = static_cast<ThreadInfo *>(parameter);
+	ti->entry(ti->param);
+	delete ti;
+	return 0;
+}
+
+int pthread_attr_init(pthread_attr_t *)
+{
+	/* No need for this */
+	return 0;
+}
+
+int pthread_attr_setdetachstate(pthread_attr_t *, int)
+{
+	/* No need for this */
+	return 0;
+}
+
+int pthread_create(pthread_t *thread, const pthread_attr_t *, void *(*entry)(void *), void *param)
+{
+	ThreadInfo *ti = new ThreadInfo;
+	ti->entry = entry;
+	ti->param = param;
+
+	*thread = CreateThread(NULL, 0, entry_point, ti, 0, NULL);
+	if (!*thread)
+	{
+		delete ti;
+		return -1;
+	}
+
+	return 0;
+}
+
+int pthread_join(pthread_t thread, void **)
+{
+	if (WaitForSingleObject(thread, INFINITE) == WAIT_FAILED)
+		return -1;
+	return 0;
+}
+
+void pthread_exit(int i)
+{
+	ExitThread(i);
+}
+
+int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *)
+{
+	InitializeCriticalSection(mutex);
+	return 0;
+}
+
+int pthread_mutex_destroy(pthread_mutex_t *mutex)
+{
+	DeleteCriticalSection(mutex);
+	return 0;
+}
+
+int pthread_mutex_lock(pthread_mutex_t *mutex)
+{
+	EnterCriticalSection(mutex);
+	return 0;
+}
+
+int pthread_mutex_trylock(pthread_mutex_t *mutex)
+{
+	return !TryEnterCriticalSection(mutex);
+}
+
+int pthread_mutex_unlock(pthread_mutex_t *mutex)
+{
+	LeaveCriticalSection(mutex);
+	return 0;
+}
+
+int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *)
+{
+	*cond = CreateEvent(NULL, false, false, NULL);
+	if (*cond == NULL)
+		return -1;
+	return 0;
+}
+
+int pthread_cond_destroy(pthread_cond_t *cond)
+{
+	return !CloseHandle(*cond);
+}
+
+int pthread_cond_signal(pthread_cond_t *cond)
+{
+	return !PulseEvent(*cond);
+}
+
+int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)
+{
+	LeaveCriticalSection(mutex);
+	WaitForSingleObject(*cond, INFINITE);
+	EnterCriticalSection(mutex);
+	return 0;
+}
diff --git a/src/win32/pthread/pthread.h b/src/win32/pthread/pthread.h
new file mode 100644
index 000000000..5ec0775ea
--- /dev/null
+++ b/src/win32/pthread/pthread.h
@@ -0,0 +1,34 @@
+ /* POSIX emulation layer for Windows.
+ *
+ * Copyright (C) 2008-2011 Anope Team <team@anope.org>
+ *
+ * Please read COPYING and README for further details.
+ */
+
+#include <Windows.h>
+
+typedef HANDLE pthread_t;
+typedef CRITICAL_SECTION pthread_mutex_t;
+typedef HANDLE pthread_cond_t;
+typedef int pthread_attr_t;
+typedef void pthread_mutexattr_t;
+typedef void pthread_condattr_t;
+
+#define PTHREAD_CREATE_JOINABLE 0
+
+extern int pthread_attr_init(pthread_attr_t *);
+extern int pthread_attr_setdetachstate(pthread_attr_t *, int);
+extern int pthread_create(pthread_t *, const pthread_attr_t *, void *(*)(void *), void *);
+extern int pthread_join(pthread_t, void **);
+extern void pthread_exit(int);
+
+extern int pthread_mutex_init(pthread_mutex_t *, const pthread_mutexattr_t *);
+extern int pthread_mutex_destroy(pthread_mutex_t *);
+extern int pthread_mutex_lock(pthread_mutex_t *);
+extern int pthread_mutex_trylock(pthread_mutex_t *);
+extern int pthread_mutex_unlock(pthread_mutex_t *);
+
+extern int pthread_cond_init(pthread_cond_t *, const pthread_condattr_t *);
+extern int pthread_cond_destroy(pthread_cond_t *);
+extern int pthread_cond_signal(pthread_cond_t *);
+extern int pthread_cond_wait(pthread_cond_t *, pthread_mutex_t *);
-- 
cgit