*Merge.

--HG--
branch : trunk

src/shared/Database/Database.h

@@ -49,7 +49,7 @@ class TRINITY_DLL_SPEC Database
         virtual ~Database();
 
         virtual bool Initialize(const char *infoString);
-        virtual void InitDelayThread(const char *infoString) = 0;
+        virtual void InitDelayThread() = 0;
         virtual void HaltDelayThread() = 0;
 
         virtual QueryResult* Query(const char *sql) = 0;

src/shared/Database/DatabaseMysql.cpp

@@ -70,7 +70,7 @@ DatabaseMysql::~DatabaseMysql()
         mysql_library_end();
 }
 
-bool DatabaseMysql::Initialize(const char *infoString, bool initDelayThread)
+bool DatabaseMysql::Initialize(const char *infoString)
 {
 
     if(!Database::Initialize(infoString))
@@ -85,8 +85,7 @@ bool DatabaseMysql::Initialize(const char *infoString, bool initDelayThread)
         return false;
     }
 
-    if(initDelayThread)
+    InitDelayThread();
-        InitDelayThread(infoString);
 
     Tokens tokens = StrSplit(infoString, ";");
 
@@ -436,12 +435,12 @@ unsigned long DatabaseMysql::escape_string(char *to, const char *from, unsigned
     return(mysql_real_escape_string(mMysql, to, from, length));
 }
 
-void DatabaseMysql::InitDelayThread(const char* infoString)
+void DatabaseMysql::InitDelayThread()
 {
     assert(!m_delayThread);
 
     //New delay thread for delay execute
-    m_threadBody = new MySQLDelayThread(this,infoString);
+    m_threadBody = new MySQLDelayThread(this);
     m_delayThread = new ACE_Based::Thread(*m_threadBody);
 }
 

src/shared/Database/DatabaseMysql.h

@@ -46,8 +46,8 @@ class TRINITY_DLL_SPEC DatabaseMysql : public Database
 
         //! Initializes Mysql and connects to a server.
         /*! infoString should be formated like hostname;username;password;database. */
-        bool Initialize(const char *infoString, bool initDelayThread = true);
+        bool Initialize(const char *infoString);
-        void InitDelayThread(const char* infoString);
+        void InitDelayThread();
         void HaltDelayThread();
         QueryResult* Query(const char *sql);
         QueryNamedResult* QueryNamed(const char *sql);

src/shared/Database/MySQLDelayThread.h

@@ -26,7 +26,7 @@
 class MySQLDelayThread : public SqlDelayThread
 {
     public:
-        MySQLDelayThread(Database* db,const char* infoString) : SqlDelayThread(db, infoString) {}
+        MySQLDelayThread(Database* db) : SqlDelayThread(db) {}
         void Stop() { SqlDelayThread::Stop(); }
 };
 #endif                                                      //__MYSQLDELAYTHREAD_H

src/shared/Database/SqlDelayThread.cpp

@@ -22,10 +22,8 @@
 #include "Database/SqlOperations.h"
 #include "DatabaseEnv.h"
 
-SqlDelayThread::SqlDelayThread(Database* db, const char* infoString) :m_running(true)
+SqlDelayThread::SqlDelayThread(Database* db) : m_dbEngine(db), m_running(true)
 {
-    m_dbEngine = new DatabaseType;
-    ((DatabaseType*)m_dbEngine)->Initialize(infoString, false);
 }
 
 void SqlDelayThread::run()
@@ -37,17 +35,16 @@ void SqlDelayThread::run()
 
     while (m_running)
     {
-        try
+        // if the running state gets turned off while sleeping
+        // empty the queue before exiting
+        ACE_Based::Thread::Sleep(10);
+        while (!m_sqlQueue.empty())
         {
             s = m_sqlQueue.next();
-        }
-        catch(...)
-            {continue;}
-        if(!s)
-            continue;
             s->Execute(m_dbEngine);
             delete s;
         }
+    }
 
     #ifndef DO_POSTGRESQL
     mysql_thread_end();
@@ -57,6 +54,5 @@ void SqlDelayThread::run()
 void SqlDelayThread::Stop()
 {
     m_running = false;
-    m_sqlQueue.cancel();
 }
 

src/shared/Database/SqlDelayThread.h

@@ -40,7 +40,7 @@ class SqlDelayThread : public ACE_Based::Runnable
 
         SqlDelayThread();
     public:
-        SqlDelayThread(Database* db,const char* infoString);
+        SqlDelayThread(Database* db);
 
         ///< Put sql statement to delay queue
         bool Delay(SqlOperation* sql) { m_sqlQueue.add(sql); return true; }