diff options
author | maximius <none@none> | 2009-09-11 13:42:39 -0700 |
---|---|---|
committer | maximius <none@none> | 2009-09-11 13:42:39 -0700 |
commit | b4a13eff5130bb9127d2898d280336a4a30b5661 (patch) | |
tree | 19fd75edfc81be946b323d06c0f4ac2401abc9d0 /src/shared/Database/SqlDelayThread.cpp | |
parent | aed229dfe6cb2e308081a334321f5981cf34dc52 (diff) |
*Missed some changes
--HG--
branch : trunk
Diffstat (limited to 'src/shared/Database/SqlDelayThread.cpp')
-rw-r--r-- | src/shared/Database/SqlDelayThread.cpp | 5 |
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; } |