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
|
#include "Stream.h"
namespace Death { namespace IO {
//###==##====#=====--==~--~=~- --- -- - - - -
std::int64_t Stream::CopyTo(Stream& targetStream)
{
#if defined(DEATH_TARGET_EMSCRIPTEN)
constexpr std::int32_t BufferSize = 8192;
#else
constexpr std::int32_t BufferSize = 16384;
#endif
char buffer[BufferSize];
std::int64_t bytesWrittenTotal = 0;
while (true) {
std::int64_t bytesRead = Read(buffer, BufferSize);
if (bytesRead <= 0) {
break;
}
std::int64_t bytesWritten = targetStream.Write(buffer, bytesRead);
bytesWrittenTotal += bytesWritten;
if (bytesWritten < bytesRead) {
break;
}
}
return bytesWrittenTotal;
}
std::int32_t Stream::ReadVariableInt32()
{
std::uint32_t n = ReadVariableUint32();
return (std::int32_t)(n >> 1) ^ -(std::int32_t)(n & 1);
}
std::int64_t Stream::ReadVariableInt64()
{
std::uint64_t n = ReadVariableUint64();
return (std::int64_t)(n >> 1) ^ -(std::int64_t)(n & 1);
}
std::uint32_t Stream::ReadVariableUint32()
{
std::uint32_t result = 0;
std::uint32_t shift = 0;
while (true) {
std::uint8_t byte;
if (Read(&byte, 1) == 0) {
break;
}
result |= (std::uint32_t)(byte & 0x7f) << shift;
shift += 7;
if ((byte & 0x80) == 0) {
break;
}
}
return result;
}
std::uint64_t Stream::ReadVariableUint64()
{
std::uint64_t result = 0;
std::uint64_t shift = 0;
while (true) {
std::uint8_t byte;
if (Read(&byte, 1) == 0) {
break;
}
result |= (std::uint64_t)(byte & 0x7f) << shift;
shift += 7;
if ((byte & 0x80) == 0) {
break;
}
}
return result;
}
std::int64_t Stream::WriteVariableInt32(std::int32_t value)
{
std::uint32_t n = (std::uint32_t)(value << 1) ^ (std::uint32_t)(value >> 31);
return WriteVariableUint32(n);
}
std::int64_t Stream::WriteVariableInt64(std::int64_t value)
{
std::uint64_t n = (std::uint64_t)(value << 1) ^ (std::uint64_t)(value >> 63);
return WriteVariableUint64(n);
}
std::int64_t Stream::WriteVariableUint32(std::uint32_t value)
{
std::int32_t bytesWritten = 1;
std::uint32_t valueLeft = value;
while (valueLeft >= 0x80) {
WriteValue((std::uint8_t)(valueLeft | 0x80));
valueLeft = valueLeft >> 7;
bytesWritten++;
}
WriteValue((std::uint8_t)valueLeft);
return bytesWritten;
}
std::int64_t Stream::WriteVariableUint64(std::uint64_t value)
{
std::int32_t bytesWritten = 1;
std::uint64_t valueLeft = value;
while (valueLeft >= 0x80) {
WriteValue((std::uint8_t)(valueLeft | 0x80));
valueLeft = valueLeft >> 7;
bytesWritten++;
}
WriteValue((std::uint8_t)valueLeft);
return bytesWritten;
}
}}
|
