mangos-mirror/server
0
0
Fork 0
mirror of https://github.com/mangosfour/server.git synced 2025-12-19 04:37:06 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

[9265] * Call Database::ThreadStart()/ThreadEnd() for all DBs.

Browse source
This commit is contained in:
XTZGZoReX 2010-01-29 19:56:05 +01:00
parent ceefebf187
commit 49a0d352b6
4 changed files with 16 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/game/WorldSocketMgr.cpp
View file

@ -152,7 +152,9 @@ 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);
@ -185,7 +187,9 @@ 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
src/mangosd/CliRunnable.cpp
View file

@ -294,6 +294,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];
@ -352,4 +354,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();
} }

5
src/mangosd/WorldRunnable.cpp
View file

@ -42,6 +42,9 @@ void WorldRunnable::run()
{ {
///- Init new SQL thread for the world database ///- Init new SQL thread for the world database
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();
loginDatabase.ThreadStart();
sWorld.InitResultQueue(); sWorld.InitResultQueue();
uint32 realCurrTime = 0; uint32 realCurrTime = 0;
@ -90,4 +93,6 @@ void WorldRunnable::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();
} }

2
src/shared/revision_nr.h
View file

@ -1,4 +1,4 @@
#ifndef __REVISION_NR_H__ #ifndef __REVISION_NR_H__
#define __REVISION_NR_H__ #define __REVISION_NR_H__
#define REVISION_NR "9264" #define REVISION_NR "9265"
#endif // __REVISION_NR_H__ #endif // __REVISION_NR_H__