Cygwin port

AerofoilPortable/GpFiberStarter_Thread.cpp

@@ -0,0 +1,68 @@
+#include "GpFiberStarter.h"
+#include "GpFiber_Thread.h"
+
+#include "IGpSystemServices.h"
+#include "IGpThreadEvent.h"
+
+#include <assert.h>
+
+namespace GpFiberStarter_Thread
+{
+	struct FiberStartState
+	{
+		GpFiberStarter::ThreadFunc_t m_threadFunc;
+		IGpThreadEvent *m_creatingReturnEvent;
+		IGpThreadEvent *m_creatingWakeEvent;
+		void *m_context;
+	};
+
+	static int FiberStartRoutine(void *lpThreadParameter)
+	{
+		const FiberStartState *tss = static_cast<const FiberStartState*>(lpThreadParameter);
+
+		GpFiberStarter::ThreadFunc_t threadFunc = tss->m_threadFunc;
+		IGpThreadEvent *creatingReturnEvent = tss->m_creatingReturnEvent;
+		IGpThreadEvent *wakeEvent = tss->m_creatingWakeEvent;
+		void *context = tss->m_context;
+		creatingReturnEvent->Signal();
+
+		wakeEvent->Wait();
+
+		threadFunc(context);
+
+		return 0;
+	}
+}
+
+IGpFiber *GpFiberStarter::StartFiber(IGpSystemServices *systemServices, ThreadFunc_t threadFunc, void *context, IGpFiber *creatingFiber)
+{
+	IGpThreadEvent *returnEvent = systemServices->CreateThreadEvent(true, false);
+	if (!returnEvent)
+		return nullptr;
+
+	IGpThreadEvent *wakeEvent = systemServices->CreateThreadEvent(true, false);
+	if (!wakeEvent)
+	{
+		returnEvent->Destroy();
+		return nullptr;
+	}
+
+	GpFiberStarter_Thread::FiberStartState startState;
+	startState.m_context = context;
+	startState.m_creatingReturnEvent = returnEvent;
+	startState.m_creatingWakeEvent = wakeEvent;
+	startState.m_threadFunc = threadFunc;
+
+	void *thread = systemServices->CreateThread(GpFiberStarter_Thread::FiberStartRoutine, &startState);
+	if (!thread)
+	{
+		returnEvent->Destroy();
+		wakeEvent->Destroy();
+		return nullptr;
+	}
+
+	returnEvent->Wait();
+	returnEvent->Destroy();
+
+	return new GpFiber_Thread(thread, wakeEvent);
+}