From ab7e83a72c7da17541e7d87b087ce8693d8b301d Mon Sep 17 00:00:00 2001 From: QAston Date: Sat, 27 Jun 2009 17:15:38 +0200 Subject: *Merge 1600 from tc1. --HG-- branch : trunk --- src/shared/Database/DatabaseMysql.cpp | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'src/shared/Database/DatabaseMysql.cpp') diff --git a/src/shared/Database/DatabaseMysql.cpp b/src/shared/Database/DatabaseMysql.cpp index 0189b5883f7..61801d65fe5 100644 --- a/src/shared/Database/DatabaseMysql.cpp +++ b/src/shared/Database/DatabaseMysql.cpp @@ -70,7 +70,7 @@ DatabaseMysql::~DatabaseMysql() mysql_library_end(); } -bool DatabaseMysql::Initialize(const char *infoString) +bool DatabaseMysql::Initialize(const char *infoString, bool initDelayThread) { if(!Database::Initialize(infoString)) @@ -85,7 +85,8 @@ bool DatabaseMysql::Initialize(const char *infoString) return false; } - InitDelayThread(); + if(initDelayThread) + InitDelayThread(infoString); Tokens tokens = StrSplit(infoString, ";"); @@ -435,12 +436,12 @@ unsigned long DatabaseMysql::escape_string(char *to, const char *from, unsigned return(mysql_real_escape_string(mMysql, to, from, length)); } -void DatabaseMysql::InitDelayThread() +void DatabaseMysql::InitDelayThread(const char* infoString) { assert(!m_delayThread); //New delay thread for delay execute - m_threadBody = new MySQLDelayThread(this); + m_threadBody = new MySQLDelayThread(this,infoString); m_delayThread = new ACE_Based::Thread(*m_threadBody); } -- cgit v1.2.3