X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=src%2Fthreadengines%2Fthreadengine_win32.cpp;h=5666113671fb6d5a56e13912dda73fc78cd4d7d3;hb=82bf46fa061a4f18071e73756e4e0d618eb57320;hp=e426fe37383eb6ece91b263a3fb3157ef7405d00;hpb=3b25592002f791c91d3a040d0f094f3df32f577e;p=user%2Fhenk%2Fcode%2Finspircd.git

diff --git a/src/threadengines/threadengine_win32.cpp b/src/threadengines/threadengine_win32.cpp
index e426fe373..566611367 100644
--- a/src/threadengines/threadengine_win32.cpp
+++ b/src/threadengines/threadengine_win32.cpp
@@ -18,31 +18,43 @@ CRITICAL_SECTION MyMutex;
 
 Win32ThreadEngine::Win32ThreadEngine(InspIRCd* Instance) : ThreadEngine(Instance)
 {
+	InitializeCriticalSection(&MyMutex);
 }
 
 void Win32ThreadEngine::Create(Thread* thread_to_init)
 {
+	Mutex(true);
 	HANDLE* MyThread = new HANDLE;
 	DWORD ThreadId = 0;
 
-	if (!(*MyThread = CreateThread(NULL,0,Win32ThreadEngine::Entry,this,0,&ThreadId)))
+	if (NULL == (*MyThread = CreateThread(NULL,0,Win32ThreadEngine::Entry,this,0,&ThreadId)))
 	{
 		delete MyThread;
-		throw CoreException(std::string("Unable to reate new Win32ThreadEngine: ") + dlerror());
+		Mutex(false);
+		throw CoreException(std::string("Unable to create new Win32ThreadEngine: ") + dlerror());
 	}
 
 	NewThread = thread_to_init;
 	NewThread->Creator = this;
 	NewThread->Extend("winthread", MyThread);
+	Mutex(false);
+
+	while (NewThread)
+		SleepEx(100, false);
 }
 
 Win32ThreadEngine::~Win32ThreadEngine()
 {
+	DeleteCriticalSection(&MyMutex);
 }
 
 void Win32ThreadEngine::Run()
 {
-	NewThread->Run();
+	Mutex(true);
+	Thread* nt = NewThread;
+	NewThread = NULL;
+	Mutex(false);
+	nt->Run();
 }
 
 bool Win32ThreadEngine::Mutex(bool enable)
@@ -73,3 +85,4 @@ void Win32ThreadEngine::FreeThread(Thread* thread)
 	}
 }
 
+