diff options
| -rwxr-xr-x | src/server/shared/Database/DatabaseWorkerPool.h | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/src/server/shared/Database/DatabaseWorkerPool.h b/src/server/shared/Database/DatabaseWorkerPool.h index 957d93d449b..6c1be4c5a42 100755 --- a/src/server/shared/Database/DatabaseWorkerPool.h +++ b/src/server/shared/Database/DatabaseWorkerPool.h @@ -102,10 +102,8 @@ class DatabaseWorkerPool { sLog->outSQLDriver("Closing down databasepool '%s'.", m_connectionInfo.database.c_str()); - /// Shuts down delaythreads for this connection pool. - m_queue->queue()->deactivate(); - while (SQLOperation* op = (SQLOperation*)(m_queue->dequeue())) - delete op; + /// Shuts down delaythreads for this connection pool by underlying deactivate() + m_queue->queue()->close(); for (uint8 i = 0; i < m_connectionCount[IDX_ASYNC]; ++i) { |