aboutsummaryrefslogtreecommitdiff
path: root/src/shared/Database/SqlDelayThread.cpp
diff options
context:
space:
mode:
authormaximius <none@none>2009-09-11 13:42:39 -0700
committermaximius <none@none>2009-09-11 13:42:39 -0700
commitb4a13eff5130bb9127d2898d280336a4a30b5661 (patch)
tree19fd75edfc81be946b323d06c0f4ac2401abc9d0 /src/shared/Database/SqlDelayThread.cpp
parentaed229dfe6cb2e308081a334321f5981cf34dc52 (diff)
*Missed some changes
--HG-- branch : trunk
Diffstat (limited to 'src/shared/Database/SqlDelayThread.cpp')
-rw-r--r--src/shared/Database/SqlDelayThread.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/src/shared/Database/SqlDelayThread.cpp b/src/shared/Database/SqlDelayThread.cpp
index 9a92fd5dd63..88b6b85df70 100644
--- a/src/shared/Database/SqlDelayThread.cpp
+++ b/src/shared/Database/SqlDelayThread.cpp
@@ -28,7 +28,6 @@ SqlDelayThread::SqlDelayThread(Database* db) : m_dbEngine(db), m_running(true)
void SqlDelayThread::run()
{
- SqlOperation* s;
#ifndef DO_POSTGRESQL
mysql_thread_init();
#endif
@@ -38,9 +37,9 @@ void SqlDelayThread::run()
// if the running state gets turned off while sleeping
// empty the queue before exiting
ACE_Based::Thread::Sleep(10);
- while (!m_sqlQueue.empty())
+ SqlOperation* s;
+ while (m_sqlQueue.next(s))
{
- s = m_sqlQueue.next();
s->Execute(m_dbEngine);
delete s;
}