celisej567/mcpe
1
0
Fork 0
mirror of https://github.com/celisej567/mcpe.git synced 2026-01-04 14:09:47 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

* Move client/common/ and client/network/ into common/ and network/ respectively.

Browse Source
This commit is contained in:
iProgramInCpp
2023-08-19 10:05:48 +03:00
parent a689ee7365
commit 919e4d8625
92 changed files with 238 additions and 238 deletions
Download Patch File Download Diff File Expand all files Collapse all files

86
source/network/packets/LevelDataPacket.cpp Normal file
View File

@@ -0,0 +1,86 @@
/********************************************************************
Minecraft: Pocket Edition - Decompilation Project
Copyright (C) 2023 iProgramInCpp
The following code is licensed under the BSD 1 clause license.
SPDX-License-Identifier: BSD-1-Clause
********************************************************************/
#include "../Packet.hpp"
#include "world/level/levelgen/chunk/LevelChunk.hpp"
void LevelDataPacket::handle(const RakNet::RakNetGUID& guid, NetEventCallback* pCallback)
{
pCallback->handle(guid, this);
}
void LevelDataPacket::write(RakNet::BitStream* pbs)
{
// @TODO: Maybe offload this to a different 'worker thread'? Or maybe just the compression job?
// send a crapton of them in a raw packet(why? Laziness)
int chunksX = C_MAX_CHUNKS_X;
int chunksZ = C_MAX_CHUNKS_Z;
int minus9999 = -9999;
RakNet::BitStream bs;
pbs->Write(PACKET_LEVEL_DATA);
int uncompMagic = 12847812, compMagic = 58712758, chunkSepMagic = 284787658;
bs.Write(uncompMagic);
bs.Write(chunksX);
bs.Write(chunksZ);
for (int x = 0; x < chunksX; x++)
{
for (int z = 0; z < chunksZ; z++)
{
bs.Write(chunkSepMagic);
RakNet::BitStream bs2;
LevelChunk* pChunk = m_pLevel->getChunk(x, z);
ChunkDataPacket cdp(x, z, pChunk);
cdp.write(&bs2);
int dataSize = int(bs2.GetNumberOfBytesUsed());
bs.Write(dataSize);
bs.Write((const char*)bs2.GetData(), dataSize);
}
}
// compress it
size_t compSize = 0;
size_t uncompSize = bs.GetNumberOfBytesUsed();
uint8_t* pCompressedData = nullptr;
if (uncompSize > 1024)
{
// takes about 5ms on release to compress everything on L4, compression ratio is around 14-15%.
// Increase or decrease this depending on your server's load.
pCompressedData = ZlibDeflateToMemoryLvl(bs.GetData(), uncompSize, &compSize, 4);
}
if (pCompressedData)
{
float ratio = 100.0f * float(compSize) / float(uncompSize);
//LogMsg("Compression ratio: %.2f (%d comp, %d uncomp)", ratio, int(compSize), int(uncompSize));
int cs2 = int(compSize), us2 = int(uncompSize);
bs.Reset();
bs.Write(compMagic);
bs.Write(us2);
bs.Write(cs2);
bs.Write((const char*)pCompressedData, compSize);
SAFE_DELETE_ARRAY(pCompressedData);
}
else
{
//LogMsg("Level not compressed.");
}
pbs->Write(bs);
return;
}
void LevelDataPacket::read(RakNet::BitStream* bs)
{
bs->Read(m_data);
}