blob: 6cb71fd3ba20e69e893b31be8dae075cb7218939 [file] [log] [blame]
Anthony Barbier6ff3b192017-09-04 18:44:23 +01001/*
Giorgio Arenaa66eaa22017-12-21 19:50:06 +00002 * Copyright (c) 2016-2018 ARM Limited.
Anthony Barbier6ff3b192017-09-04 18:44:23 +01003 *
4 * SPDX-License-Identifier: MIT
5 *
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to
8 * deal in the Software without restriction, including without limitation the
9 * rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
10 * sell copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
12 *
13 * The above copyright notice and this permission notice shall be included in all
14 * copies or substantial portions of the Software.
15 *
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
19 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
22 * SOFTWARE.
23 */
24#ifndef __UTILS_UTILS_H__
25#define __UTILS_UTILS_H__
26
27#include "arm_compute/core/Helpers.h"
28#include "arm_compute/core/ITensor.h"
29#include "arm_compute/core/Types.h"
30#include "arm_compute/core/Validate.h"
steniu01bee466b2017-06-21 16:45:41 +010031#include "arm_compute/core/Window.h"
Anthony Barbier6ff3b192017-09-04 18:44:23 +010032#include "arm_compute/runtime/Tensor.h"
Giorgio Arenacf3935f2017-10-26 17:14:13 +010033#include "libnpy/npy.hpp"
Anthony Barbier2a07e182017-08-04 18:20:27 +010034#include "support/ToolchainSupport.h"
Anthony Barbier6ff3b192017-09-04 18:44:23 +010035
36#ifdef ARM_COMPUTE_CL
37#include "arm_compute/core/CL/OpenCL.h"
Isabella Gottardi02aabcc2017-10-12 17:28:51 +010038#include "arm_compute/runtime/CL/CLDistribution1D.h"
Anthony Barbier6ff3b192017-09-04 18:44:23 +010039#include "arm_compute/runtime/CL/CLTensor.h"
40#endif /* ARM_COMPUTE_CL */
Anthony Barbier7068f992017-10-26 15:23:08 +010041#ifdef ARM_COMPUTE_GC
42#include "arm_compute/runtime/GLES_COMPUTE/GCTensor.h"
43#endif /* ARM_COMPUTE_GC */
Anthony Barbier6ff3b192017-09-04 18:44:23 +010044
45#include <cstdlib>
46#include <cstring>
47#include <fstream>
48#include <iostream>
Giorgio Arenacf3935f2017-10-26 17:14:13 +010049#include <random>
50#include <string>
51#include <tuple>
52#include <vector>
Anthony Barbier6ff3b192017-09-04 18:44:23 +010053
54namespace arm_compute
55{
56namespace utils
57{
Anthony Barbier6db0ff52018-01-05 10:59:12 +000058/** Abstract Example class.
59 *
60 * All examples have to inherit from this class.
61 */
62class Example
63{
64public:
Alex Gildayc357c472018-03-21 13:54:09 +000065 /** Setup the example.
66 *
67 * @param[in] argc Argument count.
68 * @param[in] argv Argument values.
69 */
Anthony Barbier6db0ff52018-01-05 10:59:12 +000070 virtual void do_setup(int argc, char **argv) {};
Alex Gildayc357c472018-03-21 13:54:09 +000071 /** Run the example. */
Anthony Barbier6db0ff52018-01-05 10:59:12 +000072 virtual void do_run() {};
Alex Gildayc357c472018-03-21 13:54:09 +000073 /** Teardown the example. */
Anthony Barbier6db0ff52018-01-05 10:59:12 +000074 virtual void do_teardown() {};
75
76 /** Default destructor. */
77 virtual ~Example() = default;
78};
79
80/** Run an example and handle the potential exceptions it throws
81 *
82 * @param[in] argc Number of command line arguments
83 * @param[in] argv Command line arguments
84 * @param[in] example Example to run
85 */
Anthony Barbier9fb0cac2018-04-20 15:46:21 +010086int run_example(int argc, char **argv, std::unique_ptr<Example> example);
Anthony Barbier6db0ff52018-01-05 10:59:12 +000087
88template <typename T>
89int run_example(int argc, char **argv)
90{
Anthony Barbier9fb0cac2018-04-20 15:46:21 +010091 return run_example(argc, argv, support::cpp14::make_unique<T>());
Anthony Barbier6db0ff52018-01-05 10:59:12 +000092}
Anthony Barbier6ff3b192017-09-04 18:44:23 +010093
94/** Draw a RGB rectangular window for the detected object
95 *
96 * @param[in, out] tensor Input tensor where the rectangle will be drawn on. Format supported: RGB888
97 * @param[in] rect Geometry of the rectangular window
98 * @param[in] r Red colour to use
99 * @param[in] g Green colour to use
100 * @param[in] b Blue colour to use
101 */
102void draw_detection_rectangle(arm_compute::ITensor *tensor, const arm_compute::DetectionWindow &rect, uint8_t r, uint8_t g, uint8_t b);
103
104/** Parse the ppm header from an input file stream. At the end of the execution,
105 * the file position pointer will be located at the first pixel stored in the ppm file
106 *
107 * @param[in] fs Input file stream to parse
108 *
109 * @return The width, height and max value stored in the header of the PPM file
110 */
111std::tuple<unsigned int, unsigned int, int> parse_ppm_header(std::ifstream &fs);
112
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100113/** Parse the npy header from an input file stream. At the end of the execution,
114 * the file position pointer will be located at the first pixel stored in the npy file //TODO
115 *
116 * @param[in] fs Input file stream to parse
117 *
118 * @return The width and height stored in the header of the NPY file
119 */
120std::tuple<std::vector<unsigned long>, bool, std::string> parse_npy_header(std::ifstream &fs);
121
122/** Obtain numpy type string from DataType.
123 *
124 * @param[in] data_type Data type.
125 *
126 * @return numpy type string.
127 */
128inline std::string get_typestring(DataType data_type)
129{
130 // Check endianness
131 const unsigned int i = 1;
132 const char *c = reinterpret_cast<const char *>(&i);
133 std::string endianness;
134 if(*c == 1)
135 {
136 endianness = std::string("<");
137 }
138 else
139 {
140 endianness = std::string(">");
141 }
142 const std::string no_endianness("|");
143
144 switch(data_type)
145 {
146 case DataType::U8:
Giorgio Arenaa66eaa22017-12-21 19:50:06 +0000147 case DataType::QASYMM8:
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100148 return no_endianness + "u" + support::cpp11::to_string(sizeof(uint8_t));
149 case DataType::S8:
150 return no_endianness + "i" + support::cpp11::to_string(sizeof(int8_t));
151 case DataType::U16:
152 return endianness + "u" + support::cpp11::to_string(sizeof(uint16_t));
153 case DataType::S16:
154 return endianness + "i" + support::cpp11::to_string(sizeof(int16_t));
155 case DataType::U32:
156 return endianness + "u" + support::cpp11::to_string(sizeof(uint32_t));
157 case DataType::S32:
158 return endianness + "i" + support::cpp11::to_string(sizeof(int32_t));
159 case DataType::U64:
160 return endianness + "u" + support::cpp11::to_string(sizeof(uint64_t));
161 case DataType::S64:
162 return endianness + "i" + support::cpp11::to_string(sizeof(int64_t));
163 case DataType::F32:
164 return endianness + "f" + support::cpp11::to_string(sizeof(float));
165 case DataType::F64:
166 return endianness + "f" + support::cpp11::to_string(sizeof(double));
167 case DataType::SIZET:
168 return endianness + "u" + support::cpp11::to_string(sizeof(size_t));
169 default:
170 ARM_COMPUTE_ERROR("NOT SUPPORTED!");
171 }
172}
173
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100174/** Maps a tensor if needed
175 *
176 * @param[in] tensor Tensor to be mapped
177 * @param[in] blocking Specified if map is blocking or not
178 */
179template <typename T>
Gian Marco Iodiceae27e942017-09-28 18:31:26 +0100180inline void map(T &tensor, bool blocking)
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100181{
182 ARM_COMPUTE_UNUSED(tensor);
183 ARM_COMPUTE_UNUSED(blocking);
184}
185
186/** Unmaps a tensor if needed
187 *
188 * @param tensor Tensor to be unmapped
189 */
190template <typename T>
Gian Marco Iodiceae27e942017-09-28 18:31:26 +0100191inline void unmap(T &tensor)
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100192{
193 ARM_COMPUTE_UNUSED(tensor);
194}
195
196#ifdef ARM_COMPUTE_CL
197/** Maps a tensor if needed
198 *
199 * @param[in] tensor Tensor to be mapped
200 * @param[in] blocking Specified if map is blocking or not
201 */
Gian Marco Iodiceae27e942017-09-28 18:31:26 +0100202inline void map(CLTensor &tensor, bool blocking)
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100203{
204 tensor.map(blocking);
205}
206
207/** Unmaps a tensor if needed
208 *
209 * @param tensor Tensor to be unmapped
210 */
Gian Marco Iodiceae27e942017-09-28 18:31:26 +0100211inline void unmap(CLTensor &tensor)
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100212{
213 tensor.unmap();
214}
Isabella Gottardi02aabcc2017-10-12 17:28:51 +0100215
216/** Maps a distribution if needed
217 *
218 * @param[in] distribution Distribution to be mapped
219 * @param[in] blocking Specified if map is blocking or not
220 */
221inline void map(CLDistribution1D &distribution, bool blocking)
222{
223 distribution.map(blocking);
224}
225
226/** Unmaps a distribution if needed
227 *
228 * @param distribution Distribution to be unmapped
229 */
230inline void unmap(CLDistribution1D &distribution)
231{
232 distribution.unmap();
233}
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100234#endif /* ARM_COMPUTE_CL */
235
Anthony Barbier7068f992017-10-26 15:23:08 +0100236#ifdef ARM_COMPUTE_GC
237/** Maps a tensor if needed
238 *
239 * @param[in] tensor Tensor to be mapped
240 * @param[in] blocking Specified if map is blocking or not
241 */
242inline void map(GCTensor &tensor, bool blocking)
243{
244 tensor.map(blocking);
245}
246
247/** Unmaps a tensor if needed
248 *
249 * @param tensor Tensor to be unmapped
250 */
251inline void unmap(GCTensor &tensor)
252{
253 tensor.unmap();
254}
255#endif /* ARM_COMPUTE_GC */
256
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100257/** Class to load the content of a PPM file into an Image
258 */
259class PPMLoader
260{
261public:
262 PPMLoader()
263 : _fs(), _width(0), _height(0)
264 {
265 }
266 /** Open a PPM file and reads its metadata (Width, height)
267 *
268 * @param[in] ppm_filename File to open
269 */
270 void open(const std::string &ppm_filename)
271 {
272 ARM_COMPUTE_ERROR_ON(is_open());
273 try
274 {
275 _fs.exceptions(std::ifstream::failbit | std::ifstream::badbit);
276 _fs.open(ppm_filename, std::ios::in | std::ios::binary);
277
278 unsigned int max_val = 0;
279 std::tie(_width, _height, max_val) = parse_ppm_header(_fs);
280
281 ARM_COMPUTE_ERROR_ON_MSG(max_val >= 256, "2 bytes per colour channel not supported in file %s", ppm_filename.c_str());
282 }
Anthony Barbier6db0ff52018-01-05 10:59:12 +0000283 catch(std::runtime_error &e)
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100284 {
285 ARM_COMPUTE_ERROR("Accessing %s: %s", ppm_filename.c_str(), e.what());
286 }
287 }
288 /** Return true if a PPM file is currently open
289 */
290 bool is_open()
291 {
292 return _fs.is_open();
293 }
294
295 /** Initialise an image's metadata with the dimensions of the PPM file currently open
296 *
297 * @param[out] image Image to initialise
298 * @param[in] format Format to use for the image (Must be RGB888 or U8)
299 */
300 template <typename T>
301 void init_image(T &image, arm_compute::Format format)
302 {
303 ARM_COMPUTE_ERROR_ON(!is_open());
304 ARM_COMPUTE_ERROR_ON(format != arm_compute::Format::RGB888 && format != arm_compute::Format::U8);
305
306 // Use the size of the input PPM image
307 arm_compute::TensorInfo image_info(_width, _height, format);
308 image.allocator()->init(image_info);
309 }
310
311 /** Fill an image with the content of the currently open PPM file.
312 *
313 * @note If the image is a CLImage, the function maps and unmaps the image
314 *
315 * @param[in,out] image Image to fill (Must be allocated, and of matching dimensions with the opened PPM).
316 */
317 template <typename T>
318 void fill_image(T &image)
319 {
320 ARM_COMPUTE_ERROR_ON(!is_open());
321 ARM_COMPUTE_ERROR_ON(image.info()->dimension(0) != _width || image.info()->dimension(1) != _height);
322 ARM_COMPUTE_ERROR_ON_FORMAT_NOT_IN(&image, arm_compute::Format::U8, arm_compute::Format::RGB888);
323 try
324 {
Anthony Barbier7068f992017-10-26 15:23:08 +0100325 // Map buffer if creating a CLTensor/GCTensor
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100326 map(image, true);
327
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100328 // Check if the file is large enough to fill the image
329 const size_t current_position = _fs.tellg();
330 _fs.seekg(0, std::ios_base::end);
331 const size_t end_position = _fs.tellg();
332 _fs.seekg(current_position, std::ios_base::beg);
333
334 ARM_COMPUTE_ERROR_ON_MSG((end_position - current_position) < image.info()->tensor_shape().total_size() * image.info()->element_size(),
335 "Not enough data in file");
336 ARM_COMPUTE_UNUSED(end_position);
337
338 switch(image.info()->format())
339 {
340 case arm_compute::Format::U8:
341 {
342 // We need to convert the data from RGB to grayscale:
343 // Iterate through every pixel of the image
344 arm_compute::Window window;
345 window.set(arm_compute::Window::DimX, arm_compute::Window::Dimension(0, _width, 1));
346 window.set(arm_compute::Window::DimY, arm_compute::Window::Dimension(0, _height, 1));
347
348 arm_compute::Iterator out(&image, window);
349
350 unsigned char red = 0;
351 unsigned char green = 0;
352 unsigned char blue = 0;
353
354 arm_compute::execute_window_loop(window, [&](const arm_compute::Coordinates & id)
355 {
356 red = _fs.get();
357 green = _fs.get();
358 blue = _fs.get();
359
360 *out.ptr() = 0.2126f * red + 0.7152f * green + 0.0722f * blue;
361 },
362 out);
363
364 break;
365 }
366 case arm_compute::Format::RGB888:
367 {
368 // There is no format conversion needed: we can simply copy the content of the input file to the image one row at the time.
369 // Create a vertical window to iterate through the image's rows:
370 arm_compute::Window window;
371 window.set(arm_compute::Window::DimY, arm_compute::Window::Dimension(0, _height, 1));
372
373 arm_compute::Iterator out(&image, window);
374
375 arm_compute::execute_window_loop(window, [&](const arm_compute::Coordinates & id)
376 {
377 // Copy one row from the input file to the current row of the image:
378 _fs.read(reinterpret_cast<std::fstream::char_type *>(out.ptr()), _width * image.info()->element_size());
379 },
380 out);
381
382 break;
383 }
384 default:
385 ARM_COMPUTE_ERROR("Unsupported format");
386 }
387
Anthony Barbier7068f992017-10-26 15:23:08 +0100388 // Unmap buffer if creating a CLTensor/GCTensor
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100389 unmap(image);
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100390 }
391 catch(const std::ifstream::failure &e)
392 {
393 ARM_COMPUTE_ERROR("Loading PPM file: %s", e.what());
394 }
395 }
396
Gian Marco44ec2e72017-10-19 14:13:38 +0100397 /** Fill a tensor with 3 planes (one for each channel) with the content of the currently open PPM file.
398 *
399 * @note If the image is a CLImage, the function maps and unmaps the image
400 *
401 * @param[in,out] tensor Tensor with 3 planes to fill (Must be allocated, and of matching dimensions with the opened PPM). Data types supported: U8/F32
402 * @param[in] bgr (Optional) Fill the first plane with blue channel (default = false)
403 */
404 template <typename T>
405 void fill_planar_tensor(T &tensor, bool bgr = false)
406 {
407 ARM_COMPUTE_ERROR_ON(!is_open());
408 ARM_COMPUTE_ERROR_ON_DATA_TYPE_CHANNEL_NOT_IN(&tensor, 1, DataType::U8, DataType::F32);
Georgios Pinitascac13b12018-04-27 19:07:19 +0100409
410 const DataLayout data_layout = tensor.info()->data_layout();
411 const TensorShape tensor_shape = tensor.info()->tensor_shape();
412
413 ARM_COMPUTE_UNUSED(tensor_shape);
414 ARM_COMPUTE_ERROR_ON(tensor_shape[get_data_layout_dimension_index(data_layout, DataLayoutDimension::WIDTH)] != _width);
415 ARM_COMPUTE_ERROR_ON(tensor_shape[get_data_layout_dimension_index(data_layout, DataLayoutDimension::HEIGHT)] != _height);
416 ARM_COMPUTE_ERROR_ON(tensor_shape[get_data_layout_dimension_index(data_layout, DataLayoutDimension::CHANNEL)] != 3);
Gian Marco44ec2e72017-10-19 14:13:38 +0100417
418 try
419 {
420 // Map buffer if creating a CLTensor
421 map(tensor, true);
422
423 // Check if the file is large enough to fill the image
424 const size_t current_position = _fs.tellg();
425 _fs.seekg(0, std::ios_base::end);
426 const size_t end_position = _fs.tellg();
427 _fs.seekg(current_position, std::ios_base::beg);
428
429 ARM_COMPUTE_ERROR_ON_MSG((end_position - current_position) < tensor.info()->tensor_shape().total_size(),
430 "Not enough data in file");
431 ARM_COMPUTE_UNUSED(end_position);
432
Georgios Pinitascac13b12018-04-27 19:07:19 +0100433 // Stride across channels
434 size_t stride_z = 0;
435
Gian Marco44ec2e72017-10-19 14:13:38 +0100436 // Iterate through every pixel of the image
437 arm_compute::Window window;
Georgios Pinitascac13b12018-04-27 19:07:19 +0100438 if(data_layout == DataLayout::NCHW)
439 {
440 window.set(arm_compute::Window::DimX, arm_compute::Window::Dimension(0, _width, 1));
441 window.set(arm_compute::Window::DimY, arm_compute::Window::Dimension(0, _height, 1));
442 window.set(arm_compute::Window::DimZ, arm_compute::Window::Dimension(0, 1, 1));
443 stride_z = tensor.info()->strides_in_bytes()[2];
444 }
445 else
446 {
447 window.set(arm_compute::Window::DimX, arm_compute::Window::Dimension(0, 1, 1));
448 window.set(arm_compute::Window::DimY, arm_compute::Window::Dimension(0, _width, 1));
449 window.set(arm_compute::Window::DimZ, arm_compute::Window::Dimension(0, _height, 1));
450 stride_z = tensor.info()->strides_in_bytes()[0];
451 }
Gian Marco44ec2e72017-10-19 14:13:38 +0100452
453 arm_compute::Iterator out(&tensor, window);
454
455 unsigned char red = 0;
456 unsigned char green = 0;
457 unsigned char blue = 0;
458
Gian Marco44ec2e72017-10-19 14:13:38 +0100459 arm_compute::execute_window_loop(window, [&](const arm_compute::Coordinates & id)
460 {
461 red = _fs.get();
462 green = _fs.get();
463 blue = _fs.get();
464
465 switch(tensor.info()->data_type())
466 {
467 case arm_compute::DataType::U8:
468 {
469 *(out.ptr() + 0 * stride_z) = bgr ? blue : red;
470 *(out.ptr() + 1 * stride_z) = green;
471 *(out.ptr() + 2 * stride_z) = bgr ? red : blue;
472 break;
473 }
474 case arm_compute::DataType::F32:
475 {
476 *reinterpret_cast<float *>(out.ptr() + 0 * stride_z) = static_cast<float>(bgr ? blue : red);
477 *reinterpret_cast<float *>(out.ptr() + 1 * stride_z) = static_cast<float>(green);
478 *reinterpret_cast<float *>(out.ptr() + 2 * stride_z) = static_cast<float>(bgr ? red : blue);
479 break;
480 }
481 default:
482 {
483 ARM_COMPUTE_ERROR("Unsupported data type");
484 }
485 }
486 },
487 out);
488
489 // Unmap buffer if creating a CLTensor
490 unmap(tensor);
491 }
492 catch(const std::ifstream::failure &e)
493 {
494 ARM_COMPUTE_ERROR("Loading PPM file: %s", e.what());
495 }
496 }
497
Isabella Gottardia4c61882017-11-03 12:11:55 +0000498 /** Return the width of the currently open PPM file.
499 */
500 unsigned int width() const
501 {
502 return _width;
503 }
504
505 /** Return the height of the currently open PPM file.
506 */
507 unsigned int height() const
508 {
509 return _height;
510 }
511
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100512private:
513 std::ifstream _fs;
514 unsigned int _width, _height;
515};
516
Alex Gildayc357c472018-03-21 13:54:09 +0000517/** Numpy data loader */
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100518class NPYLoader
519{
520public:
Alex Gildayc357c472018-03-21 13:54:09 +0000521 /** Default constructor */
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100522 NPYLoader()
523 : _fs(), _shape(), _fortran_order(false), _typestring()
524 {
525 }
526
527 /** Open a NPY file and reads its metadata
528 *
529 * @param[in] npy_filename File to open
530 */
531 void open(const std::string &npy_filename)
532 {
533 ARM_COMPUTE_ERROR_ON(is_open());
534 try
535 {
536 _fs.exceptions(std::ifstream::failbit | std::ifstream::badbit);
537 _fs.open(npy_filename, std::ios::in | std::ios::binary);
538
539 std::tie(_shape, _fortran_order, _typestring) = parse_npy_header(_fs);
540 }
541 catch(const std::ifstream::failure &e)
542 {
543 ARM_COMPUTE_ERROR("Accessing %s: %s", npy_filename.c_str(), e.what());
544 }
545 }
546 /** Return true if a NPY file is currently open */
547 bool is_open()
548 {
549 return _fs.is_open();
550 }
551
552 /** Return true if a NPY file is in fortran order */
553 bool is_fortran()
554 {
555 return _fortran_order;
556 }
557
Gian Marco0bc5a252017-12-04 13:55:08 +0000558 /** Initialise the tensor's metadata with the dimensions of the NPY file currently open
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100559 *
560 * @param[out] tensor Tensor to initialise
Gian Marco0bc5a252017-12-04 13:55:08 +0000561 * @param[in] dt Data type to use for the tensor
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100562 */
563 template <typename T>
Gian Marco0bc5a252017-12-04 13:55:08 +0000564 void init_tensor(T &tensor, arm_compute::DataType dt)
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100565 {
566 ARM_COMPUTE_ERROR_ON(!is_open());
Gian Marco0bc5a252017-12-04 13:55:08 +0000567 ARM_COMPUTE_ERROR_ON(dt != arm_compute::DataType::F32);
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100568
569 // Use the size of the input NPY tensor
570 TensorShape shape;
571 shape.set_num_dimensions(_shape.size());
572 for(size_t i = 0; i < _shape.size(); ++i)
573 {
574 shape.set(i, _shape.at(i));
575 }
576
Gian Marco0bc5a252017-12-04 13:55:08 +0000577 arm_compute::TensorInfo tensor_info(shape, 1, dt);
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100578 tensor.allocator()->init(tensor_info);
579 }
580
581 /** Fill a tensor with the content of the currently open NPY file.
582 *
583 * @note If the tensor is a CLTensor, the function maps and unmaps the tensor
584 *
585 * @param[in,out] tensor Tensor to fill (Must be allocated, and of matching dimensions with the opened NPY).
586 */
587 template <typename T>
588 void fill_tensor(T &tensor)
589 {
590 ARM_COMPUTE_ERROR_ON(!is_open());
Anthony Barbier6db0ff52018-01-05 10:59:12 +0000591 ARM_COMPUTE_ERROR_ON_DATA_TYPE_NOT_IN(&tensor, arm_compute::DataType::F32);
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100592 try
593 {
594 // Map buffer if creating a CLTensor
595 map(tensor, true);
596
597 // Check if the file is large enough to fill the tensor
598 const size_t current_position = _fs.tellg();
599 _fs.seekg(0, std::ios_base::end);
600 const size_t end_position = _fs.tellg();
601 _fs.seekg(current_position, std::ios_base::beg);
602
603 ARM_COMPUTE_ERROR_ON_MSG((end_position - current_position) < tensor.info()->tensor_shape().total_size() * tensor.info()->element_size(),
604 "Not enough data in file");
605 ARM_COMPUTE_UNUSED(end_position);
606
607 // Check if the typestring matches the given one
608 std::string expect_typestr = get_typestring(tensor.info()->data_type());
609 ARM_COMPUTE_ERROR_ON_MSG(_typestring != expect_typestr, "Typestrings mismatch");
610
611 // Validate tensor shape
Anthony Barbier6db0ff52018-01-05 10:59:12 +0000612 ARM_COMPUTE_ERROR_ON_MSG(_shape.size() != tensor.info()->tensor_shape().num_dimensions(), "Tensor ranks mismatch");
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100613 if(_fortran_order)
614 {
615 for(size_t i = 0; i < _shape.size(); ++i)
616 {
Anthony Barbier6db0ff52018-01-05 10:59:12 +0000617 ARM_COMPUTE_ERROR_ON_MSG(tensor.info()->tensor_shape()[i] != _shape[i], "Tensor dimensions mismatch");
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100618 }
619 }
620 else
621 {
622 for(size_t i = 0; i < _shape.size(); ++i)
623 {
Anthony Barbier6db0ff52018-01-05 10:59:12 +0000624 ARM_COMPUTE_ERROR_ON_MSG(tensor.info()->tensor_shape()[i] != _shape[_shape.size() - i - 1], "Tensor dimensions mismatch");
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100625 }
626 }
627
Gian Marco0bc5a252017-12-04 13:55:08 +0000628 switch(tensor.info()->data_type())
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100629 {
Gian Marco0bc5a252017-12-04 13:55:08 +0000630 case arm_compute::DataType::F32:
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100631 {
632 // Read data
633 if(tensor.info()->padding().empty())
634 {
635 // If tensor has no padding read directly from stream.
636 _fs.read(reinterpret_cast<char *>(tensor.buffer()), tensor.info()->total_size());
637 }
638 else
639 {
640 // If tensor has padding accessing tensor elements through execution window.
641 Window window;
642 window.use_tensor_dimensions(tensor.info()->tensor_shape());
643
644 execute_window_loop(window, [&](const Coordinates & id)
645 {
646 _fs.read(reinterpret_cast<char *>(tensor.ptr_to_element(id)), tensor.info()->element_size());
647 });
648 }
649
650 break;
651 }
652 default:
Gian Marco0bc5a252017-12-04 13:55:08 +0000653 ARM_COMPUTE_ERROR("Unsupported data type");
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100654 }
655
656 // Unmap buffer if creating a CLTensor
657 unmap(tensor);
658 }
659 catch(const std::ifstream::failure &e)
660 {
661 ARM_COMPUTE_ERROR("Loading NPY file: %s", e.what());
662 }
663 }
664
665private:
666 std::ifstream _fs;
667 std::vector<unsigned long> _shape;
668 bool _fortran_order;
669 std::string _typestring;
670};
671
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100672/** Template helper function to save a tensor image to a PPM file.
673 *
674 * @note Only U8 and RGB888 formats supported.
675 * @note Only works with 2D tensors.
676 * @note If the input tensor is a CLTensor, the function maps and unmaps the image
677 *
678 * @param[in] tensor The tensor to save as PPM file
679 * @param[in] ppm_filename Filename of the file to create.
680 */
681template <typename T>
682void save_to_ppm(T &tensor, const std::string &ppm_filename)
683{
684 ARM_COMPUTE_ERROR_ON_FORMAT_NOT_IN(&tensor, arm_compute::Format::RGB888, arm_compute::Format::U8);
685 ARM_COMPUTE_ERROR_ON(tensor.info()->num_dimensions() > 2);
686
687 std::ofstream fs;
688
689 try
690 {
691 fs.exceptions(std::ofstream::failbit | std::ofstream::badbit | std::ofstream::eofbit);
692 fs.open(ppm_filename, std::ios::out | std::ios::binary);
693
694 const unsigned int width = tensor.info()->tensor_shape()[0];
695 const unsigned int height = tensor.info()->tensor_shape()[1];
696
697 fs << "P6\n"
698 << width << " " << height << " 255\n";
699
Anthony Barbier7068f992017-10-26 15:23:08 +0100700 // Map buffer if creating a CLTensor/GCTensor
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100701 map(tensor, true);
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100702
703 switch(tensor.info()->format())
704 {
705 case arm_compute::Format::U8:
706 {
707 arm_compute::Window window;
708 window.set(arm_compute::Window::DimX, arm_compute::Window::Dimension(0, width, 1));
709 window.set(arm_compute::Window::DimY, arm_compute::Window::Dimension(0, height, 1));
710
711 arm_compute::Iterator in(&tensor, window);
712
713 arm_compute::execute_window_loop(window, [&](const arm_compute::Coordinates & id)
714 {
715 const unsigned char value = *in.ptr();
716
717 fs << value << value << value;
718 },
719 in);
720
721 break;
722 }
723 case arm_compute::Format::RGB888:
724 {
725 arm_compute::Window window;
726 window.set(arm_compute::Window::DimX, arm_compute::Window::Dimension(0, width, width));
727 window.set(arm_compute::Window::DimY, arm_compute::Window::Dimension(0, height, 1));
728
729 arm_compute::Iterator in(&tensor, window);
730
731 arm_compute::execute_window_loop(window, [&](const arm_compute::Coordinates & id)
732 {
733 fs.write(reinterpret_cast<std::fstream::char_type *>(in.ptr()), width * tensor.info()->element_size());
734 },
735 in);
736
737 break;
738 }
739 default:
740 ARM_COMPUTE_ERROR("Unsupported format");
741 }
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100742
Anthony Barbier7068f992017-10-26 15:23:08 +0100743 // Unmap buffer if creating a CLTensor/GCTensor
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100744 unmap(tensor);
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100745 }
746 catch(const std::ofstream::failure &e)
747 {
748 ARM_COMPUTE_ERROR("Writing %s: (%s)", ppm_filename.c_str(), e.what());
749 }
750}
steniu01bee466b2017-06-21 16:45:41 +0100751
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100752/** Template helper function to save a tensor image to a NPY file.
753 *
Gian Marcobfa3b522017-12-12 10:08:38 +0000754 * @note Only F32 data type supported.
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100755 * @note Only works with 2D tensors.
756 * @note If the input tensor is a CLTensor, the function maps and unmaps the image
757 *
758 * @param[in] tensor The tensor to save as NPY file
759 * @param[in] npy_filename Filename of the file to create.
760 * @param[in] fortran_order If true, save matrix in fortran order.
761 */
762template <typename T>
763void save_to_npy(T &tensor, const std::string &npy_filename, bool fortran_order)
764{
Gian Marcobfa3b522017-12-12 10:08:38 +0000765 ARM_COMPUTE_ERROR_ON_DATA_TYPE_NOT_IN(&tensor, arm_compute::DataType::F32);
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100766 ARM_COMPUTE_ERROR_ON(tensor.info()->num_dimensions() > 2);
767
768 std::ofstream fs;
769
770 try
771 {
772 fs.exceptions(std::ofstream::failbit | std::ofstream::badbit | std::ofstream::eofbit);
773 fs.open(npy_filename, std::ios::out | std::ios::binary);
774
Anthony Barbier87f21cd2017-11-10 16:27:32 +0000775 const unsigned int width = tensor.info()->tensor_shape()[0];
776 const unsigned int height = tensor.info()->tensor_shape()[1];
777 std::vector<npy::ndarray_len_t> shape(2);
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100778
779 if(!fortran_order)
780 {
781 shape[0] = height, shape[1] = width;
782 }
783 else
784 {
785 shape[0] = width, shape[1] = height;
786 }
787
788 // Map buffer if creating a CLTensor
789 map(tensor, true);
790
Gian Marcobfa3b522017-12-12 10:08:38 +0000791 switch(tensor.info()->data_type())
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100792 {
Gian Marcobfa3b522017-12-12 10:08:38 +0000793 case arm_compute::DataType::F32:
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100794 {
795 std::vector<float> tmp; /* Used only to get the typestring */
796 npy::Typestring typestring_o{ tmp };
797 std::string typestring = typestring_o.str();
798
799 std::ofstream stream(npy_filename, std::ofstream::binary);
Anthony Barbier87f21cd2017-11-10 16:27:32 +0000800 npy::write_header(stream, typestring, fortran_order, shape);
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100801
802 arm_compute::Window window;
803 window.set(arm_compute::Window::DimX, arm_compute::Window::Dimension(0, width, 1));
804 window.set(arm_compute::Window::DimY, arm_compute::Window::Dimension(0, height, 1));
805
806 arm_compute::Iterator in(&tensor, window);
807
808 arm_compute::execute_window_loop(window, [&](const arm_compute::Coordinates & id)
809 {
810 stream.write(reinterpret_cast<const char *>(in.ptr()), sizeof(float));
811 },
812 in);
813
814 break;
815 }
816 default:
817 ARM_COMPUTE_ERROR("Unsupported format");
818 }
819
820 // Unmap buffer if creating a CLTensor
821 unmap(tensor);
822 }
823 catch(const std::ofstream::failure &e)
824 {
825 ARM_COMPUTE_ERROR("Writing %s: (%s)", npy_filename.c_str(), e.what());
826 }
827}
828
steniu01bee466b2017-06-21 16:45:41 +0100829/** Load the tensor with pre-trained data from a binary file
830 *
831 * @param[in] tensor The tensor to be filled. Data type supported: F32.
832 * @param[in] filename Filename of the binary file to load from.
833 */
834template <typename T>
835void load_trained_data(T &tensor, const std::string &filename)
836{
837 ARM_COMPUTE_ERROR_ON_DATA_TYPE_CHANNEL_NOT_IN(&tensor, 1, DataType::F32);
838
839 std::ifstream fs;
840
841 try
842 {
843 fs.exceptions(std::ofstream::failbit | std::ofstream::badbit | std::ofstream::eofbit);
844 // Open file
845 fs.open(filename, std::ios::in | std::ios::binary);
846
847 if(!fs.good())
848 {
849 throw std::runtime_error("Could not load binary data: " + filename);
850 }
851
Anthony Barbier7068f992017-10-26 15:23:08 +0100852 // Map buffer if creating a CLTensor/GCTensor
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100853 map(tensor, true);
854
steniu01bee466b2017-06-21 16:45:41 +0100855 Window window;
856
857 window.set(arm_compute::Window::DimX, arm_compute::Window::Dimension(0, 1, 1));
858
859 for(unsigned int d = 1; d < tensor.info()->num_dimensions(); ++d)
860 {
861 window.set(d, Window::Dimension(0, tensor.info()->tensor_shape()[d], 1));
862 }
863
864 arm_compute::Iterator in(&tensor, window);
865
866 execute_window_loop(window, [&](const Coordinates & id)
867 {
868 fs.read(reinterpret_cast<std::fstream::char_type *>(in.ptr()), tensor.info()->tensor_shape()[0] * tensor.info()->element_size());
869 },
870 in);
871
Anthony Barbier7068f992017-10-26 15:23:08 +0100872 // Unmap buffer if creating a CLTensor/GCTensor
Georgios Pinitasdc836b62017-09-20 14:02:37 +0100873 unmap(tensor);
steniu01bee466b2017-06-21 16:45:41 +0100874 }
875 catch(const std::ofstream::failure &e)
876 {
877 ARM_COMPUTE_ERROR("Writing %s: (%s)", filename.c_str(), e.what());
878 }
879}
880
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100881template <typename T>
882void fill_random_tensor(T &tensor, float lower_bound, float upper_bound)
Anthony Barbier2a07e182017-08-04 18:20:27 +0100883{
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100884 std::random_device rd;
885 std::mt19937 gen(rd());
Anthony Barbier2a07e182017-08-04 18:20:27 +0100886
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100887 Window window;
Michalis Spyrou5e69bb42018-03-09 16:36:00 +0000888 window.use_tensor_dimensions(tensor.info()->tensor_shape());
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100889
890 map(tensor, true);
891
892 Iterator it(&tensor, window);
893
Gian Marcobfa3b522017-12-12 10:08:38 +0000894 switch(tensor.info()->data_type())
Anthony Barbier2a07e182017-08-04 18:20:27 +0100895 {
Gian Marcobfa3b522017-12-12 10:08:38 +0000896 case arm_compute::DataType::F32:
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100897 {
898 std::uniform_real_distribution<float> dist(lower_bound, upper_bound);
899
900 execute_window_loop(window, [&](const Coordinates & id)
901 {
902 *reinterpret_cast<float *>(it.ptr()) = dist(gen);
903 },
904 it);
905
906 break;
907 }
Anthony Barbier2a07e182017-08-04 18:20:27 +0100908 default:
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100909 {
910 ARM_COMPUTE_ERROR("Unsupported format");
911 }
Anthony Barbier2a07e182017-08-04 18:20:27 +0100912 }
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100913
914 unmap(tensor);
Anthony Barbier2a07e182017-08-04 18:20:27 +0100915}
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100916
917template <typename T>
Gian Marco0bc5a252017-12-04 13:55:08 +0000918void init_sgemm_output(T &dst, T &src0, T &src1, arm_compute::DataType dt)
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100919{
Gian Marco0bc5a252017-12-04 13:55:08 +0000920 dst.allocator()->init(TensorInfo(TensorShape(src1.info()->dimension(0), src0.info()->dimension(1)), 1, dt));
Giorgio Arenacf3935f2017-10-26 17:14:13 +0100921}
Gian Marco5ca74092018-02-08 16:21:54 +0000922/** This function returns the amount of memory free reading from /proc/meminfo
923 *
924 * @return The free memory in kB
925 */
926uint64_t get_mem_free_from_meminfo();
Isabella Gottardi88d5b222018-04-06 12:24:55 +0100927
928/** Compare to tensor
929 *
930 * @param[in] tensor1 First tensor to be compared.
931 * @param[in] tensor2 Second tensor to be compared.
932 *
933 * @return The number of mismatches
934 */
935template <typename T>
936int compare_tensor(ITensor &tensor1, ITensor &tensor2)
937{
938 ARM_COMPUTE_ERROR_ON_MISMATCHING_DATA_TYPES(&tensor1, &tensor2);
939 ARM_COMPUTE_ERROR_ON_MISMATCHING_SHAPES(&tensor1, &tensor2);
940
941 int num_mismatches = 0;
942 Window window;
943 window.use_tensor_dimensions(tensor1.info()->tensor_shape());
944
945 map(tensor1, true);
946 map(tensor2, true);
947 Iterator itensor1(&tensor1, window);
948 Iterator itensor2(&tensor2, window);
949
950 execute_window_loop(window, [&](const Coordinates & id)
951 {
952 if(std::abs(*reinterpret_cast<T *>(itensor1.ptr()) - *reinterpret_cast<T *>(itensor2.ptr())) > 0.00001)
953 {
954 ++num_mismatches;
955 }
956 },
957 itensor1, itensor2);
958
959 unmap(itensor1);
960 unmap(itensor2);
961
962 return num_mismatches;
963}
Anthony Barbier6ff3b192017-09-04 18:44:23 +0100964} // namespace utils
965} // namespace arm_compute
966#endif /* __UTILS_UTILS_H__*/