summaryrefslogtreecommitdiffstats
path: root/source/cClientHandle.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'source/cClientHandle.cpp')
-rw-r--r--source/cClientHandle.cpp166
1 files changed, 126 insertions, 40 deletions
diff --git a/source/cClientHandle.cpp b/source/cClientHandle.cpp
index d5fd0d5c0..1f7045d2b 100644
--- a/source/cClientHandle.cpp
+++ b/source/cClientHandle.cpp
@@ -77,18 +77,19 @@
typedef std::list<cPacket*> PacketList;
+
+
+
+
+// fwd: cServer.cpp:
+extern std::string GetWSAError();
+
+
+
+
+
struct cClientHandle::sClientHandleState
{
- sClientHandleState()
- : ProtocolVersion( 23 )
- , pReceiveThread( 0 )
- , pSendThread( 0 )
- , pAuthenticateThread( 0 )
- , pSemaphore( 0 )
- {
- for( int i = 0; i < 256; ++i )
- PacketMap[i] = 0;
- }
int ProtocolVersion;
std::string Username;
std::string Password;
@@ -111,7 +112,25 @@ struct cClientHandle::sClientHandleState
Vector3d ConfirmPosition;
cPacket* PacketMap[256];
-};
+
+ sClientHandleState(void)
+ : ProtocolVersion( 23 )
+ , pReceiveThread( 0 )
+ , pSendThread( 0 )
+ , pAuthenticateThread( 0 )
+ , pSemaphore( 0 )
+ {
+ for( int i = 0; i < 256; ++i )
+ PacketMap[i] = 0;
+ }
+} ;
+
+
+
+
+
+///////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+// cClientHandle:
cClientHandle::cClientHandle(const cSocket & a_Socket)
: m_bDestroyed( false )
@@ -135,30 +154,30 @@ cClientHandle::cClientHandle(const cSocket & a_Socket)
m_pState->pSemaphore = new cSemaphore( MAX_SEMAPHORES, 0 );
// All the packets that can be received from the client
- m_pState->PacketMap[E_KEEP_ALIVE] = new cPacket_KeepAlive;
- m_pState->PacketMap[E_HANDSHAKE] = new cPacket_Handshake;
- m_pState->PacketMap[E_LOGIN] = new cPacket_Login;
- m_pState->PacketMap[E_PLAYERPOS] = new cPacket_PlayerPosition;
- m_pState->PacketMap[E_PLAYERLOOK] = new cPacket_PlayerLook;
- m_pState->PacketMap[E_PLAYERMOVELOOK] = new cPacket_PlayerMoveLook;
- m_pState->PacketMap[E_CHAT] = new cPacket_Chat;
- m_pState->PacketMap[E_ANIMATION] = new cPacket_ArmAnim;
- m_pState->PacketMap[E_FLYING] = new cPacket_Flying;
- m_pState->PacketMap[E_BLOCK_DIG] = new cPacket_BlockDig;
- m_pState->PacketMap[E_BLOCK_PLACE] = new cPacket_BlockPlace;
- m_pState->PacketMap[E_DISCONNECT] = new cPacket_Disconnect;
- m_pState->PacketMap[E_ITEM_SWITCH] = new cPacket_ItemSwitch;
- m_pState->PacketMap[E_ENTITY_EQUIPMENT] = new cPacket_EntityEquipment;
- m_pState->PacketMap[E_CREATIVE_INVENTORY_ACTION] = new cPacket_CreativeInventoryAction;
- m_pState->PacketMap[E_NEW_INVALID_STATE] = new cPacket_NewInvalidState;
- m_pState->PacketMap[E_PICKUP_SPAWN] = new cPacket_PickupSpawn;
- m_pState->PacketMap[E_USE_ENTITY] = new cPacket_UseEntity;
- m_pState->PacketMap[E_WINDOW_CLOSE] = new cPacket_WindowClose;
- m_pState->PacketMap[E_WINDOW_CLICK] = new cPacket_WindowClick;
- m_pState->PacketMap[E_PACKET_13] = new cPacket_13;
- m_pState->PacketMap[E_UPDATE_SIGN] = new cPacket_UpdateSign;
- m_pState->PacketMap[E_RESPAWN] = new cPacket_Respawn;
- m_pState->PacketMap[E_PING] = new cPacket_Ping;
+ m_pState->PacketMap[E_KEEP_ALIVE] = new cPacket_KeepAlive;
+ m_pState->PacketMap[E_HANDSHAKE] = new cPacket_Handshake;
+ m_pState->PacketMap[E_LOGIN] = new cPacket_Login;
+ m_pState->PacketMap[E_PLAYERPOS] = new cPacket_PlayerPosition;
+ m_pState->PacketMap[E_PLAYERLOOK] = new cPacket_PlayerLook;
+ m_pState->PacketMap[E_PLAYERMOVELOOK] = new cPacket_PlayerMoveLook;
+ m_pState->PacketMap[E_CHAT] = new cPacket_Chat;
+ m_pState->PacketMap[E_ANIMATION] = new cPacket_ArmAnim;
+ m_pState->PacketMap[E_FLYING] = new cPacket_Flying;
+ m_pState->PacketMap[E_BLOCK_DIG] = new cPacket_BlockDig;
+ m_pState->PacketMap[E_BLOCK_PLACE] = new cPacket_BlockPlace;
+ m_pState->PacketMap[E_DISCONNECT] = new cPacket_Disconnect;
+ m_pState->PacketMap[E_ITEM_SWITCH] = new cPacket_ItemSwitch;
+ m_pState->PacketMap[E_ENTITY_EQUIPMENT] = new cPacket_EntityEquipment;
+ m_pState->PacketMap[E_CREATIVE_INVENTORY_ACTION] = new cPacket_CreativeInventoryAction;
+ m_pState->PacketMap[E_NEW_INVALID_STATE] = new cPacket_NewInvalidState;
+ m_pState->PacketMap[E_PICKUP_SPAWN] = new cPacket_PickupSpawn;
+ m_pState->PacketMap[E_USE_ENTITY] = new cPacket_UseEntity;
+ m_pState->PacketMap[E_WINDOW_CLOSE] = new cPacket_WindowClose;
+ m_pState->PacketMap[E_WINDOW_CLICK] = new cPacket_WindowClick;
+ m_pState->PacketMap[E_PACKET_13] = new cPacket_13;
+ m_pState->PacketMap[E_UPDATE_SIGN] = new cPacket_UpdateSign;
+ m_pState->PacketMap[E_RESPAWN] = new cPacket_Respawn;
+ m_pState->PacketMap[E_PING] = new cPacket_Ping;
memset( m_LoadedChunks, 0x00, sizeof(cChunk*)*VIEWDISTANCE*VIEWDISTANCE );
@@ -172,6 +191,10 @@ cClientHandle::cClientHandle(const cSocket & a_Socket)
LOG("New ClientHandle" );
}
+
+
+
+
cClientHandle::~cClientHandle()
{
LOG("Deleting client %s", GetUsername() );
@@ -251,6 +274,10 @@ cClientHandle::~cClientHandle()
delete m_pState;
}
+
+
+
+
void cClientHandle::Destroy()
{
m_bDestroyed = true;
@@ -263,12 +290,20 @@ void cClientHandle::Destroy()
m_pState->SocketCriticalSection.Unlock();
}
+
+
+
+
void cClientHandle::Kick( const char* a_Reason )
{
Send( cPacket_Disconnect( a_Reason ) );
m_bKicking = true;
}
+
+
+
+
void cClientHandle::StreamChunks()
{
if( !m_bLoggedIn )
@@ -347,6 +382,10 @@ void cClientHandle::StreamChunks()
}
}
+
+
+
+
// Sends chunks to the player from the player position outward
void cClientHandle::StreamChunksSmart( cChunk** a_Chunks, unsigned int a_NumChunks )
{
@@ -386,6 +425,10 @@ void cClientHandle::StreamChunksSmart( cChunk** a_Chunks, unsigned int a_NumChun
}
}
+
+
+
+
// This removes the client from all chunks. Used when switching worlds
void cClientHandle::RemoveFromAllChunks()
{
@@ -400,6 +443,10 @@ void cClientHandle::RemoveFromAllChunks()
}
}
+
+
+
+
void cClientHandle::AddPacket(cPacket * a_Packet)
{
m_pState->CriticalSection.Lock();
@@ -407,12 +454,20 @@ void cClientHandle::AddPacket(cPacket * a_Packet)
m_pState->CriticalSection.Unlock();
}
+
+
+
+
void cClientHandle::RemovePacket( cPacket * a_Packet )
{
delete a_Packet;
m_pState->PendingParsePackets.remove( a_Packet );
}
+
+
+
+
void cClientHandle::HandlePendingPackets()
{
m_pState->CriticalSection.Lock();
@@ -424,12 +479,16 @@ void cClientHandle::HandlePendingPackets()
m_pState->CriticalSection.Unlock();
}
+
+
+
+
void cClientHandle::HandlePacket( cPacket* a_Packet )
{
m_TimeLastPacket = cWorld::GetTime();
-// cPacket* CopiedPacket = a_Packet->Clone();
-// a_Packet = CopiedPacket;
+ // cPacket* CopiedPacket = a_Packet->Clone();
+ // a_Packet = CopiedPacket;
//LOG("Packet: 0x%02x", a_Packet->m_PacketID );
@@ -1325,6 +1384,10 @@ void cClientHandle::HandlePacket( cPacket* a_Packet )
}
}
+
+
+
+
void cClientHandle::AuthenticateThread( void* a_Param )
{
cClientHandle* self = (cClientHandle*)a_Param;
@@ -1339,6 +1402,9 @@ void cClientHandle::AuthenticateThread( void* a_Param )
}
+
+
+
void cClientHandle::Tick(float a_Dt)
{
(void)a_Dt;
@@ -1414,6 +1480,10 @@ void cClientHandle::Tick(float a_Dt)
}
}
+
+
+
+
void cClientHandle::Send( const cPacket & a_Packet, ENUM_PRIORITY a_Priority /* = E_PRIORITY_NORMAL */ )
{
if( m_bKicking ) return; // Don't add more packets if player is getting kicked anyway
@@ -1460,6 +1530,10 @@ void cClientHandle::Send( const cPacket & a_Packet, ENUM_PRIORITY a_Priority /*
m_pState->pSemaphore->Signal();
}
+
+
+
+
void cClientHandle::SendThread( void *lpParam )
{
cClientHandle* self = (cClientHandle*)lpParam;
@@ -1539,7 +1613,8 @@ void cClientHandle::SendThread( void *lpParam )
}
-extern std::string GetWSAError();
+
+
void cClientHandle::ReceiveThread( void *lpParam )
{
@@ -1581,11 +1656,11 @@ void cClientHandle::ReceiveThread( void *lpParam )
}
else
{
- LOG("Unknown packet: 0x%2x %c %i", (unsigned char)temp, (unsigned char)temp, (unsigned char)temp );
+ LOG("Unknown packet: 0x%02x \'%c\' %i", (unsigned char)temp, (unsigned char)temp, (unsigned char)temp );
char c_Str[128];
- sprintf_s( c_Str, 128, "[C->S] Unknown PacketID: 0x%2x", (unsigned char)temp );
+ sprintf_s( c_Str, 128, "[C->S] Unknown PacketID: 0x%02x", (unsigned char)temp );
cPacket_Disconnect DC(c_Str);
DC.Send( socket );
@@ -1602,12 +1677,23 @@ void cClientHandle::ReceiveThread( void *lpParam )
}
+
+
+
const char* cClientHandle::GetUsername()
{
return m_pState->Username.c_str();
}
+
+
+
+
const cSocket & cClientHandle::GetSocket()
{
return m_pState->Socket;
}
+
+
+
+
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-21 18:01:32 +0100