aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMachiavelli <none@none>2010-08-20 12:44:08 +0200
committerMachiavelli <none@none>2010-08-20 12:44:08 +0200
commita3270e79e3c7fe5752009c5df9ff2b7d1f9f967c (patch)
tree98da947f89a2488f5aa134ab5931272715bb2700
parent24d752e782f64b5f65166ebf1c108863e0aac61d (diff)
Return proper MySQL connection for syncrhonous requests based on calling thread instead of bundled connection.
--HG-- branch : trunk
-rw-r--r--src/server/shared/Database/DatabaseWorkerPool.cpp2
-rw-r--r--src/server/shared/Database/MySQLConnection.cpp4
2 files changed, 4 insertions, 2 deletions
diff --git a/src/server/shared/Database/DatabaseWorkerPool.cpp b/src/server/shared/Database/DatabaseWorkerPool.cpp
index 6ec4b9d3870..538a3535efd 100644
--- a/src/server/shared/Database/DatabaseWorkerPool.cpp
+++ b/src/server/shared/Database/DatabaseWorkerPool.cpp
@@ -258,7 +258,7 @@ MySQLConnection* DatabaseWorkerPool::GetConnection()
ACE_Guard<ACE_Thread_Mutex> guard(m_connectionMap_mtx);
itr = m_sync_connections.find(ACE_Based::Thread::current());
if (itr != m_sync_connections.end())
- conn = itr->second;
+ return itr->second;
}
/*! Bundled threads */
conn = m_bundle_conn;
diff --git a/src/server/shared/Database/MySQLConnection.cpp b/src/server/shared/Database/MySQLConnection.cpp
index 51b6d649bb0..9f16cbdf414 100644
--- a/src/server/shared/Database/MySQLConnection.cpp
+++ b/src/server/shared/Database/MySQLConnection.cpp
@@ -26,7 +26,9 @@
#include "Timer.h"
MySQLConnection::MySQLConnection() :
-m_Mysql(NULL)
+m_Mysql(NULL),
+m_worker(NULL),
+m_queue(NULL)
{
}