querydbsocket.cpp

国内著名网络游戏dragon的服务端完整源码 内附完整数据库结构

// QueryDBSocket.cpp: implementation of the CQueryDBSocket class.
//
//////////////////////////////////////////////////////////////////////

#include "..\stdafx.h"
//#include "DRPointManger.h"
#include "QueryDBSocket.h"
#include "../Async/Async.h"
#include "../MyLog.h"
#include "../ShopDemon.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
extern CMySocket *ConC;
CQueryDBSocket::CQueryDBSocket()
{
//	for(int i=0;i<MAXCONNECTION;i++)
//	{
		m_AcceptSock = ConC;
		m_AcceptSock->status=EMPTY;
		m_AcceptSock->parent=LONG(this);
		
//	}
	


}

CQueryDBSocket::~CQueryDBSocket()
{

}
void CQueryDBSocket::MyAccept(CMySocket *SendSock)
{
	return;
}
void CQueryDBSocket::MyError(CMySocket *SendSock)
{
	DebugPrintf("network error(myERRORevent)...");

//	for (int i=0;i<MAXCONNECTION;i++)
		if (SendSock==m_AcceptSock)
		{
				if ( m_AcceptSock->status!=WAITING ) 
				{
					//PostMessage(outputWnd, GAME_EVENT, i, NetErrorEvent);
				}
				else
				{
				//	m_AcceptSock.Close();
					m_AcceptSock->status = EMPTY;
					DebugPrintf("... before he logon");
				}
			 
		}

}

BOOL CQueryDBSocket::Connsock(const char *ipaddr,LONG port) 
{
	// TODO: Add your command handler code here
//		if (!m_AcceptSock[0].Create()) 
//		{
//			DebugPrintf("礚猭秨币戈