Removed excessive debug logging in cProtocol132
git-svn-id: http://mc-server.googlecode.com/svn/trunk@840 0a769ca7-a7f5-676a-18bf-c427514a06d6
This commit is contained in:
parent
879806e5a1
commit
d75bdabc90
@ -70,12 +70,6 @@ enum
|
|||||||
|
|
||||||
cProtocol132::cProtocol132(cClientHandle * a_Client) :
|
cProtocol132::cProtocol132(cClientHandle * a_Client) :
|
||||||
super(a_Client),
|
super(a_Client),
|
||||||
// DEBUG:
|
|
||||||
m_CurrentIn(0),
|
|
||||||
m_CurrentOut(0),
|
|
||||||
m_EncIn(0),
|
|
||||||
m_EncOut(0),
|
|
||||||
|
|
||||||
m_IsEncrypted(false)
|
m_IsEncrypted(false)
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
@ -98,10 +92,8 @@ cProtocol132::~cProtocol132()
|
|||||||
|
|
||||||
void cProtocol132::DataReceived(const char * a_Data, int a_Size)
|
void cProtocol132::DataReceived(const char * a_Data, int a_Size)
|
||||||
{
|
{
|
||||||
m_CurrentIn += a_Size;
|
|
||||||
if (m_IsEncrypted)
|
if (m_IsEncrypted)
|
||||||
{
|
{
|
||||||
m_EncIn += a_Size;
|
|
||||||
byte Decrypted[512];
|
byte Decrypted[512];
|
||||||
while (a_Size > 0)
|
while (a_Size > 0)
|
||||||
{
|
{
|
||||||
@ -157,22 +149,17 @@ void cProtocol132::SendBlockChange(int a_BlockX, int a_BlockY, int a_BlockZ, BLO
|
|||||||
|
|
||||||
void cProtocol132::SendChunkData(int a_ChunkX, int a_ChunkZ, cChunkDataSerializer & a_Serializer)
|
void cProtocol132::SendChunkData(int a_ChunkX, int a_ChunkZ, cChunkDataSerializer & a_Serializer)
|
||||||
{
|
{
|
||||||
{
|
|
||||||
cCSLock Lock(m_CSPacket);
|
cCSLock Lock(m_CSPacket);
|
||||||
|
|
||||||
// Pre-chunk not used in 1.3.2. Finally.
|
// Pre-chunk not used in 1.3.2. Finally.
|
||||||
|
|
||||||
// Send the chunk data:
|
// Send the chunk data:
|
||||||
// Chunk data seems to break the connection for some reason; without it, the connection lives indefinitely
|
|
||||||
AString Serialized = a_Serializer.Serialize(cChunkDataSerializer::RELEASE_1_3_2);
|
AString Serialized = a_Serializer.Serialize(cChunkDataSerializer::RELEASE_1_3_2);
|
||||||
WriteByte(PACKET_CHUNK_DATA);
|
WriteByte(PACKET_CHUNK_DATA);
|
||||||
WriteInt (a_ChunkX);
|
WriteInt (a_ChunkX);
|
||||||
WriteInt (a_ChunkZ);
|
WriteInt (a_ChunkZ);
|
||||||
SendData(Serialized.data(), Serialized.size());
|
SendData(Serialized.data(), Serialized.size());
|
||||||
Flush();
|
Flush();
|
||||||
}
|
|
||||||
// Enabling the sleep here sometimes makes the client accept us and spawn us in the world. But it makes the connection lag behind, ultimately timing out
|
|
||||||
// cSleep::MilliSleep(500);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -282,9 +269,6 @@ void cProtocol132::SendUnloadChunk(int a_ChunkX, int a_ChunkZ)
|
|||||||
|
|
||||||
int cProtocol132::ParsePacket(unsigned char a_PacketType)
|
int cProtocol132::ParsePacket(unsigned char a_PacketType)
|
||||||
{
|
{
|
||||||
// DEBUG:
|
|
||||||
LOGD("Received packet 0x%02x, %d B avail; BM %d, enc %d", a_PacketType, m_ReceivedData.GetReadableSpace(), m_CurrentIn, m_EncIn);
|
|
||||||
|
|
||||||
switch (a_PacketType)
|
switch (a_PacketType)
|
||||||
{
|
{
|
||||||
default: return super::ParsePacket(a_PacketType); // off-load previously known packets into cProtocol125
|
default: return super::ParsePacket(a_PacketType); // off-load previously known packets into cProtocol125
|
||||||
@ -432,9 +416,7 @@ int cProtocol132::ParsePlayerAbilities(void)
|
|||||||
|
|
||||||
void cProtocol132::SendData(const char * a_Data, int a_Size)
|
void cProtocol132::SendData(const char * a_Data, int a_Size)
|
||||||
{
|
{
|
||||||
// DEBUG:
|
|
||||||
m_DataToSend.append(a_Data, a_Size);
|
m_DataToSend.append(a_Data, a_Size);
|
||||||
m_CurrentOut += a_Size;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -443,7 +425,6 @@ void cProtocol132::SendData(const char * a_Data, int a_Size)
|
|||||||
|
|
||||||
void cProtocol132::Flush(void)
|
void cProtocol132::Flush(void)
|
||||||
{
|
{
|
||||||
// DEBUG
|
|
||||||
ASSERT(m_CSPacket.IsLockedByCurrentThread()); // Did all packets lock the CS properly?
|
ASSERT(m_CSPacket.IsLockedByCurrentThread()); // Did all packets lock the CS properly?
|
||||||
|
|
||||||
if (m_DataToSend.empty())
|
if (m_DataToSend.empty())
|
||||||
@ -451,23 +432,15 @@ void cProtocol132::Flush(void)
|
|||||||
LOGD("Flushing empty");
|
LOGD("Flushing empty");
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
LOGD("Flushing packet 0x%02x, %d B; %d B out, %d enc out", (unsigned char)m_DataToSend[0], m_DataToSend.size(), m_CurrentOut, m_EncOut);
|
|
||||||
const char * a_Data = m_DataToSend.data();
|
const char * a_Data = m_DataToSend.data();
|
||||||
int a_Size = m_DataToSend.size();
|
int a_Size = m_DataToSend.size();
|
||||||
if (m_IsEncrypted)
|
if (m_IsEncrypted)
|
||||||
{
|
{
|
||||||
m_EncOut += a_Size;
|
|
||||||
byte Encrypted[8192]; // Larger buffer, we may be sending lots of data (chunks)
|
byte Encrypted[8192]; // Larger buffer, we may be sending lots of data (chunks)
|
||||||
while (a_Size > 0)
|
while (a_Size > 0)
|
||||||
{
|
{
|
||||||
int NumBytes = (a_Size > sizeof(Encrypted)) ? sizeof(Encrypted) : a_Size;
|
int NumBytes = (a_Size > sizeof(Encrypted)) ? sizeof(Encrypted) : a_Size;
|
||||||
m_Encryptor.ProcessData(Encrypted, (byte *)a_Data, NumBytes);
|
m_Encryptor.ProcessData(Encrypted, (byte *)a_Data, NumBytes);
|
||||||
|
|
||||||
// DEBUG: decrypt the data to check if encryption works:
|
|
||||||
byte Decrypted[sizeof(Encrypted)];
|
|
||||||
m_Decryptor2.ProcessData(Decrypted, Encrypted, NumBytes);
|
|
||||||
ASSERT(memcmp(Decrypted, a_Data, NumBytes) == 0);
|
|
||||||
|
|
||||||
super::SendData((const char *)Encrypted, NumBytes);
|
super::SendData((const char *)Encrypted, NumBytes);
|
||||||
a_Size -= NumBytes;
|
a_Size -= NumBytes;
|
||||||
a_Data += NumBytes;
|
a_Data += NumBytes;
|
||||||
@ -478,7 +451,6 @@ void cProtocol132::Flush(void)
|
|||||||
super::SendData(a_Data, a_Size);
|
super::SendData(a_Data, a_Size);
|
||||||
}
|
}
|
||||||
m_DataToSend.clear();
|
m_DataToSend.clear();
|
||||||
// cSleep::MilliSleep(400);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -567,9 +539,12 @@ void cProtocol132::SendCompass(const cWorld & a_World)
|
|||||||
|
|
||||||
void cProtocol132::SendEncryptionKeyRequest(const AString & a_Key)
|
void cProtocol132::SendEncryptionKeyRequest(const AString & a_Key)
|
||||||
{
|
{
|
||||||
|
// DEBUG:
|
||||||
|
LOGD("ServerID: \"%s\"", cRoot::Get()->GetServer()->GetServerID().c_str());
|
||||||
|
|
||||||
cCSLock Lock(m_CSPacket);
|
cCSLock Lock(m_CSPacket);
|
||||||
WriteByte((char)0xfd);
|
WriteByte((char)0xfd);
|
||||||
WriteString("MCServer");
|
WriteString(cRoot::Get()->GetServer()->GetServerID());
|
||||||
WriteShort((short)a_Key.size());
|
WriteShort((short)a_Key.size());
|
||||||
SendData(a_Key.data(), a_Key.size());
|
SendData(a_Key.data(), a_Key.size());
|
||||||
WriteShort(4);
|
WriteShort(4);
|
||||||
@ -634,7 +609,6 @@ void cProtocol132::StartEncryption(const byte * a_Key)
|
|||||||
{
|
{
|
||||||
m_Encryptor.SetKey(a_Key, 16, MakeParameters(Name::IV(), ConstByteArrayParameter(a_Key, 16))(Name::FeedbackSize(), 1));
|
m_Encryptor.SetKey(a_Key, 16, MakeParameters(Name::IV(), ConstByteArrayParameter(a_Key, 16))(Name::FeedbackSize(), 1));
|
||||||
m_Decryptor.SetKey(a_Key, 16, MakeParameters(Name::IV(), ConstByteArrayParameter(a_Key, 16))(Name::FeedbackSize(), 1));
|
m_Decryptor.SetKey(a_Key, 16, MakeParameters(Name::IV(), ConstByteArrayParameter(a_Key, 16))(Name::FeedbackSize(), 1));
|
||||||
m_Decryptor2.SetKey(a_Key, 16, MakeParameters(Name::IV(), ConstByteArrayParameter(a_Key, 16))(Name::FeedbackSize(), 1));
|
|
||||||
m_IsEncrypted = true;
|
m_IsEncrypted = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -62,12 +62,7 @@ protected:
|
|||||||
bool m_IsEncrypted;
|
bool m_IsEncrypted;
|
||||||
CryptoPP::CFB_Mode<CryptoPP::AES>::Decryption m_Decryptor;
|
CryptoPP::CFB_Mode<CryptoPP::AES>::Decryption m_Decryptor;
|
||||||
CryptoPP::CFB_Mode<CryptoPP::AES>::Encryption m_Encryptor;
|
CryptoPP::CFB_Mode<CryptoPP::AES>::Encryption m_Encryptor;
|
||||||
|
|
||||||
// DEBUG:
|
|
||||||
CryptoPP::CFB_Mode<CryptoPP::AES>::Decryption m_Decryptor2;
|
|
||||||
AString m_DataToSend;
|
AString m_DataToSend;
|
||||||
int m_CurrentIn, m_CurrentOut;
|
|
||||||
int m_EncIn, m_EncOut;
|
|
||||||
|
|
||||||
virtual void SendData(const char * a_Data, int a_Size) override;
|
virtual void SendData(const char * a_Data, int a_Size) override;
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user