diff options
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; } |