-
Notifications
You must be signed in to change notification settings - Fork 3
/
Copy pathbyte_buffer.h
123 lines (105 loc) · 2.91 KB
/
byte_buffer.h
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
// The core library - copyright GarageGames. The core library is released under the MIT Open Source software license. See /license.txt in this distribution for specific license terms.
class byte_buffer : public ref_object
{
protected:
/// Pointer to our data buffer.
uint8 *_data_ptr;
/// Length of buffer.
uint32 _buf_size;
public:
enum {
default_buffer_size = 1500,
};
byte_buffer(const char *string)
{
_buf_size = strlen(string) + 1;
_data_ptr = (uint8 *) memory_allocate(_buf_size);
memcpy(_data_ptr, (const uint8 *) string, _buf_size);
}
/// Create a byte_buffer from a chunk of memory.
byte_buffer(const uint8 *data_ptr, uint32 buffer_size)
{
_buf_size = buffer_size;
_data_ptr = (uint8 *) memory_allocate(buffer_size);
memcpy(_data_ptr, data_ptr, buffer_size);
}
/// Create a byte_buffer of the specified size.
byte_buffer(uint32 buffer_size = default_buffer_size)
{
_buf_size = buffer_size;
_data_ptr = (uint8 *) malloc(buffer_size);
}
~byte_buffer()
{
memory_deallocate(_data_ptr);
}
/// Set the byte_buffer to point to a new chunk of memory.
void set_buffer(uint8 *data_ptr, uint32 buffer_size)
{
memory_deallocate(_data_ptr);
_data_ptr = (uint8 *) memory_allocate(buffer_size);
_buf_size = buffer_size;
memcpy(_data_ptr, data_ptr, buffer_size);
}
/// Attempts to resize the buffer.
///
void resize(uint32 new_buffer_size)
{
if(_buf_size >= new_buffer_size)
_buf_size = new_buffer_size;
else
{
_buf_size = new_buffer_size;
_data_ptr = (uint8 *) memory_reallocate(_data_ptr, new_buffer_size);
}
}
/// Appends the specified buffer to the end of the byte buffer.
void append_buffer(const uint8 *data_buffer, uint32 buffer_size)
{
uint32 start = _buf_size;
resize(_buf_size + buffer_size);
memcpy(_data_ptr + start, data_buffer, buffer_size);
}
/// Appends the specified byte_buffer to the end of this byte buffer.
void append_buffer(const byte_buffer &the_buffer)
{
return append_buffer(the_buffer.get_buffer(), the_buffer.get_buffer_size());
}
bool is_equal(const byte_buffer &the_buffer)
{
if(the_buffer._buf_size != _buf_size)
return false;
return !memcmp(the_buffer._data_ptr, _data_ptr, _buf_size);
}
uint32 get_buffer_size() const
{
return _buf_size;
}
uint8 *get_buffer()
{
return _data_ptr;
}
const uint8 *get_buffer() const
{
return _data_ptr;
}
/// Clear the buffer.
void clear()
{
memset(_data_ptr, 0, _buf_size);
}
};
typedef ref_ptr<byte_buffer> byte_buffer_ptr;
template <class stream> inline bool write(stream &the_stream, const byte_buffer_ptr &buffer)
{
uint32 len = buffer->get_buffer_size();
write(the_stream, len);
return the_stream.write_bytes(buffer->get_buffer(), len);
}
template <class stream> inline bool read(stream &the_stream, byte_buffer_ptr &buffer)
{
uint32 len;
read(the_stream, len);
buffer = new byte_buffer(len);
return the_stream.read_bytes(buffer->get_buffer(), len);
}