diff --git a/src/server/shared/Database/DatabaseWorker.h b/src/server/shared/Database/DatabaseWorker.h index 54434f31c5..2e0fe58e81 100755 --- a/src/server/shared/Database/DatabaseWorker.h +++ b/src/server/shared/Database/DatabaseWorker.h @@ -32,9 +32,9 @@ template class DatabaseWorker : public ACE_Task_Base { public: - DatabaseWorker(ACE_Activation_Queue* new_queue, T* t) : + DatabaseWorker(ACE_Activation_Queue* new_queue, DatabaseWorkerPool* pool) : m_queue(new_queue), - m_pool(t) + m_pool(pool) { /// Assign thread to task activate(); @@ -87,7 +87,7 @@ class DatabaseWorker : public ACE_Task_Base DatabaseWorker() : ACE_Task_Base() {} ACE_Activation_Queue* m_queue; MySQLConnection* m_conn; - T* m_pool; // Databasepool we operate on + DatabaseWorkerPool* m_pool; // Databasepool we operate on }; #endif diff --git a/src/server/shared/Database/DatabaseWorkerPool.h b/src/server/shared/Database/DatabaseWorkerPool.h index 6de6cf630c..40a31b59e8 100755 --- a/src/server/shared/Database/DatabaseWorkerPool.h +++ b/src/server/shared/Database/DatabaseWorkerPool.h @@ -84,7 +84,7 @@ class DatabaseWorkerPool m_delaythreads.resize(delaythreads); for (uint8 i = 0; i < delaythreads; ++i) - m_delaythreads[i] = new DatabaseWorker(m_queue, this); + m_delaythreads[i] = new DatabaseWorker(m_queue, this); sLog.outSQLDriver("Databasepool opened succesfuly. %u connections running.", m_connectionCount); return true; @@ -342,13 +342,12 @@ class DatabaseWorkerPool } private: - typedef DatabaseWorkerPool ThisClass; ACE_Activation_Queue* m_queue; //! Queue shared by async worker threads. std::vector m_connections; uint8 m_connectionCount; //! Counter of MySQL connections; MySQLConnectionInfo m_connectionInfo; - std::vector*> m_delaythreads; //! Delaythreads (templatized) + std::vector*> m_delaythreads; //! Delaythreads (templatized) }; #endif