Mirror/TrinityCore
1
0
Fork 0
mirror of https://github.com/TrinityCore/TrinityCore.git synced 2026-01-23 18:36:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

Backed out changeset 97d8a5f6449c

Browse Source 
--HG--
branch : trunk
This commit is contained in:
QAston
2009-06-27 17:59:57 +02:00
parent ab7e83a72c
commit 1592fe9aa3
6 changed files with 16 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/shared/Database/SqlDelayThread.cpp
View File

@@ -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,16 +35,15 @@ 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();
s->Execute(m_dbEngine);
delete s;
}
catch(...)
{continue;}
if(!s)
continue;
s->Execute(m_dbEngine);
delete s;
}
#ifndef DO_POSTGRESQL
@@ -57,6 +54,5 @@ void SqlDelayThread::run()
void SqlDelayThread::Stop()
{
m_running = false;
m_sqlQueue.cancel();
}