From 988a6f5c9307ccbf62e38b5d2baec16523042fda Mon Sep 17 00:00:00 2001 From: Machiavelli Date: Mon, 6 Dec 2010 19:28:05 +0100 Subject: Core/DBLayer: Simplify template usage for DatabaseWorker --HG-- branch : trunk --- src/server/shared/Database/DatabaseWorker.h | 6 +++--- src/server/shared/Database/DatabaseWorkerPool.h | 5 ++--- 2 files changed, 5 insertions(+), 6 deletions(-) (limited to 'src/server/shared/Database') diff --git a/src/server/shared/Database/DatabaseWorker.h b/src/server/shared/Database/DatabaseWorker.h index 54434f31c58..2e0fe58e814 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 6de6cf630c0..40a31b59e83 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 -- cgit v1.2.3