* Call Database::ThreadStart()/Database::ThreadEnd() for all databases in all threads.

--HG--
branch : trunk
This commit is contained in:
XTZGZoReX
2010-01-29 19:24:14 +01:00
parent 80061b7899
commit a385ea64b0
4 changed files with 15 additions and 2 deletions
+4
View File
@@ -18,6 +18,8 @@ class WDBThreadStartReq1 : public ACE_Method_Request
call (void) call (void)
{ {
WorldDatabase.ThreadStart(); WorldDatabase.ThreadStart();
CharacterDatabase.ThreadStart();
loginDatabase.ThreadStart();
return 0; return 0;
} }
}; };
@@ -31,6 +33,8 @@ class WDBThreadEndReq1 : public ACE_Method_Request
call (void) call (void)
{ {
WorldDatabase.ThreadEnd(); WorldDatabase.ThreadEnd();
CharacterDatabase.ThreadEnd();
loginDatabase.ThreadEnd();
return 0; return 0;
} }
}; };
+4
View File
@@ -155,6 +155,8 @@ class ReactorRunnable : protected ACE_Task_Base
DEBUG_LOG ("Network Thread Starting"); DEBUG_LOG ("Network Thread Starting");
WorldDatabase.ThreadStart(); WorldDatabase.ThreadStart();
CharacterDatabase.ThreadStart();
loginDatabase.ThreadStart();
ACE_ASSERT (m_Reactor); ACE_ASSERT (m_Reactor);
@@ -188,6 +190,8 @@ class ReactorRunnable : protected ACE_Task_Base
} }
WorldDatabase.ThreadEnd(); WorldDatabase.ThreadEnd();
CharacterDatabase.ThreadEnd();
loginDatabase.ThreadEnd();
DEBUG_LOG ("Network Thread Exitting"); DEBUG_LOG ("Network Thread Exitting");
+4
View File
@@ -369,6 +369,8 @@ void CliRunnable::run()
{ {
///- Init new SQL thread for the world database (one connection call enough) ///- Init new SQL thread for the world database (one connection call enough)
WorldDatabase.ThreadStart(); // let thread do safe mySQL requests WorldDatabase.ThreadStart(); // let thread do safe mySQL requests
CharacterDatabase.ThreadStart();
loginDatabase.ThreadStart();
char commandbuf[256]; char commandbuf[256];
bool canflush = true; bool canflush = true;
@@ -438,4 +440,6 @@ void CliRunnable::run()
///- End the database thread ///- End the database thread
WorldDatabase.ThreadEnd(); // free mySQL thread resources WorldDatabase.ThreadEnd(); // free mySQL thread resources
CharacterDatabase.ThreadEnd();
loginDatabase.ThreadEnd();
} }
+1
View File
@@ -47,6 +47,7 @@ void WorldRunnable::run()
WorldDatabase.ThreadStart(); // let thread do safe mySQL requests (one connection call enough) WorldDatabase.ThreadStart(); // let thread do safe mySQL requests (one connection call enough)
CharacterDatabase.ThreadStart(); CharacterDatabase.ThreadStart();
loginDatabase.ThreadStart(); loginDatabase.ThreadStart();
sWorld.InitResultQueue(); sWorld.InitResultQueue();
uint32 realCurrTime = 0; uint32 realCurrTime = 0;