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
|
//
// Copyright © 2019 Arm Ltd. All rights reserved.
// SPDX-License-Identifier: MIT
//
#pragma once
#include "../SendCounterPacket.hpp"
#include "../ProfilingUtils.hpp"
#include <armnn/Exceptions.hpp>
#include <boost/test/unit_test.hpp>
#include <chrono>
#include <iostream>
using namespace armnn::profiling;
class MockBuffer : public IBufferWrapper
{
public:
MockBuffer(unsigned int size)
: m_BufferSize(size),
m_Buffer(std::make_unique<unsigned char[]>(size)) {}
unsigned char* Reserve(unsigned int requestedSize, unsigned int& reservedSize) override
{
if (requestedSize > m_BufferSize)
{
reservedSize = m_BufferSize;
}
else
{
reservedSize = requestedSize;
}
return m_Buffer.get();
}
void Commit(unsigned int size) override {}
const unsigned char* GetReadBuffer(unsigned int& size) override
{
size = static_cast<unsigned int>(strlen(reinterpret_cast<const char*>(m_Buffer.get())) + 1);
return m_Buffer.get();
}
void Release( unsigned int size) override {}
private:
unsigned int m_BufferSize;
std::unique_ptr<unsigned char[]> m_Buffer;
};
class MockSendCounterPacket : public ISendCounterPacket
{
public:
MockSendCounterPacket(IBufferWrapper& sendBuffer) : m_Buffer(sendBuffer) {}
void SendStreamMetaDataPacket() override
{
std::string message("SendStreamMetaDataPacket");
unsigned int reserved = 0;
unsigned char* buffer = m_Buffer.Reserve(1024, reserved);
memcpy(buffer, message.c_str(), static_cast<unsigned int>(message.size()) + 1);
}
void SendCounterDirectoryPacket(const CounterDirectory& counterDirectory) override
{
std::string message("SendCounterDirectoryPacket");
unsigned int reserved = 0;
unsigned char* buffer = m_Buffer.Reserve(1024, reserved);
memcpy(buffer, message.c_str(), static_cast<unsigned int>(message.size()) + 1);
}
void SendPeriodicCounterCapturePacket(uint64_t timestamp,
const std::vector<std::pair<uint16_t, uint32_t>>& values) override
{
std::string message("SendPeriodicCounterCapturePacket");
unsigned int reserved = 0;
unsigned char* buffer = m_Buffer.Reserve(1024, reserved);
memcpy(buffer, message.c_str(), static_cast<unsigned int>(message.size()) + 1);
}
void SendPeriodicCounterSelectionPacket(uint32_t capturePeriod,
const std::vector<uint16_t>& selectedCounterIds) override
{
std::string message("SendPeriodicCounterSelectionPacket");
unsigned int reserved = 0;
unsigned char* buffer = m_Buffer.Reserve(1024, reserved);
memcpy(buffer, message.c_str(), static_cast<unsigned int>(message.size()) + 1);
m_Buffer.Commit(reserved);
}
void SetReadyToRead() override
{}
private:
IBufferWrapper& m_Buffer;
};
|
