Split db_mysql_live into two modules so other modules can make use of the asynchronous command interface

3 files changed, 17 insertions, 3 deletions

diff --git a/src/threadengine.cpp b/src/threadengine.cpp
index 0ac049c38..c2aa3da20 100644
--- a/src/threadengine.cpp
+++ b/src/threadengine.cpp
@@ -20,7 +20,7 @@ void ThreadEngine::Process()
 
 /** Threads constructor
  */
-Thread::Thread() : Exit(false)
+Thread::Thread() : exit(false)
 {
 	threadEngine.threads.push_back(this);
 }
@@ -41,7 +41,7 @@ Thread::~Thread()
  */
 void Thread::SetExitState()
 {
-	Exit = true;
+	exit = true;
 }
 
 /** Returns the exit state of the thread
@@ -49,7 +49,7 @@ void Thread::SetExitState()
  */
 bool Thread::GetExitState() const
 {
-	return Exit;
+	return exit;
 }
 
 /** Called to run the thread, should be overloaded
diff --git a/src/threadengines/threadengine_pthread.cpp b/src/threadengines/threadengine_pthread.cpp
index acdccfeb5..e8242bb82 100644
--- a/src/threadengines/threadengine_pthread.cpp
+++ b/src/threadengines/threadengine_pthread.cpp
@@ -39,6 +39,13 @@ void Thread::Join()
 	pthread_join(Handle, NULL);
 }
 
+/** Exit the thread. Note that the thread still must be joined to free resources!
+ */
+void Thread::Exit()
+{
+	pthread_exit(0);
+}
+
 /** Start a new thread
  * @param thread A pointer to a newley allocated thread
  */
diff --git a/src/threadengines/threadengine_win32.cpp b/src/threadengines/threadengine_win32.cpp
index e6ad725bf..218f711c4 100644
--- a/src/threadengines/threadengine_win32.cpp
+++ b/src/threadengines/threadengine_win32.cpp
@@ -31,6 +31,13 @@ void Thread::Join()
 	WaitForSingleObject(Handle, INFINITE);
 }
 
+/** Exit the thread. Note that the thread still must be joined to free resources!
+ */
+void Thread::Exit()
+{
+	ExitThread(0);
+}
+
 /** Start a new thread
  * @param thread A pointer to a newley allocated thread
  */