sharedservermanager.cpp

天之炼狱1服务器端源文件游戏服务端不完整

//////////////////////////////////////////////////////////////////////
//
// Filename    : SharedServerManager.cpp
// Written By  : Reiot
// Description :
//
//////////////////////////////////////////////////////////////////////

// include files
#include "SharedServerManager.h"
#include "SharedServerClient.h"
#include "Properties.h"
#include "LogClient.h"
#include "Assert.h"

#include "ThreadManager.h"
#include "ThreadPool.h"

#include <unistd.h>
#include "DB.h"
#include "Timeval.h"

#include "Gpackets/GSRequestGuildInfo.h"

//////////////////////////////////////////////////////////////////////
// constructor
//////////////////////////////////////////////////////////////////////
SharedServerManager::SharedServerManager () 
	throw (Error)
{
	__BEGIN_TRY

	m_pSharedServerClient = NULL;

	m_Mutex.setName( "SharedServerManager" );

	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
// destructor
//////////////////////////////////////////////////////////////////////
SharedServerManager::~SharedServerManager () 
	throw (Error)
{
	__BEGIN_TRY

	SAFE_DELETE(m_pSharedServerClient);

	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
// stop thread
//////////////////////////////////////////////////////////////////////
void SharedServerManager::stop () 
	throw (Error)
{
	__BEGIN_TRY

	throw UnsupportedError();

	__END_CATCH
}

//////////////////////////////////////////////////////////////////////
// main method
//////////////////////////////////////////////////////////////////////
void SharedServerManager::run () 
	throw ()
{
	try {

		string host     = g_pConfig->getProperty("DB_HOST");
		string db       = g_pConfig->getProperty("DB_DB");
		string user     = g_pConfig->getProperty("DB_USER");
		string password = g_pConfig->getProperty("DB_PASSWORD");

		Connection* pConnection = new Connection(host, db, user, password);
		g_pDatabaseManager->addConnection((int)Thread::self(), pConnection);
		cout << "************************************************************************" << endl;
		cout << "OPEN LOGIN DB" << endl;
		cout << "************************************************************************" << endl;

		Timeval dummyQueryTime;
		getCurrentTime( dummyQueryTime );

		while ( true )
		{
			usleep( 100 );

			// 楷搬登绢 乐瘤 臼促搁 楷搬阑 矫档茄促.
			if ( m_pSharedServerClient == NULL )
			{
				Socket* pSocket = NULL;

				try
				{
					string SharedServerIP = g_pConfig->getProperty( "SharedServerIP" );
					uint SharedServerPort = g_pConfig->getPropertyInt( "SharedServerPort" );

					// create socket
					pSocket = new Socket( SharedServerIP, SharedServerPort );

					// connect
					pSocket->connect();

					// make nonblocking socket
					pSocket->setNonBlocking();

					// make no-linger socket
					pSocket->setLinger(0);

					__ENTER_CRITICAL_SECTION(m_Mutex)
					m_pSharedServerClient = new SharedServerClient( pSocket );
					__LEAVE_CRITICAL_SECTION(m_Mutex)

					pSocket = NULL;

					cout << "connection to sharedserver established" << endl;

					// 辨靛 沥焊甫 啊廉坷档废 夸没茄促.
					GSRequestGuildInfo gsRequestGuildInfo;
					m_pSharedServerClient->sendPacket( &gsRequestGuildInfo );
				} 
				catch ( Throwable& t )
				{
					cout << "connect to sharedserver fail" << endl;

					try {
						SAFE_DELETE( pSocket );
					} catch (Throwable& t) {
						filelog("sharedServerClient.txt", "[0]%s", t.toString().c_str());
					}

					__ENTER_CRITICAL_SECTION(m_Mutex)
					
					try {
							SAFE_DELETE( m_pSharedServerClient ); 
					} catch (Throwable& t) {
						filelog("sharedServerClient.txt", "[1]%s", t.toString().c_str());
					}
					__LEAVE_CRITICAL_SECTION(m_Mutex)

					// 促澜 立加矫档矫埃
					usleep( 500000 );
				}
			}

			// 家南捞 楷搬登绢 乐促搁 涝免仿阑 贸府茄促.
			__ENTER_CRITICAL_SECTION(m_Mutex)

			if ( m_pSharedServerClient != NULL )
			{
				try
				{
					m_pSharedServerClient->processInput();
					m_pSharedServerClient->processOutput();
					m_pSharedServerClient->processCommand();
				}
				catch ( Throwable& t )
				{
					cout << t.toString().c_str() << endl;

					try {
						SAFE_DELETE( m_pSharedServerClient );
					} catch (Throwable& t) {
						filelog("sharedServerClient.txt", "[2]%s", t.toString().c_str());
					}
				}
			}

			__LEAVE_CRITICAL_SECTION(m_Mutex)

			// dummy query
			Timeval currentTime;
			getCurrentTime(currentTime);

			if (dummyQueryTime < currentTime)
			{
				g_pDatabaseManager->executeDummyQuery( pConnection );

				// 1矫埃 ~ 1矫埃 30盒 荤捞俊辑 dummy query 矫埃阑 汲沥茄促.
				// timeout捞 登瘤 臼霸 窍扁 困秦辑捞促.
				dummyQueryTime.tv_sec += (60+rand()%30) * 60;
			}
		}

	}
	catch (Throwable & t)
	{
		filelog("SHAREDSERVERMANAGER.log", "SharedServerManager::run() 4 : %s", t.toString().c_str());

		cerr << t.toString() << endl;
	}
}

//////////////////////////////////////////////////////////////////////
// send packet to shared server
//////////////////////////////////////////////////////////////////////
void SharedServerManager::sendPacket ( Packet* pPacket )
	throw (ProtocolException , Error)
{
	__ENTER_CRITICAL_SECTION(m_Mutex)
		
	if ( m_pSharedServerClient != NULL )
	{
		m_pSharedServerClient->sendPacket( pPacket );
	}

	__LEAVE_CRITICAL_SECTION(m_Mutex)
}


// global variable definition
SharedServerManager* g_pSharedServerManager = NULL;