aboutsummaryrefslogtreecommitdiff
path: root/src/profiling/ProfilingConnectionDumpToFileDecorator.hpp
blob: c2ae5381382b07240c90b02ff4cf5d6cca249464 (plain)
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
//
// Copyright © 2019 Arm Ltd. All rights reserved.
// SPDX-License-Identifier: MIT
//

#pragma once

#include "IProfilingConnection.hpp"

#include <armnn/Optional.hpp>

#include <fstream>
#include <memory>
#include <string>
#include <vector>

namespace armnn
{

namespace profiling
{

class ProfilingConnectionDumpToFileDecorator : public IProfilingConnection
{
public:
    struct Settings
    {
        Settings(const std::string& incomingDumpFileName = "",
                 const std::string& outgoingDumpFileName = "",
                 bool ignoreFileErrors = true)
            : m_IncomingDumpFileName(incomingDumpFileName)
            , m_OutgoingDumpFileName(outgoingDumpFileName)
            , m_DumpIncoming(!incomingDumpFileName.empty())
            , m_DumpOutgoing(!outgoingDumpFileName.empty())
            , m_IgnoreFileErrors(ignoreFileErrors)
        {}

        ~Settings() = default;

        std::string m_IncomingDumpFileName;
        std::string m_OutgoingDumpFileName;
        bool        m_DumpIncoming;
        bool        m_DumpOutgoing;
        bool        m_IgnoreFileErrors;
    };

    ProfilingConnectionDumpToFileDecorator(std::unique_ptr<IProfilingConnection> connection,
                                           const Settings& settings);

    ~ProfilingConnectionDumpToFileDecorator();

    bool IsOpen() const override;

    void Close() override;

    bool WritePacket(const unsigned char* buffer, uint32_t length) override;

    Packet ReadPacket(uint32_t timeout) override;

private:
    bool OpenIncomingDumpFile();

    bool OpenOutgoingDumpFile();

    void DumpIncomingToFile(const Packet& packet);

    bool DumpOutgoingToFile(const char* buffer, uint32_t length);

    void Fail(const std::string& errorMessage);

    std::unique_ptr<IProfilingConnection> m_Connection;
    Settings                              m_Settings;
    std::ofstream                         m_IncomingDumpFileStream;
    std::ofstream                         m_OutgoingDumpFileStream;
};

using ProfilingConnectionDumpToFileDecoratorSettings = ProfilingConnectionDumpToFileDecorator::Settings;

} // namespace profiling

} // namespace armnn