1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
#pragma once
#include "../ByteBuffer.h"
#include "../ChunkData.h"
#include "../Defines.h"
#include "CircularBufferCompressor.h"
#include "StringCompression.h"
class cByteBuffer;
/** Serializes one chunk's data to (possibly multiple) protocol versions.
Caches the serialized data for as long as this object lives, so that the same data can be sent to
other clients using the same protocol. */
class cChunkDataSerializer
{
using ClientHandles = std::vector<std::shared_ptr<cClientHandle>>;
/** Enum to collapse protocol versions into a contiguous index. */
enum class CacheVersion
{
v47,
v107,
v110,
v393,
v401,
v477,
Last = CacheVersion::v477
};
/** A single cache entry containing the raw data, compressed data, and a validity flag. */
struct ChunkDataCache
{
ContiguousByteBuffer ToSend;
bool Engaged = false;
};
public:
cChunkDataSerializer(eDimension a_Dimension);
/** For each client, serializes the chunk into their protocol version and sends it.
Parameters are the coordinates of the chunk to serialise, and the data and biome data read from the chunk. */
void SendToClients(
int a_ChunkX,
int a_ChunkZ,
const ChunkBlockData & a_BlockData,
const ChunkLightData & a_LightData,
const unsigned char * a_BiomeMap,
const ClientHandles & a_SendTo
);
private:
/** Serialises the given chunk, storing the result into the given cache entry, and sends the data.
If the cache entry is already present, simply re-uses it. */
inline void Serialize(
const ClientHandles::value_type & a_Client,
int a_ChunkX,
int a_ChunkZ,
const ChunkBlockData & a_BlockData,
const ChunkLightData & a_LightData,
const unsigned char * a_BiomeMap,
CacheVersion a_CacheVersion
);
inline void Serialize47(
int a_ChunkX,
int a_ChunkZ,
const ChunkBlockData & a_BlockData,
const ChunkLightData & a_LightData,
const unsigned char * a_BiomeMap
); // Release 1.8
inline void Serialize107(
int a_ChunkX,
int a_ChunkZ,
const ChunkBlockData & a_BlockData,
const ChunkLightData & a_LightData,
const unsigned char * a_BiomeMap
); // Release 1.9
inline void Serialize110(
int a_ChunkX,
int a_ChunkZ,
const ChunkBlockData & a_BlockData,
const ChunkLightData & a_LightData,
const unsigned char * a_BiomeMap
); // Release 1.9.4
template <auto Palette>
inline void Serialize393(
int a_ChunkX,
int a_ChunkZ,
const ChunkBlockData & a_BlockData,
const ChunkLightData & a_LightData,
const unsigned char * a_BiomeMap
); // Release 1.13 - 1.13.2
inline void Serialize477(
int a_ChunkX,
int a_ChunkZ,
const ChunkBlockData & a_BlockData,
const ChunkLightData & a_LightData,
const unsigned char * a_BiomeMap
); // Release 1.14 - 1.14.4
/** Writes all blocks in a chunk section into a series of Int64.
Writes start from the bit directly subsequent to the previous write's end, possibly crossing over to the next Int64.
*/
template <auto Palette>
inline void WriteBlockSectionSeamless(
const ChunkBlockData::BlockArray * a_Blocks,
const ChunkBlockData::MetaArray * a_Metas,
UInt8 a_BitsPerEntry
);
/** Copies all lights in a chunk section into the packet, block light followed immediately by sky light. */
inline void WriteLightSectionGrouped(
const ChunkLightData::LightArray * a_BlockLights,
const ChunkLightData::LightArray * a_SkyLights
);
/** Finalises the data, compresses it if required, and stores it into cache. */
inline void CompressPacketInto(ChunkDataCache & a_Cache);
/** A staging area used to construct the chunk packet, persistent to avoid reallocating. */
cByteBuffer m_Packet;
/** A compressor used to compress the chunk data. */
CircularBufferCompressor m_Compressor;
/** The dimension for the World this Serializer is tied to. */
const eDimension m_Dimension;
/** A cache, mapping protocol version to a fully serialised chunk.
It is used during a single invocation of SendToClients with more than one client. */
std::array<ChunkDataCache, static_cast<size_t>(CacheVersion::Last) + 1> m_Cache;
};
|
