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
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
|
// BSD 3-Clause License; see https://github.com/scikit-hep/awkward/blob/main/LICENSE
#ifndef AWKWARD_FORTHOUTPUTBUFFER_H_
#define AWKWARD_FORTHOUTPUTBUFFER_H_
#include "awkward/common.h"
#include "awkward/util.h"
namespace awkward {
#define NATIVELY_BIG_ENDIAN (*(uint16_t *)"\0\xff" < 0x100)
/// @brief HERE
template <typename T>
void byteswap16(int64_t num_items, T& value);
/// @brief HERE
template <typename T>
void byteswap32(int64_t num_items, T& value);
/// @brief HERE
template <typename T>
void byteswap64(int64_t num_items, T& value);
/// @brief HERE
template <typename T>
void byteswap_intp(int64_t num_items, T& value);
/// @class ForthOutputBuffer
///
/// @brief HERE
///
/// THERE
class EXPORT_SYMBOL ForthOutputBuffer {
public:
ForthOutputBuffer(int64_t initial, double resize);
/// @brief Virtual destructor acts as a first non-inline virtual function
/// that determines a specific translation unit in which vtable shall be
/// emitted.
virtual ~ForthOutputBuffer();
/// @brief HERE
int64_t
len() const noexcept;
/// @brief HERE
void
rewind(int64_t num_items, util::ForthError& err) noexcept;
/// @brief HERE
void
reset() noexcept;
/// @brief HERE
virtual void
dup(int64_t num_times, util::ForthError& err) noexcept = 0;
/// @brief HERE
virtual const std::shared_ptr<void>
ptr() const noexcept = 0;
virtual util::dtype
dtype() const = 0;
/// @brief HERE
virtual void
write_one_bool(bool value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_int8(int8_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_int16(int16_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_int32(int32_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_int64(int64_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_intp(ssize_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_uint8(uint8_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_uint16(uint16_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_uint32(uint32_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_uint64(uint64_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_uintp(size_t value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_float32(float value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_float64(double value, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_one_string(char* string_buffer, int64_t length) noexcept = 0;
/// @brief HERE
virtual void
write_bool(int64_t num_items, bool* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_int8(int64_t num_items, int8_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_int16(int64_t num_items, int16_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_int32(int64_t num_items, int32_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_int64(int64_t num_items, int64_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_intp(int64_t num_items, ssize_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_const_uint8(int64_t num_items, const uint8_t* values) noexcept = 0;
/// @brief HERE
virtual void
write_uint8(int64_t num_items, uint8_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_uint16(int64_t num_items, uint16_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_uint32(int64_t num_items, uint32_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_uint64(int64_t num_items, uint64_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_uintp(int64_t num_items, size_t* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_float32(int64_t num_items, float* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_float64(int64_t num_items, double* values, bool byteswap) noexcept = 0;
/// @brief HERE
virtual void
write_add_int32(int32_t value) noexcept = 0;
/// @brief HERE
virtual void
write_add_int64(int64_t value) noexcept = 0;
virtual std::string
tostring() const = 0;
protected:
int64_t length_;
int64_t reserved_;
double resize_;
};
template <typename OUT>
class EXPORT_SYMBOL ForthOutputBufferOf : public ForthOutputBuffer {
public:
ForthOutputBufferOf(int64_t initial, double resize);
void
dup(int64_t num_times, util::ForthError& err) noexcept override;
const std::shared_ptr<void>
ptr() const noexcept override;
util::dtype
dtype() const override;
void
write_one_bool(bool value, bool byteswap) noexcept override;
void
write_one_int8(int8_t value, bool byteswap) noexcept override;
void
write_one_int16(int16_t value, bool byteswap) noexcept override;
void
write_one_int32(int32_t value, bool byteswap) noexcept override;
void
write_one_int64(int64_t value, bool byteswap) noexcept override;
void
write_one_intp(ssize_t value, bool byteswap) noexcept override;
void
write_one_uint8(uint8_t value, bool byteswap) noexcept override;
void
write_one_uint16(uint16_t value, bool byteswap) noexcept override;
void
write_one_uint32(uint32_t value, bool byteswap) noexcept override;
void
write_one_uint64(uint64_t value, bool byteswap) noexcept override;
void
write_one_uintp(size_t value, bool byteswap) noexcept override;
void
write_one_float32(float value, bool byteswap) noexcept override;
void
write_one_float64(double value, bool byteswap) noexcept override;
void
write_one_string(char* string_buffer, int64_t length) noexcept override;
void
write_bool(int64_t num_items, bool* values, bool byteswap) noexcept override;
void
write_int8(int64_t num_items, int8_t* values, bool byteswap) noexcept override;
void
write_int16(int64_t num_items, int16_t* values, bool byteswap) noexcept override;
void
write_int32(int64_t num_items, int32_t* values, bool byteswap) noexcept override;
void
write_int64(int64_t num_items, int64_t* values, bool byteswap) noexcept override;
void
write_intp(int64_t num_items, ssize_t* values, bool byteswap) noexcept override;
void
write_const_uint8(int64_t num_items, const uint8_t* values) noexcept override;
void
write_uint8(int64_t num_items, uint8_t* values, bool byteswap) noexcept override;
void
write_uint16(int64_t num_items, uint16_t* values, bool byteswap) noexcept override;
void
write_uint32(int64_t num_items, uint32_t* values, bool byteswap) noexcept override;
void
write_uint64(int64_t num_items, uint64_t* values, bool byteswap) noexcept override;
void
write_uintp(int64_t num_items, size_t* values, bool byteswap) noexcept override;
void
write_float32(int64_t num_items, float* values, bool byteswap) noexcept override;
void
write_float64(int64_t num_items, double* values, bool byteswap) noexcept override;
void
write_add_int32(int32_t value) noexcept override;
void
write_add_int64(int64_t value) noexcept override;
std::string tostring() const override;
private:
/// @brief HERE
void
maybe_resize(int64_t next);
/// @brief HERE
template <typename IN>
inline void write_one(IN value) noexcept {
length_++;
maybe_resize(length_);
ptr_.get()[length_ - 1] = (OUT)value;
}
/// @brief HERE
template <typename IN>
inline void write_copy(int64_t num_items, const IN* values) noexcept {
int64_t next = length_ + num_items;
maybe_resize(next);
for (int64_t i = 0; i < num_items; i++) {
ptr_.get()[length_ + i] = (OUT)values[i];
}
length_ = next;
}
std::shared_ptr<OUT> ptr_;
};
}
#endif // AWKWARD_FORTHOUTPUTBUFFER_H_
|
